package proto

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

Dependency Relation
	imports 8 packages, and imported by one package

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) func github.com/pancsta/asyncmachine-go/examples/benchmark_grpc.(*WorkerServiceServer).CallOp(ctx context.Context, req *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) func github.com/pancsta/asyncmachine-go/examples/benchmark_grpc.(*WorkerServiceServer).CallOp(ctx context.Context, req *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 github.com/pancsta/asyncmachine-go/examples/benchmark_grpc.(*WorkerServiceServer).Start(ctx context.Context, req *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 func github.com/pancsta/asyncmachine-go/examples/benchmark_grpc.(*WorkerServiceServer).GetValue(ctx context.Context, req *Empty) (*GetValueResponse, error) func github.com/pancsta/asyncmachine-go/examples/benchmark_grpc.(*WorkerServiceServer).Start(ctx context.Context, req *Empty) (*Empty, error) func github.com/pancsta/asyncmachine-go/examples/benchmark_grpc.(*WorkerServiceServer).Subscribe(req *Empty, stream WorkerService_SubscribeServer) 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) func github.com/pancsta/asyncmachine-go/examples/benchmark_grpc.(*WorkerServiceServer).GetValue(ctx context.Context, req *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) github.com/pancsta/asyncmachine-go/examples/benchmark_grpc.WorkerServiceServer
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 *github.com/pancsta/asyncmachine-go/examples/benchmark_grpc.WorkerServiceServer 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 = "/proto.WorkerService/CallOp"
const WorkerService_GetValue_FullMethodName = "/proto.WorkerService/GetValue"
const WorkerService_Start_FullMethodName = "/proto.WorkerService/Start"
const WorkerService_Subscribe_FullMethodName = "/proto.WorkerService/Subscribe"