Versions in this module Expand all Collapse all v1 v1.0.0 May 4, 2025 Changes in this version + const PubSub_Publish_FullMethodName + const PubSub_Subscribe_FullMethodName + var File_subpub_proto protoreflect.FileDescriptor + var PubSub_ServiceDesc = grpc.ServiceDesc + func RegisterPubSubServer(s grpc.ServiceRegistrar, srv PubSubServer) + type Event struct + Data string + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (x *Event) GetData() string + func (x *Event) ProtoReflect() protoreflect.Message + func (x *Event) Reset() + func (x *Event) String() string + type PubSubClient interface + Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Event], error) + func NewPubSubClient(cc grpc.ClientConnInterface) PubSubClient + type PubSubServer interface + Publish func(context.Context, *PublishRequest) (*emptypb.Empty, error) + Subscribe func(*SubscribeRequest, grpc.ServerStreamingServer[Event]) error + type PubSub_SubscribeClient = grpc.ServerStreamingClient[Event] + type PubSub_SubscribeServer = grpc.ServerStreamingServer[Event] + type PublishRequest struct + Data string + Key string + func (*PublishRequest) Descriptor() ([]byte, []int) + func (*PublishRequest) ProtoMessage() + func (x *PublishRequest) GetData() string + func (x *PublishRequest) GetKey() string + func (x *PublishRequest) ProtoReflect() protoreflect.Message + func (x *PublishRequest) Reset() + func (x *PublishRequest) String() string + type SubscribeRequest struct + Key string + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (x *SubscribeRequest) GetKey() string + func (x *SubscribeRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeRequest) Reset() + func (x *SubscribeRequest) String() string + type UnimplementedPubSubServer struct + func (UnimplementedPubSubServer) Publish(context.Context, *PublishRequest) (*emptypb.Empty, error) + func (UnimplementedPubSubServer) Subscribe(*SubscribeRequest, grpc.ServerStreamingServer[Event]) error + type UnsafePubSubServer interface
Go to main page