rmq

type AfterHandleFunc func(ctx context.Context, channel *amqp.Channel, msg *amqp.Delivery, action MsgAction) error

type AmqpConnectionConstructor func() (*amqp.Connection, error)

type BeforeHandleFunc func(ctx context.Context, channel *amqp.Channel, msg *amqp.Delivery) error

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

type ConnectionCfg struct {
	// ReconnectTimeout - period, when process try to establish connection again.
	ReconnectTimeout time.Duration
}

type ConsumeParams struct {
	Queue, Consumer                     string
	AutoAck, Exclusive, NoLocal, NoWait bool
	Args                                amqp.Table
}

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

type ConsumerConfig struct {
	// number of consuming workers
	WorkersCount int
	// run message handling in a single goroutine or in worker loop
	Synchronous bool
}

type DeclareParams struct {
	// Primitive name
	Name string
	// Kind - for exchange only
	Kind                                 ExchangeKind
	Durable, AutoDelete, NoWait, Passive bool
	// Internal - for exchange only
	Internal bool
	// Exclusive - for queue only
	Exclusive bool
	Args      amqp.Table
}

type DefaultMessageHandler struct {
	// BeforeHandle - custom before handle func
	BeforeHandleFunc BeforeHandleFunc
	// HandleFunc - custom handle func
	HandleFunc HandleFunc
	// AfterHandleFunc - custom after handle func
	AfterHandleFunc AfterHandleFunc
}

type DelayedRetryMessageHandler struct {
	*DefaultMessageHandler
	// DelayQueueRoutingKey - queue routing key for delayed messages resend
	DelayQueueRoutingKey string
	// DelayExchangeName - exchange name for delayed messages resend
	DelayExchangeName string
	// Delay - time interval for message expiration in delay queue
	Delay time.Duration
	// MaxRetriesCount - maximum count of retires before message will be rejected
	MaxRetriesCount int64
}

type DeleteParams struct {
	Name                      string
	IfUnused, IfEmpty, NoWait bool
}

type ExchangeBindParams struct {
	Destination, Key, Source string
	NoWait                   bool
	Args                     amqp.Table
}

type ExchangeKind string

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

type HandleFunc func(ctx context.Context, channel *amqp.Channel, msg *amqp.Delivery) (MsgAction, error)

type MessageHandler interface {
	Handle(ctx context.Context, channel *amqp.Channel, msg *amqp.Delivery) error
}

type MsgAction int

type Preset interface {
	Apply(*amqp.Channel, *Schema) error
}

type PublishMessage struct {
	ExchangeName, RoutingKey string
	Mandatory, Immediate     bool
	Publishing               amqp.Publishing
}

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

type PublisherConfig struct {
	// MaxChannelsCount max channels count
	MaxChannelsCount int32
	// CleanUp interval - task for closing idle channels in pool
	CleanUpInterval time.Duration
	// Max idle time per one channel. Set this param smaller than CleanUpInterval
	MaxIdleTime time.Duration
}

type QueueBindParams struct {
	Name, Key, Exchange string
	NoWait              bool
	Args                amqp.Table
}

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

type Schema struct {
	Queue    *QueueManager
	Exchange *ExchangeManager
	// contains filtered or unexported fields
}