rabbitmq

type Connection struct {
	*amqp.Connection
	// contains filtered or unexported fields
}

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

type Consumer struct {
	Conn    *Connection
	Channel *amqp.Channel
	// contains filtered or unexported fields
}

type ConsumerOption func(p *Consumer)

type ConsumerParams struct {
	ConsumerName string
	AutoAck      bool
	ConsumerArgs amqp.Table
}

type ControllerFunc func(ctx *DeliveryContext)

type DeliveryContext struct {
	context.Context
	Delivery amqp.Delivery
	Channel  *amqp.Channel

	Acked  bool
	Nacked bool
	// contains filtered or unexported fields
}

type ExchangeParams struct {
	Name       string
	Kind       string
	Durable    bool
	AutoDelete bool
	Internal   bool
	NoWait     bool
	Args       amqp.Table
}

type GroupOption func(g *RouterGroup)

type Publisher struct {
	Conn *Connection
	// contains filtered or unexported fields
}

type PublisherOption func(p *Publisher)

type QualityOfService struct {
	PrefetchCount int
	PrefetchSize  int
}

type QueueParams struct {
	Name       string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
	Args       amqp.Table
}

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

type RouterEngine interface {
	// AddBinding добавляет маршрутизацию контроллеров в роутер
	AddBinding(bindingKey string, controllers ...ControllerFunc)
	// Route подбирает все подходящие контроллеры по настроенным параметрам маршрутизации
	Route(routingKey string) []ControllerFunc
}

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

type Server struct {
	Conn *Connection
	// contains filtered or unexported fields
}