rabbitmq

Documentation

Index

• type ConsumerOptions
  • func (options *ConsumerOptions) SetupQueue(ch *amqp.Channel) error
• type Container
  • func Start(ctx context.Context, options Options) (Container, error)
  • func (c *Container) Terminate(ctx context.Context)
• type Options
• type ProducerOptions
  • func (options *ProducerOptions) ConnectionURI() string
  • func (options *ProducerOptions) SetupConnection() (*amqp.Connection, *amqp.Channel, error)

Types

type ConsumerOptions

type ConsumerOptions struct {
	ExchangeName       string
	QueueName          string
	ExchangeRoutingKey string
	QueueLength        int64
}

ConsumerOptions ...

func (*ConsumerOptions) SetupQueue

func (options *ConsumerOptions) SetupQueue(ch *amqp.Channel) error

SetupQueue ...

type Container

type Container struct {
	Container testcontainers.Container
	tc.ContainerConfig
	Host string
	Port int64
}

Container ...

func Start

func Start(ctx context.Context, options Options) (Container, error)

Start ...

func (*Container) Terminate

func (c *Container) Terminate(ctx context.Context)

Terminate ...

type Options

type Options struct {
	tc.ContainerOptions
	ImageTag string
}

Options ...

type ProducerOptions

type ProducerOptions struct {
	Host               string
	Port               int64
	ExchangeName       string
	ExchangeRoutingKey string
}

ProducerOptions for rabbitmq

func (*ProducerOptions) ConnectionURI

func (options *ProducerOptions) ConnectionURI() string

ConnectionURI ...

func (*ProducerOptions) SetupConnection

func (options *ProducerOptions) SetupConnection() (*amqp.Connection, *amqp.Channel, error)

SetupConnection ...