rabbitmq

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

type DeliveryHandler interface {
	Handle(ctx context.Context, delivery *amqp.Delivery) error
}

type DeliveryHandlerFunc func(ctx context.Context, delivery *amqp.Delivery) error

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

type PoolOptions struct {
	ConnectionsCount int
	ChannelsPoolSize int
	TLSCfg           *tls.Config
	Heartbeat        time.Duration
	Locale           string
}

type Pooler interface {
	GetAMQPChan() (*amqp.Channel, error)
	ReleaseAMQPChan(channel *amqp.Channel)
	io.Closer
}

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