kafka

Documentation

Index

• Constants
• type Container
  • func NewContainer(ctx context.Context, opts ...RequestFn) (*Container, error)
  • func (c *Container) Admin(ctx context.Context) (*kadm.Client, error)
  • func (c *Container) Broker(ctx context.Context) (string, error)
  • func (c *Container) Client(ctx context.Context, opts ...kgo.Opt) (*kgo.Client, error)
  • func (c *Container) Properties(ctx context.Context) (map[string]any, error)
  • func (c *Container) Stop(ctx context.Context) error
• type Request
• type RequestFn

Constants

const (
	DefaultPort                 = 9092
	DefaultAdminPort            = 9644
	DefaultVersion              = "v23.2.12"
	ContainerEntrypointFile     = "/entrypoint-tc.sh"
	RedPandaDir                 = "/etc/redpanda"
	RedPandaBootstrapConfigFile = ".bootstrap.yaml"
	RedPandaBConfigFile         = "redpanda.yaml"
)

Types

type Container

type Container struct {
	testcontainers.Container
}

func NewContainer

func NewContainer(ctx context.Context, opts ...RequestFn) (*Container, error)

func (*Container) Admin

func (c *Container) Admin(ctx context.Context) (*kadm.Client, error)

func (*Container) Broker

func (c *Container) Broker(ctx context.Context) (string, error)

func (*Container) Client

func (c *Container) Client(ctx context.Context, opts ...kgo.Opt) (*kgo.Client, error)

func (*Container) Properties

func (c *Container) Properties(ctx context.Context) (map[string]any, error)

func (*Container) Stop

func (c *Container) Stop(ctx context.Context) error

type Request

type Request struct {
	testcontainers.ContainerRequest
}

type RequestFn

type RequestFn func(*Request) *Request