testrabbit

Documentation

Index

• Constants
• func AutoStartRabbit(t *testing.T, ctx context.Context) testcontainers.Container
• func BrokerUrl(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) *url.URL
• func CreateDurableQueue(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container, ...)
• func CreateExchange(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container, ...)
• func CreateNonDurableQueue(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container, ...)
• func Host(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) string
• func ManagementPort(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) int
• func ManagementUrl(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) string
• func TerminateContainer(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container)
• type Binding
  • func FindBindings(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) []Binding
• type Exchange
  • func FindOwnedExchanges(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) []Exchange
  • func FindQueues(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) []Exchange
• type Queue

Constants

const BrokerPort = "5672"

const RabbitPassword = "guest"

const RabbitUsername = "guest"

const RabbitVersion = "3.8"

Functions

func AutoStartRabbit

func AutoStartRabbit(t *testing.T, ctx context.Context) testcontainers.Container

func BrokerUrl

func BrokerUrl(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) *url.URL

func CreateDurableQueue

func CreateDurableQueue(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container, queueName string)

func CreateExchange

func CreateExchange(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container, exchangeName, exchangeType string)

func CreateNonDurableQueue

func CreateNonDurableQueue(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container, queueName string)

func Host

func Host(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) string

func ManagementPort

func ManagementPort(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) int

func ManagementUrl

func ManagementUrl(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) string

func TerminateContainer

func TerminateContainer(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container)

Types

type Binding

type Binding = map[string]interface{}

func FindBindings

func FindBindings(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) []Binding

type Exchange

type Exchange = map[string]interface{}

func FindOwnedExchanges

func FindOwnedExchanges(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) []Exchange

func FindQueues

func FindQueues(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) []Exchange

type Queue

type Queue = map[string]interface{}