resender

Documentation

Index

• type Resender
  • func NewResender(fromNats, toNats *options.NatsOptions) *Resender
  • func (r *Resender) Close() error
  • func (r *Resender) FlushCounter() (uint, int, int)
  • func (r *Resender) Subscribe(fromSubject, queue, toSubject string, pendingMsgLimit, pendingByteLimit int, ...) (*nats.Subscription, error)

Types

type Resender

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

func NewResender

func NewResender(fromNats, toNats *options.NatsOptions) *Resender

func (*Resender) Close

func (r *Resender) Close() error

func (*Resender) FlushCounter

func (r *Resender) FlushCounter() (uint, int, int)

func (*Resender) Subscribe

func (r *Resender) Subscribe(
	fromSubject, queue, toSubject string,
	pendingMsgLimit, pendingByteLimit int,
	debug bool,
) (*nats.Subscription, error)