Documentation
¶
Index ¶
- type NATSConfig
- type NATSMsg
- func (m *NATSMsg) Copy(subject string) interfaces.Msg
- func (m *NATSMsg) GetData() []byte
- func (m *NATSMsg) GetHeader() map[string][]string
- func (m *NATSMsg) GetSubject() 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)
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NATSConfig ¶
func (*NATSConfig) GetConcurrentSize ¶
func (c *NATSConfig) GetConcurrentSize() int
func (*NATSConfig) GetMaxConcurrentSize ¶
func (c *NATSConfig) GetMaxConcurrentSize() uint64
func (*NATSConfig) GetReadTimeout ¶
func (c *NATSConfig) GetReadTimeout() time.Duration
type NATSMsg ¶
func (*NATSMsg) GetSubject ¶
func (*NATSMsg) RespondMsg ¶
func (m *NATSMsg) RespondMsg(msg interfaces.Msg) error
type NATSSubscriber ¶
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
func (*NATSSubscription) NextMsg ¶
func (s *NATSSubscription) NextMsg(timeout time.Duration) (interfaces.Msg, error)
Source Files
Click to show internal directories.
Click to hide internal directories.