nats

Documentation

Index

• func NewNats(config config.MQConfig, logger zerolog.Logger) (mq.MQ, error)
• type Nats
  • func (nat *Nats) InitSubscriber(ctx context.Context, projectID, topicID string, subIDs ...string) error
  • func (nat *Nats) InitTopic(ctx context.Context, projectID, topicID string) error
  • func (nat *Nats) Publish(distributedID int64, projectID, topicID string, message []byte) error
  • func (nat *Nats) Stop()
  • func (nat *Nats) Subscribe(projectID, subscription string, process func(context.Context, []byte) error) error
• type Subscriber
  • func NewSubscriber(logger zerolog.Logger, queueGroup, projectID, subscription string, ...) *Subscriber
  • func (sub *Subscriber) Start(stanConn stan.Conn) error
  • func (sub *Subscriber) Stop()

Functions

func NewNats

func NewNats(config config.MQConfig, logger zerolog.Logger) (mq.MQ, error)

NewNats returns a mq.MQ implement with nats streaming

Types

type Nats

type Nats struct {
	// contains filtered or unexported fields
}

func (*Nats) InitSubscriber

func (nat *Nats) InitSubscriber(ctx context.Context, projectID, topicID string, subIDs ...string) error

func (*Nats) InitTopic

func (nat *Nats) InitTopic(ctx context.Context, projectID, topicID string) error

func (*Nats) Publish

func (nat *Nats) Publish(distributedID int64, projectID, topicID string, message []byte) error

func (*Nats) Stop

func (nat *Nats) Stop()

func (*Nats) Subscribe

func (nat *Nats) Subscribe(projectID, subscription string, process func(context.Context, []byte) error) error

type Subscriber

type Subscriber struct {
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber(
	logger zerolog.Logger,
	queueGroup, projectID, subscription string,
	process func(context.Context, []byte) error,
	durableName string,
	ackWait time.Duration,
	maxInflight, workerSize int,
) *Subscriber

func (*Subscriber) Start

func (sub *Subscriber) Start(stanConn stan.Conn) error

func (*Subscriber) Stop

func (sub *Subscriber) Stop()