driver

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 28, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.