infrarabbit

type BindConfig struct {
	Exchange   string // required
	RoutingKey string // required
	Queue      string // required

	// optional
	ExchangeKind       Kind
	ExchangeDurable    bool
	ExchangeAutoDelete bool
	ExchangeInternal   bool
	ExchangeNoWait     bool
	ExchangeArgs       map[string]interface{}
	QueueDurable       bool
	QueueAutoDelete    bool
	QueueExclusive     bool
	QueueNoWait        bool
	QueueArgs          map[string]interface{}
	BindNoWait         bool
	BindArgs           map[string]interface{}
}

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

type ConnectionConfig struct {
	Address  string `mapstructure:"address"`
	Username string `mapstructure:"username"`
	Password string `mapstructure:"password"`
	Vhost    string `mapstructure:"vhost"`
}

type ConnectionsConfig map[string]*ConnectionConfig

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

type ConsumerConfig struct {
	ConnectionName string
	Queue          string
	QueueDurable   bool                   // optional
	QueuePriority  uint8                  // deprecated
	QueueArgs      map[string]interface{} // optional
	PrefetchCount  int                    // optional
	Tag            string                 // optional
	Metrics        *ConsumerMetrics       // optional
}

type ConsumerMetrics struct {
	CheckInterval time.Duration                         // optional
	QueueLength   func(host, queue string, value int64) // optional
	QueueDelay    func(host, queue string, value int64) // optional
}

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

type Kind string

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

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

type ProducerConfig struct {
	ConnectionName string
	Tag            string // optional
	Bindings       []*BindConfig
}

type ProducerMessage struct {
	Body       []byte
	Exchange   string
	RoutingKey string
	Priority   uint8
}