pubsub_bench

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

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

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

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:"-"`
}

type UnimplementedPubsubBenchWrapperServer struct {
}