watermillamqptest

Documentation

Index

• func NewPubSub(tb watermilltest.TestingTB, conn *amqp.ConnectionWrapper, ...) (*amqp.Publisher, *amqp.Subscriber)
• type RabbitMQ
  • func NewRabbitMQ(pool *dockertest.Pool, opts ...RabbitMQOption) (*RabbitMQ, error)
  • func (rmq *RabbitMQ) Close() error
  • func (rmq *RabbitMQ) NewConnection(tb watermilltest.TestingTB) *amqp.ConnectionWrapper
• type RabbitMQOption
  • func WithRabbitMQImage(image string) RabbitMQOption
  • func WithRabbitMQTTL(ttlSeconds uint) RabbitMQOption
• type TopicNameGenerator

Functions

func NewPubSub

func NewPubSub(
	tb watermilltest.TestingTB,
	conn *amqp.ConnectionWrapper,
	queueNameGenerator amqp.QueueNameGenerator,
	exchangeAndRoutingKeyNameGenerator TopicNameGenerator,
) (*amqp.Publisher, *amqp.Subscriber)

Types

type RabbitMQ

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

func NewRabbitMQ

func NewRabbitMQ(pool *dockertest.Pool, opts ...RabbitMQOption) (*RabbitMQ, error)

NewRabbitMQ constructs a new RabbitMQ resource. If the env variable 'TESTS_RABBITMQ_CONNECTION_STRING' is set, this function doesn't run a new Docker container and uses the value of this variable as a connection string, otherwise this function runs a new RabbitMQ instance in a Docker container. This function is intended for use in TestMain.

func (*RabbitMQ) Close

func (rmq *RabbitMQ) Close() error

func (*RabbitMQ) NewConnection

func (rmq *RabbitMQ) NewConnection(tb watermilltest.TestingTB) *amqp.ConnectionWrapper

type RabbitMQOption

type RabbitMQOption func(cfg *rabbitMQConfig)

func WithRabbitMQImage

func WithRabbitMQImage(image string) RabbitMQOption

func WithRabbitMQTTL

func WithRabbitMQTTL(ttlSeconds uint) RabbitMQOption

type TopicNameGenerator

type TopicNameGenerator amqp.QueueNameGenerator