spi

Documentation

Index

• Constants
• type Option
  • func WithDeliveryDelay(delay time.Duration) Option
  • func WithPool(size int) Option
• type Options

Constants

const UndeliverableTopic = "oak.undeliverable.activities"

UndeliverableTopic is the topic to which to post undeliverable messages.

Types

type Option

type Option func(option *Options)

Option specifies a publisher/subscriber option.

func WithDeliveryDelay

func WithDeliveryDelay(delay time.Duration) Option

WithDeliveryDelay sets the delivery delay. Note: Not all message brokers support this option.

func WithPool

func WithPool(size int) Option

WithPool sets the pool size.

type Options

type Options struct {
	PoolSize      int
	DeliveryDelay time.Duration
}

Options contains publisher/subscriber options.