package containers

import "github.com/apache/beam/sdks/v2/go/test/integration/internal/containers"

Package containers contains utilities for running test containers in integration tests.

Index ¶

• func NewContainer( ctx context.Context, t *testing.T, image string, maxRetries int, opts ...ContainerOptionFn, ) testcontainers.Container
• func Port( ctx context.Context, t *testing.T, container testcontainers.Container, port nat.Port, ) string
• type ContainerOptionFn
• func WithEnv(env map[string]string) ContainerOptionFn
• func WithHostname(hostname string) ContainerOptionFn
• func WithPorts(ports []string) ContainerOptionFn
• func WithWaitStrategy(waitStrategy wait.Strategy) ContainerOptionFn

Functions ¶

func NewContainer ¶

func NewContainer(
	ctx context.Context,
	t *testing.T,
	image string,
	maxRetries int,
	opts ...ContainerOptionFn,
) testcontainers.Container

func Port ¶

func Port(
	ctx context.Context,
	t *testing.T,
	container testcontainers.Container,
	port nat.Port,
) string

Types ¶

type ContainerOptionFn ¶

type ContainerOptionFn func(*testcontainers.ContainerRequest)

func WithEnv ¶

func WithEnv(env map[string]string) ContainerOptionFn

func WithHostname ¶

func WithHostname(hostname string) ContainerOptionFn

func WithPorts ¶

func WithPorts(ports []string) ContainerOptionFn

func WithWaitStrategy ¶

func WithWaitStrategy(waitStrategy wait.Strategy) ContainerOptionFn

Source Files ¶

containers.go