containers

Documentation

Index

• func SetupKafkaContainer() (testcontainers.Container, []string, error)
• func SetupLocalStackWithKinesis() (testcontainers.Container, string, error)
• func SetupLocalStackWithSQS(region, queueName string) (testcontainers.Container, string, string, error)
• func SetupNatsContainer() (testcontainers.Container, string, error)
• func SetupRedPandaContainer() (testcontainers.Container, []string, error)
• func SetupRedisContainer() (testcontainers.Container, string, error)
• type ConfigProvider
  • func SetupTimescaleContainer() (testcontainers.Container, *ConfigProvider, error)
  • func (c *ConfigProvider) ReplicationConnConfig() (*pgx.ConnConfig, error)
  • func (c *ConfigProvider) UserConnConfig() (*pgxpool.Config, error)

Functions

func SetupKafkaContainer

func SetupKafkaContainer() (testcontainers.Container, []string, error)

func SetupLocalStackWithKinesis

func SetupLocalStackWithKinesis() (testcontainers.Container, string, error)

func SetupLocalStackWithSQS

func SetupLocalStackWithSQS(
	region, queueName string,
) (testcontainers.Container, string, string, error)

func SetupNatsContainer

func SetupNatsContainer() (testcontainers.Container, string, error)

func SetupRedPandaContainer

func SetupRedPandaContainer() (testcontainers.Container, []string, error)

func SetupRedisContainer

func SetupRedisContainer() (testcontainers.Container, string, error)

Types

type ConfigProvider

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

func SetupTimescaleContainer

func SetupTimescaleContainer() (testcontainers.Container, *ConfigProvider, error)

func (*ConfigProvider) ReplicationConnConfig

func (c *ConfigProvider) ReplicationConnConfig() (*pgx.ConnConfig, error)

func (*ConfigProvider) UserConnConfig

func (c *ConfigProvider) UserConnConfig() (*pgxpool.Config, error)