Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var File_pubsub_proto protoreflect.FileDescriptor
Functions ¶
func RegisterPubsubServiceServer ¶
func RegisterPubsubServiceServer(s *grpc.Server, srv PubsubServiceServer)
Types ¶
type PubsubServiceClient ¶
type PubsubServiceClient interface { Publish(ctx context.Context, in *String, opts ...grpc.CallOption) (*String, error) Subscribe(ctx context.Context, in *String, opts ...grpc.CallOption) (PubsubService_SubscribeClient, error) }
PubsubServiceClient is the client API for PubsubService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPubsubServiceClient ¶
func NewPubsubServiceClient(cc grpc.ClientConnInterface) PubsubServiceClient
type PubsubServiceServer ¶
type PubsubServiceServer interface { Publish(context.Context, *String) (*String, error) Subscribe(*String, PubsubService_SubscribeServer) error }
PubsubServiceServer is the server API for PubsubService service.
type PubsubService_SubscribeClient ¶
type PubsubService_SubscribeClient interface { Recv() (*String, error) grpc.ClientStream }
type PubsubService_SubscribeServer ¶
type PubsubService_SubscribeServer interface { Send(*String) error grpc.ServerStream }
type String ¶
type String struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*String) Descriptor
deprecated
func (*String) ProtoMessage ¶
func (*String) ProtoMessage()
func (*String) ProtoReflect ¶
func (x *String) ProtoReflect() protoreflect.Message
type UnimplementedPubsubServiceServer ¶
type UnimplementedPubsubServiceServer struct { }
UnimplementedPubsubServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedPubsubServiceServer) Subscribe ¶
func (*UnimplementedPubsubServiceServer) Subscribe(*String, PubsubService_SubscribeServer) error
Click to show internal directories.
Click to hide internal directories.