The highest tagged major version is
Documentation
¶
Index ¶
- type Topologer
- func (top *Topologer) BindExchanges(bindings []*models.ExchangeBinding, ignoreErrors bool) error
- func (top *Topologer) BindQueues(bindings []*models.QueueBinding, ignoreErrors bool) error
- func (top *Topologer) BuildExchanges(exchanges []*models.Exchange, ignoreErrors bool) error
- func (top *Topologer) BuildQueues(queues []*models.Queue, ignoreErrors bool) error
- func (top *Topologer) BuildToplogy(config *models.TopologyConfig, ignoreErrors bool) error
- func (top *Topologer) CreateExchange(exchangeName string, exchangeType string, ...) error
- func (top *Topologer) CreateExchangeFromConfig(exchange *models.Exchange) error
- func (top *Topologer) CreateQueue(queueName string, passiveDeclare bool, durable bool, autoDelete bool, ...) error
- func (top *Topologer) CreateQueueFromConfig(queue *models.Queue) error
- func (top *Topologer) ExchangeBind(exchangeBinding *models.ExchangeBinding) error
- func (top *Topologer) ExchangeDelete(exchangeName string, ifUnused, noWait bool) error
- func (top *Topologer) ExchangeUnbind(exchangeName, routingKey, parentExchangeName string, noWait bool, ...) error
- func (top *Topologer) PurgeQueue(queueName string, noWait bool) (int, error)
- func (top *Topologer) PurgeQueues(queueNames []string, noWait bool) (int, error)
- func (top *Topologer) QueueBind(queueBinding *models.QueueBinding) error
- func (top *Topologer) QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error)
- func (top *Topologer) UnbindQueue(queueName, routingKey, exchangeName string, args map[string]interface{}) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Topologer ¶
type Topologer struct {
// contains filtered or unexported fields
}
Topologer allows you to build RabbitMQ topology backed by a ChannelPool.
func NewTopologer ¶
func NewTopologer(channelPool *pools.ChannelPool) (*Topologer, error)
NewTopologer builds you a new Topologer.
func (*Topologer) BindExchanges ¶
func (top *Topologer) BindExchanges(bindings []*models.ExchangeBinding, ignoreErrors bool) error
BindExchanges loops thrrough and binds Exchanges to Exchanges - stops on first error.
func (*Topologer) BindQueues ¶
func (top *Topologer) BindQueues(bindings []*models.QueueBinding, ignoreErrors bool) error
BindQueues loops through and binds Queues to Exchanges - stops on first error.
func (*Topologer) BuildExchanges ¶
BuildExchanges loops through and builds Exchanges - stops on first error.
func (*Topologer) BuildQueues ¶
BuildQueues loops through and builds Queues - stops on first error.
func (*Topologer) BuildToplogy ¶
func (top *Topologer) BuildToplogy(config *models.TopologyConfig, ignoreErrors bool) error
BuildToplogy builds a topology based on a ToplogyConfig - stops on first error.
func (*Topologer) CreateExchange ¶
func (top *Topologer) CreateExchange( exchangeName string, exchangeType string, passiveDeclare, durable, autoDelete, internal, noWait bool, args map[string]interface{}) error
CreateExchange builds an Exchange topology.
func (*Topologer) CreateExchangeFromConfig ¶
CreateExchangeFromConfig builds an Exchange toplogy from a config Exchange element.
func (*Topologer) CreateQueue ¶
func (top *Topologer) CreateQueue( queueName string, passiveDeclare bool, durable bool, autoDelete bool, exclusive bool, noWait bool, args map[string]interface{}) error
CreateQueue builds a Queue topology.
func (*Topologer) CreateQueueFromConfig ¶
CreateQueueFromConfig builds a Queue topology from a config Exchange element.
func (*Topologer) ExchangeBind ¶
func (top *Topologer) ExchangeBind(exchangeBinding *models.ExchangeBinding) error
ExchangeBind binds an exchange to an Exchange.
func (*Topologer) ExchangeDelete ¶
ExchangeDelete removes the exchange from the server.
func (*Topologer) ExchangeUnbind ¶
func (top *Topologer) ExchangeUnbind(exchangeName, routingKey, parentExchangeName string, noWait bool, args map[string]interface{}) error
ExchangeUnbind removes the binding of an Exchange to an Exchange.
func (*Topologer) PurgeQueue ¶
PurgeQueue removes all messages from the Queue that are not waiting to be Acknowledged and returns the count.
func (*Topologer) PurgeQueues ¶
PurgeQueues purges each Queue provided.
func (*Topologer) QueueBind ¶
func (top *Topologer) QueueBind(queueBinding *models.QueueBinding) error
QueueBind binds an Exchange to a Queue.
func (*Topologer) QueueDelete ¶
QueueDelete removes the queue from the server (and all bindings) and returns messages purged (count).
Source Files