driver

Documentation

Overview

Package driver is the legacy NATS subscriber adapter import path.

New code should prefer github.com/InsideGallery/core/queue/generic/subscriber/nats. Existing exports remain for compatibility.

Index

• type NATSConfig
  • func (c *NATSConfig) ConcurrentSize() int
  • func (c *NATSConfig) GetConcurrentSize() int
  • func (c *NATSConfig) GetMaxConcurrentSize() uint64
  • func (c *NATSConfig) GetReadTimeout() time.Duration
  • func (c *NATSConfig) MaxConcurrentSize() uint64
  • func (c *NATSConfig) ReadTimeout() time.Duration
• type NATSMsg
  • func (m *NATSMsg) Copy(subject string) interfaces.Msg
  • func (m *NATSMsg) Data() []byte
  • func (m *NATSMsg) GetData() []byte
  • func (m *NATSMsg) GetHeader() map[string][]string
  • func (m *NATSMsg) GetSubject() string
  • 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 interfaces.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() interfaces.Config
  • func (n *NATSSubscriber) Context() context.Context
  • func (n *NATSSubscriber) Logger() interfaces.Logger
  • func (n *NATSSubscriber) Meter() metric.Meter
  • func (n *NATSSubscriber) QueueSubscribeSync(subject, queue string) (interfaces.Subscription, error)
  • func (n *NATSSubscriber) WithMeter(m metric.Meter)
• type NATSSubscription
  • func (s *NATSSubscription) Delivered() (int64, error)
  • func (s *NATSSubscription) Drain() error
  • func (s *NATSSubscription) Dropped() (int64, error)
  • func (s *NATSSubscription) GetSubject() string
  • func (s *NATSSubscription) NextMsg(timeout time.Duration) (interfaces.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) GetConcurrentSize

func (c *NATSConfig) GetConcurrentSize() int

Deprecated: use ConcurrentSize.

func (*NATSConfig) GetMaxConcurrentSize

func (c *NATSConfig) GetMaxConcurrentSize() uint64

Deprecated: use MaxConcurrentSize.

func (*NATSConfig) GetReadTimeout

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

Deprecated: use ReadTimeout.

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) interfaces.Msg

func (*NATSMsg) Data

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

func (*NATSMsg) GetData

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

Deprecated: use Data.

func (*NATSMsg) GetHeader

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

Deprecated: use Header.

func (*NATSMsg) GetSubject

func (m *NATSMsg) GetSubject() string

Deprecated: use Subject.

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 interfaces.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() interfaces.Config

func (*NATSSubscriber) Context

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

func (*NATSSubscriber) Logger

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

func (*NATSSubscriber) Meter

func (n *NATSSubscriber) Meter() metric.Meter

func (*NATSSubscriber) QueueSubscribeSync

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

func (*NATSSubscriber) WithMeter

func (n *NATSSubscriber) WithMeter(m metric.Meter)

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) GetSubject

func (s *NATSSubscription) GetSubject() string

Deprecated: use Subject.

func (*NATSSubscription) NextMsg

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

func (*NATSSubscription) Pending

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

func (*NATSSubscription) Subject

func (s *NATSSubscription) Subject() string