containers

Jul 22, 2023

Changes in this version

+ 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 struct

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

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

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