Versions in this module Expand all Collapse all v0 v0.15.0 Nov 26, 2024 v0.14.0 Jan 29, 2024 Changes in this version + var File_pkg_messaging_message_proto protoreflect.FileDescriptor + type DeliveryPolicy uint8 + const DeliverAllPolicy + const DeliverNewPolicy + 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 MessageHandler interface + Cancel func() error + Handle func(msg *Message) error + type Option func(vals interface{}) error + type PubSub interface + type Publisher interface + Close func() error + Publish func(ctx context.Context, topic string, msg *Message) error + type Subscriber interface + Close func() error + Subscribe func(ctx context.Context, cfg SubscriberConfig) error + Unsubscribe func(ctx context.Context, id, topic string) error + type SubscriberConfig struct + DeliveryPolicy DeliveryPolicy + Handler MessageHandler + ID string + Topic string
Go to main page