package pubsub_bench

import "cloud.google.com/go/pubsub/internal/benchwrapper/proto"

Index ¶

• Constants
• Variables
• func RegisterPubsubBenchWrapperServer(s grpc.ServiceRegistrar, srv PubsubBenchWrapperServer)
• type EmptyResponse
• func (*EmptyResponse) Descriptor() ([]byte, []int)
• func (*EmptyResponse) ProtoMessage()
• func (x *EmptyResponse) ProtoReflect() protoreflect.Message
• func (x *EmptyResponse) Reset()
• func (x *EmptyResponse) String() string
• type PubsubBenchWrapperClient
• func NewPubsubBenchWrapperClient(cc grpc.ClientConnInterface) PubsubBenchWrapperClient
• type PubsubBenchWrapperServer
• type PubsubRecv
• func (*PubsubRecv) Descriptor() ([]byte, []int)
• func (x *PubsubRecv) GetSubName() string
• func (*PubsubRecv) ProtoMessage()
• func (x *PubsubRecv) ProtoReflect() protoreflect.Message
• func (x *PubsubRecv) Reset()
• func (x *PubsubRecv) String() string
• type UnimplementedPubsubBenchWrapperServer
• func (UnimplementedPubsubBenchWrapperServer) Recv(context.Context, *PubsubRecv) (*EmptyResponse, error)
• type UnsafePubsubBenchWrapperServer

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 ¶

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 ¶

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 ¶

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 ¶

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 ¶

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.

Source Files ¶

pubsub.pb.go pubsub_grpc.pb.go