Versions in this module Expand all Collapse all v1 v1.0.0 Jan 2, 2019 Changes in this version + func RegisterPubsubServiceServer(s *grpc.Server, srv PubsubServiceServer) + type PubsubServiceClient interface + Publish func(ctx context.Context, in *String, opts ...grpc.CallOption) (*String, error) + Subscribe func(ctx context.Context, in *String, opts ...grpc.CallOption) (PubsubService_SubscribeClient, error) + func NewPubsubServiceClient(cc *grpc.ClientConn) PubsubServiceClient + type PubsubServiceServer interface + Publish func(context.Context, *String) (*String, error) + Subscribe func(*String, PubsubService_SubscribeServer) error + type PubsubService_SubscribeClient interface + Recv func() (*String, error) + type PubsubService_SubscribeServer interface + Send func(*String) error + type String struct + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*String) Descriptor() ([]byte, []int) + func (*String) ProtoMessage() + func (dst *String) XXX_Merge(src proto.Message) + func (m *String) GetValue() string + func (m *String) Reset() + func (m *String) String() string + func (m *String) XXX_DiscardUnknown() + func (m *String) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *String) XXX_Size() int + func (m *String) XXX_Unmarshal(b []byte) error
Go to main page