session

Apr 16, 2024

Changes in this version

type Container

+ OnSessionError func(func(err error))

+ type RetryableError interface

+ Retry func() time.Duration

Mar 6, 2024

Changes in this version

type ContainerConfig

+ ContainerID string

+ MaxFrameSize uint32

+ SASLType SASLType

+ TLSConfig *tls.Config

+ type SASLType string

+ const SASLTypeExternal

Mar 5, 2024

Changes in this version

+ type ContainerFactory interface

+ Create func(id string) Container

+ func NewContainerFactory(address string, cfg ContainerConfig) ContainerFactory

+ func NewMockContainerFactory() ContainerFactory

Mar 4, 2024

Changes in this version

+ type Container interface

+ NewReceiver func(address string, opts ReceiverOptions) Receiver

+ NewSender func(address string, opts SenderOptions) Sender

+ Start func(context.Context)

+ func NewContainer(address string, config ContainerConfig) Container

+ func NewMockContainer(router *MockRouter) Container

+ type ContainerConfig struct

+ BackOff backoff.BackOff

+ Conn *amqp.ConnOptions

+ type MockRouter struct

+ func NewMockRouter() *MockRouter

+ type Receiver interface

+ Accept func(context.Context, *amqp.Message) error

+ Close func(context.Context) error

+ Next func(context.Context) (*amqp.Message, error)

+ type ReceiverOptions struct

+ Credit int

+ type Sender interface

+ Close func(context.Context) error

+ Send func(context.Context, *amqp.Message) error

+ type SenderOptions struct