package pubsub_bench

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

Index ¶

• func RegisterPubsubBenchWrapperServer(s *grpc.Server, srv PubsubBenchWrapperServer)
• type EmptyResponse
• func (*EmptyResponse) Descriptor() ([]byte, []int)
• func (*EmptyResponse) ProtoMessage()
• func (m *EmptyResponse) Reset()
• func (m *EmptyResponse) String() string
• func (m *EmptyResponse) XXX_DiscardUnknown()
• func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
• func (m *EmptyResponse) XXX_Merge(src proto.Message)
• func (m *EmptyResponse) XXX_Size() int
• func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
• type PubsubBenchWrapperClient
• func NewPubsubBenchWrapperClient(cc *grpc.ClientConn) PubsubBenchWrapperClient
• type PubsubBenchWrapperServer
• type PubsubRecv
• func (*PubsubRecv) Descriptor() ([]byte, []int)
• func (m *PubsubRecv) GetSubName() string
• func (*PubsubRecv) ProtoMessage()
• func (m *PubsubRecv) Reset()
• func (m *PubsubRecv) String() string
• func (m *PubsubRecv) XXX_DiscardUnknown()
• func (m *PubsubRecv) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
• func (m *PubsubRecv) XXX_Merge(src proto.Message)
• func (m *PubsubRecv) XXX_Size() int
• func (m *PubsubRecv) XXX_Unmarshal(b []byte) error
• type UnimplementedPubsubBenchWrapperServer
• func (*UnimplementedPubsubBenchWrapperServer) Recv(ctx context.Context, req *PubsubRecv) (*EmptyResponse, error)

Functions ¶

func RegisterPubsubBenchWrapperServer ¶

func RegisterPubsubBenchWrapperServer(s *grpc.Server, srv PubsubBenchWrapperServer)

Types ¶

type EmptyResponse ¶

type EmptyResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*EmptyResponse) Descriptor ¶

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

func (*EmptyResponse) ProtoMessage ¶

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset ¶

func (m *EmptyResponse) Reset()

func (*EmptyResponse) String ¶

func (m *EmptyResponse) String() string

func (*EmptyResponse) XXX_DiscardUnknown ¶

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal ¶

func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptyResponse) XXX_Merge ¶

func (m *EmptyResponse) XXX_Merge(src proto.Message)

func (*EmptyResponse) XXX_Size ¶

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal ¶

func (m *EmptyResponse) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPubsubBenchWrapperClient ¶

func NewPubsubBenchWrapperClient(cc *grpc.ClientConn) PubsubBenchWrapperClient

type PubsubBenchWrapperServer ¶

type PubsubBenchWrapperServer interface {
	// Recv represents opening a streaming pull stream to receive messages on.
	Recv(context.Context, *PubsubRecv) (*EmptyResponse, error)
}

PubsubBenchWrapperServer is the server API for PubsubBenchWrapper service.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubsubRecv) Descriptor ¶

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

func (*PubsubRecv) GetSubName ¶

func (m *PubsubRecv) GetSubName() string

func (*PubsubRecv) ProtoMessage ¶

func (*PubsubRecv) ProtoMessage()

func (*PubsubRecv) Reset ¶

func (m *PubsubRecv) Reset()

func (*PubsubRecv) String ¶

func (m *PubsubRecv) String() string

func (*PubsubRecv) XXX_DiscardUnknown ¶

func (m *PubsubRecv) XXX_DiscardUnknown()

func (*PubsubRecv) XXX_Marshal ¶

func (m *PubsubRecv) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubsubRecv) XXX_Merge ¶

func (m *PubsubRecv) XXX_Merge(src proto.Message)

func (*PubsubRecv) XXX_Size ¶

func (m *PubsubRecv) XXX_Size() int

func (*PubsubRecv) XXX_Unmarshal ¶

func (m *PubsubRecv) XXX_Unmarshal(b []byte) error

type UnimplementedPubsubBenchWrapperServer ¶

type UnimplementedPubsubBenchWrapperServer struct {
}

UnimplementedPubsubBenchWrapperServer can be embedded to have forward compatible implementations.

func (*UnimplementedPubsubBenchWrapperServer) Recv ¶

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

Source Files ¶

pubsub.pb.go