Versions in this module Expand all Collapse all v1 v1.0.2 Sep 27, 2023 v1.0.1 May 23, 2023 Changes in this version + var File_nats_proto protoreflect.FileDescriptor + func RegisterNatsServer(s *grpc.Server, srv NatsServer) + type Message struct + Channel string + Created int64 + Payload []byte + Protocol string + Publisher string + Subtopic string + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetChannel() string + func (x *Message) GetCreated() int64 + func (x *Message) GetPayload() []byte + func (x *Message) GetProtocol() string + func (x *Message) GetPublisher() string + func (x *Message) GetSubtopic() string + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type NatsClient interface + AdapterMessages func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*emptypb.Empty, error) + func NewNatsClient(cc grpc.ClientConnInterface) NatsClient + type NatsServer interface + AdapterMessages func(context.Context, *Message) (*emptypb.Empty, error) + type UnimplementedNatsServer struct + func (*UnimplementedNatsServer) AdapterMessages(context.Context, *Message) (*emptypb.Empty, error)