Versions in this module Expand all Collapse all v1 v1.0.0 Apr 28, 2026 Changes in this version + type ConnectOptions struct + URL string + type DeclareExchangeOptions struct + Args amqpDriver.Table + AutoDelete bool + Durable bool + Internal bool + Kind string + Name string + NoWait bool + type DeclareQueueOptions struct + Args amqpDriver.Table + DeleteWhenUnused bool + Durable bool + Exclusive bool + Name string + NoWait bool + type ExchangeBindOptions struct + Args amqpDriver.Table + DestinationExchangeName string + NoWait bool + RoutingKey string + SourceExchangeName string + type ExchangeUnbindOptions struct + Args amqpDriver.Table + DestinationExchangeName string + NoWait bool + RoutingKey string + SourceExchangeName string + type ListenOptions struct + Args amqpDriver.Table + AutoAck bool + Consumer string + Exclusive bool + NoLocal bool + NoWait bool + QueueName string + type ModuleInstance struct + func (mi *ModuleInstance) BindExchange(options ExchangeBindOptions) error + func (mi *ModuleInstance) BindQueue(options QueueBindOptions) error + func (mi *ModuleInstance) Close() error + func (mi *ModuleInstance) Connect(options ConnectOptions) error + func (mi *ModuleInstance) DeclareExchange(options DeclareExchangeOptions) error + func (mi *ModuleInstance) DeclareQueue(options DeclareQueueOptions) (map[string]interface{}, error) + func (mi *ModuleInstance) DeleteExchange(name string) error + func (mi *ModuleInstance) DeleteQueue(name string) error + func (mi *ModuleInstance) Exports() modules.Exports + func (mi *ModuleInstance) InspectQueue(name string) (map[string]interface{}, error) + func (mi *ModuleInstance) Listen(options ListenOptions) interface{} + func (mi *ModuleInstance) Publish(options PublishOptions) error + func (mi *ModuleInstance) PurgeQueue(name string) (int, error) + func (mi *ModuleInstance) UnbindExchange(options ExchangeUnbindOptions) error + func (mi *ModuleInstance) UnbindQueue(options QueueUnbindOptions) error + type PublishOptions struct + AppID string + Body string + ContentType string + CorrelationID string + Exchange string + Expiration string + Headers amqpDriver.Table + Immediate bool + Mandatory bool + MessageID string + Persistent bool + QueueName string + ReplyTo string + Timestamp int64 + Type string + UserID string + type QueueBindOptions struct + Args amqpDriver.Table + ExchangeName string + NoWait bool + QueueName string + RoutingKey string + type QueueUnbindOptions struct + Args amqpDriver.Table + ExchangeName string + QueueName string + RoutingKey string + type RootModule struct + func (r *RootModule) NewModuleInstance(vu modules.VU) modules.Instance
Go to main page