consumer

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

type AssistantBinding struct {
	Binding

	Dest map[string]string `yaml:"dest"`
	// contains filtered or unexported fields
}

type Binding struct {
	// имя точки обмена и очереди
	Name string `yaml:"name"`

	// имя точки обмена
	Exchange string `yaml:"exchange"`

	// аргументы точки обмена
	ExchangeArgs amqp.Table

	// имя очереди
	Queue string `yaml:"queue"`

	// аргументы очереди
	QueueArgs amqp.Table

	// тип точки обмена
	Type ExchangeType `yaml:"type"`

	// ключ маршрутизации
	Routing string `yaml:"routing"`

	// количество потоков, разбирающих очередь
	Handlers int `yaml:"workers"`

	// количество сообщений, получаемых одновременно
	PrefetchCount int `yaml:"prefetchCount"`
	// contains filtered or unexported fields
}

type Config struct {
	URI        string              `yaml:"uri"`
	Assistants []*AssistantBinding `yaml:"assistants"`
	Bindings   []*Binding          `yaml:"bindings"`
}

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

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

type ErrorSigns []ErrorSign

type ErrorSignsMap map[int]ErrorSigns

type ExchangeType string

type FailureBindingType int

type Service struct {
	// настройка получателей сообщений
	Configs []*Config `yaml:"consumers"`
	// contains filtered or unexported fields
}

type Waiter struct {
	*time.Ticker
}