go: cloud.google.com/go/pubsub/internal/benchwrapper/proto Index | Files

package pubsub_bench

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

Index

Package Files

pubsub.pb.go

func RegisterPubsubBenchWrapperServer Uses

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

type EmptyResponse Uses

❖
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 Uses

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

func (*EmptyResponse) ProtoMessage Uses

❖
func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset Uses

❖
func (m *EmptyResponse) Reset()

func (*EmptyResponse) String Uses

❖
func (m *EmptyResponse) String() string

func (*EmptyResponse) XXX_DiscardUnknown Uses

❖
func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal Uses

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

func (*EmptyResponse) XXX_Merge Uses

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

func (*EmptyResponse) XXX_Size Uses

❖
func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal Uses

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

type PubsubBenchWrapperClient Uses

❖
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 Uses

❖
func NewPubsubBenchWrapperClient(cc *grpc.ClientConn) PubsubBenchWrapperClient

type PubsubBenchWrapperServer Uses

❖
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 Uses

❖
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 Uses

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

func (*PubsubRecv) GetSubName Uses

❖
func (m *PubsubRecv) GetSubName() string

func (*PubsubRecv) ProtoMessage Uses

❖
func (*PubsubRecv) ProtoMessage()

func (*PubsubRecv) Reset Uses

❖
func (m *PubsubRecv) Reset()

func (*PubsubRecv) String Uses

❖
func (m *PubsubRecv) String() string

func (*PubsubRecv) XXX_DiscardUnknown Uses

❖
func (m *PubsubRecv) XXX_DiscardUnknown()

func (*PubsubRecv) XXX_Marshal Uses

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

func (*PubsubRecv) XXX_Merge Uses

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

func (*PubsubRecv) XXX_Size Uses

❖
func (m *PubsubRecv) XXX_Size() int

func (*PubsubRecv) XXX_Unmarshal Uses

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

type UnimplementedPubsubBenchWrapperServer Uses

❖
type UnimplementedPubsubBenchWrapperServer struct {
}

UnimplementedPubsubBenchWrapperServer can be embedded to have forward compatible implementations.

func (*UnimplementedPubsubBenchWrapperServer) Recv Uses

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

Package pubsub_bench imports 7 packages (graph) and is imported by 3 packages. Updated 2020-08-02. Refresh now. Tools for package owners.