▽

Package pubsub_bench

Constants ¶

const (
    PubsubBenchWrapper_Recv_FullMethodName = "/pubsub_bench.PubsubBenchWrapper/Recv"
)

Variables ¶

var File_pubsub_proto protoreflect.FileDescriptor

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)

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",
}

func RegisterPubsubBenchWrapperServer ¶

func RegisterPubsubBenchWrapperServer(s grpc.ServiceRegistrar, srv PubsubBenchWrapperServer)

type EmptyResponse ¶

TODO(deklerk): Replace with Google's canonical Empty.

type EmptyResponse struct {
    // contains filtered or unexported fields
}

func (*EmptyResponse) Descriptor ¶

func (*EmptyResponse) Descriptor() ([]byte, []int)

Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.

func (*EmptyResponse) ProtoMessage ¶

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) ProtoReflect ¶

func (x *EmptyResponse) ProtoReflect() protoreflect.Message

func (*EmptyResponse) Reset ¶

func (x *EmptyResponse) Reset()

func (*EmptyResponse) String ¶

func (x *EmptyResponse) String() string

type PubsubBenchWrapperClient ¶

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.

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)
}

func NewPubsubBenchWrapperClient ¶

func NewPubsubBenchWrapperClient(cc grpc.ClientConnInterface) PubsubBenchWrapperClient

type PubsubBenchWrapperServer ¶

PubsubBenchWrapperServer is the server API for PubsubBenchWrapper service. All implementations must embed UnimplementedPubsubBenchWrapperServer for forward compatibility

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
}

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 ¶

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 ¶

func (x *PubsubRecv) ProtoReflect() protoreflect.Message

func (*PubsubRecv) Reset ¶

func (x *PubsubRecv) Reset()

func (*PubsubRecv) String ¶

func (x *PubsubRecv) String() string

type UnimplementedPubsubBenchWrapperServer ¶

UnimplementedPubsubBenchWrapperServer must be embedded to have forward compatible implementations.

type UnimplementedPubsubBenchWrapperServer struct {
}

func (UnimplementedPubsubBenchWrapperServer) Recv ¶

func (UnimplementedPubsubBenchWrapperServer) Recv(context.Context, *PubsubRecv) (*EmptyResponse, error)

type UnsafePubsubBenchWrapperServer ¶

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.

type UnsafePubsubBenchWrapperServer interface {
    // contains filtered or unexported methods
}