subscribe

Documentation

Index

• type Option
  • func DisableAutoPing() Option
  • func MaxPendingEvents(n uint) Option
  • func WithAutoPingInterval(interval time.Duration) Option
  • func WithDefaultRetryBackoff(decider delays.DelayDecider) Option
• type Options
  • func (o *Options) Apply(opts []Option)

Types

type Option

type Option func(*Options)

func DisableAutoPing

func DisableAutoPing() Option

DisableAutoPing disables automatic pinging of events.

func MaxPendingEvents

func MaxPendingEvents(n uint) Option

MaxPendingEvents is the maximum number of events to keep ready for processing.

If not set this defaults to 50.

func WithAutoPingInterval

func WithAutoPingInterval(interval time.Duration) Option

WithAutoPingInterval sets the interval at which events should be pinged.

func WithDefaultRetryBackoff

func WithDefaultRetryBackoff(decider delays.DelayDecider) Option

WithDefaultRetryBackoff sets the default backoff strategy to use when acking, rejecting or pinging an event fails.

type Options

type Options struct {
	MaxPendingEvents uint

	// CallRetryBackoff is the backoff strategy to use when acking, rejecting
	// or pinging an event fails.
	CallRetryBackoff delays.DelayDecider

	// AutoPingInterval is the interval at which events should be pinged.
	// Defaults to zero which will determine the ping interval based on the
	// timeout of the consumer.
	AutoPingInterval time.Duration
}

func (*Options) Apply

func (o *Options) Apply(opts []Option)