package worker_proto

Import Path
	github.com/pancsta/asyncmachine-go/examples/benchmark_grpc/worker_proto (on go.dev)

Dependency Relation
	imports 8 packages, and imported by 0 packages

Involved Source Files worker.pb.go worker_grpc.pb.go
Package-Level Type Names (total 10)
/* sort by: | */
Op int32 Deprecated: Use CallOpRequest.ProtoReflect.Descriptor instead. (*CallOpRequest) GetOp() int32 (*CallOpRequest) ProtoMessage() (*CallOpRequest) ProtoReflect() protoreflect.Message (*CallOpRequest) Reset() (*CallOpRequest) String() string *CallOpRequest : github.com/gogo/protobuf/proto.Message *CallOpRequest : expvar.Var *CallOpRequest : fmt.Stringer *CallOpRequest : google.golang.org/protobuf/reflect/protoreflect.ProtoMessage *CallOpRequest : google.golang.org/protobuf/runtime/protoiface.MessageV1 func UnimplementedWorkerServiceServer.CallOp(context.Context, *CallOpRequest) (*CallOpResponse, error) func WorkerServiceClient.CallOp(ctx context.Context, in *CallOpRequest, opts ...grpc.CallOption) (*CallOpResponse, error) func WorkerServiceServer.CallOp(context.Context, *CallOpRequest) (*CallOpResponse, error)
Success bool Deprecated: Use CallOpResponse.ProtoReflect.Descriptor instead. (*CallOpResponse) GetSuccess() bool (*CallOpResponse) ProtoMessage() (*CallOpResponse) ProtoReflect() protoreflect.Message (*CallOpResponse) Reset() (*CallOpResponse) String() string *CallOpResponse : github.com/gogo/protobuf/proto.Message *CallOpResponse : expvar.Var *CallOpResponse : fmt.Stringer *CallOpResponse : google.golang.org/protobuf/reflect/protoreflect.ProtoMessage *CallOpResponse : google.golang.org/protobuf/runtime/protoiface.MessageV1 func UnimplementedWorkerServiceServer.CallOp(context.Context, *CallOpRequest) (*CallOpResponse, error) func WorkerServiceClient.CallOp(ctx context.Context, in *CallOpRequest, opts ...grpc.CallOption) (*CallOpResponse, error) func WorkerServiceServer.CallOp(context.Context, *CallOpRequest) (*CallOpResponse, error)
Deprecated: Use Empty.ProtoReflect.Descriptor instead. (*Empty) ProtoMessage() (*Empty) ProtoReflect() protoreflect.Message (*Empty) Reset() (*Empty) String() string *Empty : github.com/gogo/protobuf/proto.Message *Empty : expvar.Var *Empty : fmt.Stringer *Empty : google.golang.org/protobuf/reflect/protoreflect.ProtoMessage *Empty : google.golang.org/protobuf/runtime/protoiface.MessageV1 func UnimplementedWorkerServiceServer.Start(context.Context, *Empty) (*Empty, error) func WorkerServiceClient.Start(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) func WorkerServiceServer.Start(context.Context, *Empty) (*Empty, error) func UnimplementedWorkerServiceServer.GetValue(context.Context, *Empty) (*GetValueResponse, error) func UnimplementedWorkerServiceServer.Start(context.Context, *Empty) (*Empty, error) func UnimplementedWorkerServiceServer.Subscribe(*Empty, grpc.ServerStreamingServer[Empty]) error func WorkerServiceClient.GetValue(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetValueResponse, error) func WorkerServiceClient.Start(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) func WorkerServiceClient.Subscribe(ctx context.Context, in *Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Empty], error) func WorkerServiceServer.GetValue(context.Context, *Empty) (*GetValueResponse, error) func WorkerServiceServer.Start(context.Context, *Empty) (*Empty, error) func WorkerServiceServer.Subscribe(*Empty, grpc.ServerStreamingServer[Empty]) error
Value int32 Deprecated: Use GetValueResponse.ProtoReflect.Descriptor instead. (*GetValueResponse) GetValue() int32 (*GetValueResponse) ProtoMessage() (*GetValueResponse) ProtoReflect() protoreflect.Message (*GetValueResponse) Reset() (*GetValueResponse) String() string *GetValueResponse : github.com/gogo/protobuf/proto.Message *GetValueResponse : expvar.Var *GetValueResponse : fmt.Stringer *GetValueResponse : google.golang.org/protobuf/reflect/protoreflect.ProtoMessage *GetValueResponse : google.golang.org/protobuf/runtime/protoiface.MessageV1 func UnimplementedWorkerServiceServer.GetValue(context.Context, *Empty) (*GetValueResponse, error) func WorkerServiceClient.GetValue(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetValueResponse, error) func WorkerServiceServer.GetValue(context.Context, *Empty) (*GetValueResponse, error)
UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations. NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called. ( UnimplementedWorkerServiceServer) CallOp(context.Context, *CallOpRequest) (*CallOpResponse, error) ( UnimplementedWorkerServiceServer) GetValue(context.Context, *Empty) (*GetValueResponse, error) ( UnimplementedWorkerServiceServer) Start(context.Context, *Empty) (*Empty, error) ( UnimplementedWorkerServiceServer) Subscribe(*Empty, grpc.ServerStreamingServer[Empty]) error UnimplementedWorkerServiceServer : UnsafeWorkerServiceServer UnimplementedWorkerServiceServer : WorkerServiceServer
UnsafeWorkerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServiceServer will result in compilation errors. UnimplementedWorkerServiceServer WorkerServiceServer (interface)
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
WorkerServiceClient is the client API for WorkerService service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. ( WorkerServiceClient) CallOp(ctx context.Context, in *CallOpRequest, opts ...grpc.CallOption) (*CallOpResponse, error) ( WorkerServiceClient) GetValue(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetValueResponse, error) ( WorkerServiceClient) Start(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) ( WorkerServiceClient) Subscribe(ctx context.Context, in *Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Empty], error) func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient
WorkerServiceServer is the server API for WorkerService service. All implementations must embed UnimplementedWorkerServiceServer for forward compatibility. ( WorkerServiceServer) CallOp(context.Context, *CallOpRequest) (*CallOpResponse, error) ( WorkerServiceServer) GetValue(context.Context, *Empty) (*GetValueResponse, error) ( WorkerServiceServer) Start(context.Context, *Empty) (*Empty, error) ( WorkerServiceServer) Subscribe(*Empty, grpc.ServerStreamingServer[Empty]) error UnimplementedWorkerServiceServer WorkerServiceServer : UnsafeWorkerServiceServer func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)
Package-Level Variables (total 2)
WorkerService_ServiceDesc is the grpc.ServiceDesc for WorkerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Package-Level Constants (total 4)
const WorkerService_CallOp_FullMethodName = "/worker.WorkerService/CallOp"
const WorkerService_GetValue_FullMethodName = "/worker.WorkerService/GetValue"
const WorkerService_Start_FullMethodName = "/worker.WorkerService/Start"
const WorkerService_Subscribe_FullMethodName = "/worker.WorkerService/Subscribe"