Documentation
¶
Index ¶
Constants ¶
const (
PubsubBenchWrapper_Recv_FullMethodName = "/pubsub_bench.PubsubBenchWrapper/Recv"
)
Variables ¶
var File_pubsub_proto protoreflect.FileDescriptor
var PubsubBenchWrapper_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pubsub_bench.PubsubBenchWrapper", HandlerType: (*PubsubBenchWrapperServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Recv", Handler: _PubsubBenchWrapper_Recv_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pubsub.proto", }
PubsubBenchWrapper_ServiceDesc is the grpc.ServiceDesc for PubsubBenchWrapper service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPubsubBenchWrapperServer ¶
func RegisterPubsubBenchWrapperServer(s grpc.ServiceRegistrar, srv PubsubBenchWrapperServer)
Types ¶
type EmptyResponse ¶
type EmptyResponse struct {
// contains filtered or unexported fields
}
TODO(deklerk): Replace with Google's canonical Empty.
func (*EmptyResponse) Descriptor
deprecated
func (*EmptyResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.
func (*EmptyResponse) ProtoMessage ¶
func (*EmptyResponse) ProtoMessage()
func (*EmptyResponse) ProtoReflect ¶ added in v1.38.0
func (x *EmptyResponse) ProtoReflect() protoreflect.Message
func (*EmptyResponse) Reset ¶
func (x *EmptyResponse) Reset()
func (*EmptyResponse) String ¶
func (x *EmptyResponse) String() string
type PubsubBenchWrapperClient ¶
type PubsubBenchWrapperClient interface { // Recv represents opening a streaming pull stream to receive messages on. Recv(ctx context.Context, in *PubsubRecv, opts ...grpc.CallOption) (*EmptyResponse, error) }
PubsubBenchWrapperClient is the client API for PubsubBenchWrapper 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.
func NewPubsubBenchWrapperClient ¶
func NewPubsubBenchWrapperClient(cc grpc.ClientConnInterface) PubsubBenchWrapperClient
type PubsubBenchWrapperServer ¶
type PubsubBenchWrapperServer interface { // Recv represents opening a streaming pull stream to receive messages on. Recv(context.Context, *PubsubRecv) (*EmptyResponse, error) // contains filtered or unexported methods }
PubsubBenchWrapperServer is the server API for PubsubBenchWrapper service. All implementations must embed UnimplementedPubsubBenchWrapperServer for forward compatibility
type PubsubRecv ¶
type PubsubRecv struct { // The subscription identifier corresponding to number of messages sent. SubName string `protobuf:"bytes,1,opt,name=sub_name,json=subName,proto3" json:"sub_name,omitempty"` // contains filtered or unexported fields }
func (*PubsubRecv) Descriptor
deprecated
func (*PubsubRecv) Descriptor() ([]byte, []int)
Deprecated: Use PubsubRecv.ProtoReflect.Descriptor instead.
func (*PubsubRecv) GetSubName ¶
func (x *PubsubRecv) GetSubName() string
func (*PubsubRecv) ProtoMessage ¶
func (*PubsubRecv) ProtoMessage()
func (*PubsubRecv) ProtoReflect ¶ added in v1.38.0
func (x *PubsubRecv) ProtoReflect() protoreflect.Message
func (*PubsubRecv) Reset ¶
func (x *PubsubRecv) Reset()
func (*PubsubRecv) String ¶
func (x *PubsubRecv) String() string
type UnimplementedPubsubBenchWrapperServer ¶
type UnimplementedPubsubBenchWrapperServer struct { }
UnimplementedPubsubBenchWrapperServer must be embedded to have forward compatible implementations.
func (UnimplementedPubsubBenchWrapperServer) Recv ¶
func (UnimplementedPubsubBenchWrapperServer) Recv(context.Context, *PubsubRecv) (*EmptyResponse, error)
type UnsafePubsubBenchWrapperServer ¶ added in v1.38.0
type UnsafePubsubBenchWrapperServer interface {
// contains filtered or unexported methods
}
UnsafePubsubBenchWrapperServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PubsubBenchWrapperServer will result in compilation errors.