nats

May 14, 2019

Changes in this version

+ func NewStanConnection(config *StanConnConfig) (stan.Conn, error)

+ type StanConnConfig struct

+ ClientID string

+ ClusterID string

+ StanOptions []stan.Option

type StreamingPublisher

+ func NewStreamingPublisherWithStanConn(conn stan.Conn, config StreamingPublisherPublishConfig, ...) (*StreamingPublisher, error)

type StreamingPublisherConfig

+ func (c StreamingPublisherConfig) GetStreamingPublisherPublishConfig() StreamingPublisherPublishConfig

+ type StreamingPublisherPublishConfig struct

+ Marshaler Marshaler

type StreamingSubscriber

+ func NewStreamingSubscriberWithStanConn(conn stan.Conn, config StreamingSubscriberSubscriptionConfig, ...) (*StreamingSubscriber, error)

type StreamingSubscriberConfig

+ func (c *StreamingSubscriberConfig) GetStreamingSubscriberSubscriptionConfig() StreamingSubscriberSubscriptionConfig

+ type StreamingSubscriberSubscriptionConfig struct

+ AckWaitTimeout time.Duration

+ CloseTimeout time.Duration

+ DurableName string

+ QueueGroup string

+ StanSubscriptionOptions []stan.SubscriptionOption

+ SubscribersCount int

+ Unmarshaler Unmarshaler

+ func (c *StreamingSubscriberSubscriptionConfig) Validate() error

Feb 13, 2019

Changes in this version

type StreamingSubscriber

+ func (s *StreamingSubscriber) SubscribeInitialize(topic string) (err error)

Dec 18, 2018

Changes in this version

+ type GobMarshaler struct

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

+ func (GobMarshaler) Unmarshal(stanMsg *stan.Msg) (*message.Message, error)

+ type Marshaler interface

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

+ type MarshalerUnmarshaler interface

+ type StreamingPublisher struct

+ func NewStreamingPublisher(config StreamingPublisherConfig, logger watermill.LoggerAdapter) (*StreamingPublisher, error)

+ func (p StreamingPublisher) Close() error

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

+ type StreamingPublisherConfig struct

+ ClientID string

+ ClusterID string

+ Marshaler Marshaler

+ StanOptions []stan.Option

+ func (c StreamingPublisherConfig) Validate() error

+ type StreamingSubscriber struct

+ func NewStreamingSubscriber(config StreamingSubscriberConfig, logger watermill.LoggerAdapter) (*StreamingSubscriber, error)

+ func (s *StreamingSubscriber) Close() error

+ func (s *StreamingSubscriber) Subscribe(topic string) (chan *message.Message, error)

+ type StreamingSubscriberConfig struct

+ AckWaitTimeout time.Duration

+ ClientID string

+ CloseTimeout time.Duration

+ ClusterID string

+ DurableName string

+ QueueGroup string

+ StanOptions []stan.Option

+ StanSubscriptionOptions []stan.SubscriptionOption

+ SubscribersCount int

+ Unmarshaler Unmarshaler

+ func (c *StreamingSubscriberConfig) Validate() error

+ type Unmarshaler interface

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