Versions in this module Expand all Collapse all v0 v0.1.0 May 14, 2026 v0.0.7 Jan 29, 2026 v0.0.6 Jul 7, 2025 Changes in this version type AmqpClient + func (amqpClient *AmqpClient) Connect() (*amqp.Connection, error) type Client + func (client *Client) Listen(opts ListenOptions, listener ListenerType) error + type ListenOptions struct + Args amqp.Table + AutoAck bool + Exclusive bool + NoLocal bool + NoWait bool + Queue string + type ListenerType func(amqp.Delivery) error v0.0.5 Jun 28, 2025 v0.0.4 May 25, 2025 v0.0.3 Dec 1, 2024 Changes in this version type AmqpConsumeResponse + Deliveries []amqp.Delivery + type AmqpGetResponse struct + Delivery amqp.Delivery + Error bool + ErrorMessage string + Ok bool type Client + func (client *Client) Consume(opts ConsumeOptions) (AmqpConsumeResponse, error) + type ConsumeOptions struct + Args amqp.Table + AutoAck bool + Exclusive bool + NoLocal bool + NoWait bool + Queue string + Size int + type GetOptions struct + AutoAck bool + Queue string v0.0.2 Nov 24, 2024 Changes in this version type Queue + func (queue *Queue) Purge(client *Client, opts QueuePurgeOptions) (int, error) + type QueuePurgeOptions struct + Name string + NoWait bool + type QueueUnbindOptions struct + Args amqp.Table + Exchange string + Key string + Name string v0.0.1 Nov 23, 2024 Changes in this version + type AmqpClient struct + type AmqpConsumeResponse struct + Delivery amqp.Delivery + Error bool + ErrorMessage string + Ok bool + type AmqpOptions struct + Host string + Password string + Port int + Username string + Vhost string + type AmqpPool struct + type AmqpProduceResponse struct + Error bool + ErrorMessage string + type Client struct + func (client *Client) Get(opts GetDeliveryOptions) (AmqpConsumeResponse, error) + func (client *Client) Publish(opts PublishOptions, msg amqp.Publishing) (AmqpProduceResponse, error) + func (client *Client) Teardown() + type Exchange struct + func (exchange *Exchange) Bind(client *Client, opts ExchangeBindOptions) error + func (exchange *Exchange) Unind(client *Client, opts ExchangeUnbindOptions) error + func (queue *Exchange) Declare(client *Client, opts ExchangeDeclareOptions) error + func (queue *Exchange) Delete(client *Client, opts ExchangeDeleteOptions) error + type ExchangeBindOptions struct + Args amqp.Table + Destination string + Key string + NoWait bool + Source string + type ExchangeDeclareOptions struct + Args amqp.Table + AutoDelete bool + Durable bool + Internal bool + Kind string + Name string + NoWait bool + type ExchangeDeleteOptions struct + IfUnused bool + Name string + NoWait bool + type ExchangeUnbindOptions struct + Args amqp.Table + Destination string + Key string + NoWait bool + Source string + type GetDeliveryOptions struct + AutoAck bool + Queue string + type K9amqp struct + func (k9amqp *K9amqp) XClient(call sobek.ConstructorCall, rt *sobek.Runtime) *sobek.Object + type ModuleInstance struct + func (mi *ModuleInstance) Exports() modules.Exports + type PoolOptions struct + ChannelsCacheSize int + ChannelsPerConn int + type PublishOptions struct + Exchange string + Immediate bool + Key string + Mandatory bool + type Queue struct + func (queue *Queue) Bind(client *Client, opts QueueBindOptions) error + func (queue *Queue) Declare(client *Client, opts QueueDeclareOptions) (*amqp.Queue, error) + func (queue *Queue) Delete(client *Client, opts QueueDeleteOptions) error + func (queue *Queue) Unbind(client *Client, opts QueueBindOptions) error + type QueueBindOptions struct + Args amqp.Table + Exchange string + Key string + Name string + NoWait bool + type QueueDeclareOptions struct + Args amqp.Table + AutoDelete bool + Durable bool + Exclusive bool + Name string + NoWait bool + Passive bool + type QueueDeleteOptions struct + IfEmpty bool + IfUnused bool + Name string + NoWait bool + type QueueUnindOptions struct + Args amqp.Table + Exchange string + Key string + Name string + type RootModule struct + func New() *RootModule + func (*RootModule) NewModuleInstance(vu modules.VU) modules.Instance
Go to main page