pubsub_bench

README

Regenerating protos

cd pubsub/internal/benchwrapper/proto
protoc --go_out=plugins=grpc:. *.proto

Documentation

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)