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
Package-Level Type Names (total 10)
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 Functions (total 2)
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"![]() |
The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds. |