driver

Documentation

Index

• type NATSConfig
  • func (c *NATSConfig) ConcurrentSize() int
  • func (c *NATSConfig) MaxConcurrentSize() uint64
  • func (c *NATSConfig) ReadTimeout() time.Duration
• type NATSMsg
  • func (m *NATSMsg) Copy(subject string) mq.Msg
  • func (m *NATSMsg) Data() []byte
  • func (m *NATSMsg) Header() map[string][]string
  • func (m *NATSMsg) IsReply() bool
  • func (m *NATSMsg) ReplyTo() string
  • func (m *NATSMsg) Respond(data []byte) error
  • func (m *NATSMsg) RespondMsg(msg mq.Msg) error
  • func (m *NATSMsg) SetHeader(key, value string)
  • func (m *NATSMsg) Subject() string
• type NATSSubscriber
  • func NewNATSSubscriber(conn *client.Client) *NATSSubscriber
  • func (n *NATSSubscriber) Close() error
  • func (n *NATSSubscriber) Config() mq.Config
  • func (n *NATSSubscriber) Context() context.Context
  • func (n *NATSSubscriber) Logger() mq.Logger
  • func (n *NATSSubscriber) Meter() mq.Metrics
  • func (n *NATSSubscriber) QueueSubscribeSync(subject, queue string) (mq.Subscription, error)
  • func (n *NATSSubscriber) WithMeter(m mq.Metrics)
• type NATSSubscription
  • func (s *NATSSubscription) Delivered() (int64, error)
  • func (s *NATSSubscription) Drain() error
  • func (s *NATSSubscription) Dropped() (int64, error)
  • func (s *NATSSubscription) NextMsg(timeout time.Duration) (mq.Msg, error)
  • func (s *NATSSubscription) Pending() (int64, int64, error)
  • func (s *NATSSubscription) Subject() string

Types

type NATSConfig

type NATSConfig struct {
	*client.Config
}

func (*NATSConfig) ConcurrentSize

func (c *NATSConfig) ConcurrentSize() int

func (*NATSConfig) MaxConcurrentSize

func (c *NATSConfig) MaxConcurrentSize() uint64

func (*NATSConfig) ReadTimeout

func (c *NATSConfig) ReadTimeout() time.Duration

type NATSMsg

type NATSMsg struct {
	*nats.Msg
}

func (*NATSMsg) Copy

func (m *NATSMsg) Copy(subject string) mq.Msg

func (*NATSMsg) Data

func (m *NATSMsg) Data() []byte

func (*NATSMsg) Header

func (m *NATSMsg) Header() map[string][]string

func (*NATSMsg) IsReply

func (m *NATSMsg) IsReply() bool

func (*NATSMsg) ReplyTo

func (m *NATSMsg) ReplyTo() string

func (*NATSMsg) Respond

func (m *NATSMsg) Respond(data []byte) error

func (*NATSMsg) RespondMsg

func (m *NATSMsg) RespondMsg(msg mq.Msg) error

func (*NATSMsg) SetHeader

func (m *NATSMsg) SetHeader(key, value string)

func (*NATSMsg) Subject

func (m *NATSMsg) Subject() string

type NATSSubscriber

type NATSSubscriber struct {
	Conn *client.Client
}

func NewNATSSubscriber

func NewNATSSubscriber(conn *client.Client) *NATSSubscriber

func (*NATSSubscriber) Close

func (n *NATSSubscriber) Close() error

func (*NATSSubscriber) Config

func (n *NATSSubscriber) Config() mq.Config

func (*NATSSubscriber) Context

func (n *NATSSubscriber) Context() context.Context

func (*NATSSubscriber) Logger

func (n *NATSSubscriber) Logger() mq.Logger

func (*NATSSubscriber) Meter

func (n *NATSSubscriber) Meter() mq.Metrics

func (*NATSSubscriber) QueueSubscribeSync

func (n *NATSSubscriber) QueueSubscribeSync(subject, queue string) (mq.Subscription, error)

func (*NATSSubscriber) WithMeter

func (n *NATSSubscriber) WithMeter(m mq.Metrics)

type NATSSubscription

type NATSSubscription struct {
	*nats.Subscription
}

func (*NATSSubscription) Delivered

func (s *NATSSubscription) Delivered() (int64, error)

func (*NATSSubscription) Drain

func (s *NATSSubscription) Drain() error

func (*NATSSubscription) Dropped

func (s *NATSSubscription) Dropped() (int64, error)

func (*NATSSubscription) NextMsg

func (s *NATSSubscription) NextMsg(timeout time.Duration) (mq.Msg, error)

func (*NATSSubscription) Pending

func (s *NATSSubscription) Pending() (int64, int64, error)

func (*NATSSubscription) Subject

func (s *NATSSubscription) Subject() string