jetstream

package

Go to main page

Versions in this module

v0

v0.0.4

Mar 22, 2022

Changes in this version

+ type JSONMarshaler struct

+ func (JSONMarshaler) Marshal(topic string, msg *message.Message) (*nats.Msg, error)

+ func (JSONMarshaler) Unmarshal(natsMsg *nats.Msg) (*message.Message, error)

+ type NATSMarshaler struct

+ func (*NATSMarshaler) Marshal(topic string, msg *message.Message) (*nats.Msg, error)

+ func (*NATSMarshaler) Unmarshal(natsMsg *nats.Msg) (*message.Message, error)

v0.0.3

Mar 1, 2022

Changes in this version

type PublisherConfig

+ TrackMsgId bool

type PublisherPublishConfig

+ TrackMsgId bool

+ type Subjects struct

+ Additional []string

+ Primary string

+ func (s *Subjects) All() []string

type SubscriberConfig

+ AckSync bool

type SubscriberSubscriptionConfig

+ AckSync bool

v0.0.3-unstable.1

Mar 1, 2022

v0.0.3-unstable

Feb 20, 2022

v0.0.2

Feb 13, 2022

Changes in this version

type PublisherConfig

+ AutoProvision bool

+ JetstreamOptions []nats.JSOpt

+ PublishOptions []nats.PubOpt

+ SubjectCalculator SubjectCalculator

type PublisherPublishConfig

+ AutoProvision bool

+ JetstreamOptions []nats.JSOpt

+ PublishOptions []nats.PubOpt

+ SubjectCalculator SubjectCalculator

+ type SubjectCalculator func(topic string) []string

type SubscriberConfig

+ AutoProvision bool

+ JetstreamOptions []nats.JSOpt

+ SubjectCalculator SubjectCalculator

+ func (c *SubscriberConfig) GetSubscriberSubscriptionConfig() SubscriberSubscriptionConfig

type SubscriberSubscriptionConfig

+ AutoProvision bool

+ JetstreamOptions []nats.JSOpt

+ SubjectCalculator SubjectCalculator

v0.0.1

Feb 6, 2022

Changes in this version

+ func NewJetstreamConnection(config *NatsConnConfig) (nats.JetStreamContext, error)

+ func NewNatsConnection(config *NatsConnConfig) (*nats.Conn, error)

+ type GobMarshaler struct

+ func (GobMarshaler) Marshal(topic string, msg *message.Message) ([]byte, error)

+ func (GobMarshaler) Unmarshal(natsMsg *nats.Msg) (*message.Message, error)

+ type Marshaler interface

+ Marshal func(topic string, msg *message.Message) ([]byte, error)

+ type MarshalerUnmarshaler interface

+ type NatsConnConfig struct

+ NatsOptions []nats.Option

+ URL string

+ type Publisher struct

+ func NewPublisher(config PublisherConfig, logger watermill.LoggerAdapter) (*Publisher, error)

+ func NewPublisherWithNatsConn(conn *nats.Conn, config PublisherPublishConfig, logger watermill.LoggerAdapter) (*Publisher, error)

+ func (p *Publisher) Close() error

+ func (p *Publisher) Publish(topic string, messages ...*message.Message) error

+ type PublisherConfig struct

+ Marshaler Marshaler

+ NatsOptions []nats.Option

+ URL string

+ func (c PublisherConfig) GetPublisherPublishConfig() PublisherPublishConfig

+ func (c PublisherConfig) Validate() error

+ type PublisherPublishConfig struct

+ Marshaler Marshaler

+ type Subscriber struct

+ func NewSubscriber(config SubscriberConfig, logger watermill.LoggerAdapter) (*Subscriber, error)

+ func NewSubscriberWithNatsConn(conn *nats.Conn, config SubscriberSubscriptionConfig, ...) (*Subscriber, error)

+ func (s *Subscriber) Close() error

+ func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)

+ func (s *Subscriber) SubscribeInitialize(topic string) error

+ type SubscriberConfig struct

+ AckWaitTimeout time.Duration

+ ClientID string

+ CloseTimeout time.Duration

+ DurableName string

+ NatsOptions []nats.Option

+ QueueGroup string

+ SubscribeOptions []nats.SubOpt

+ SubscribeTimeout time.Duration

+ SubscribersCount int

+ URL string

+ Unmarshaler Unmarshaler

+ func (c *SubscriberConfig) GetStreamingSubscriberSubscriptionConfig() SubscriberSubscriptionConfig

+ type SubscriberSubscriptionConfig struct

+ AckWaitTimeout time.Duration

+ CloseTimeout time.Duration

+ DurableName string

+ QueueGroup string

+ SubscribeOptions []nats.SubOpt

+ SubscribeTimeout time.Duration

+ SubscribersCount int

+ Unmarshaler Unmarshaler

+ func (c *SubscriberSubscriptionConfig) Validate() error

+ type Unmarshaler interface

+ Unmarshal func(*nats.Msg) (*message.Message, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL