Versions in this module Expand all Collapse all v0 v0.0.4 Apr 3, 2025 Changes in this version + var ApplyMigrations = false + var BrokerExternalPort = "9092" + var BrokerInternalPort = "29092" + var CreateDatabasePath = "script/init/01.database.sql" + var CreateSchemaPath = "script/init/02.schema.sql" + var DefaultDB = "postgres" + var DefaultDBPass = "postgres" + var DefaultDBUser = "postgres" + var ErrConfigValidationError = errors.New("config validation error") + var ErrNoBrokerAvailable = errors.New("no broker available") + var ErrNoDockerClient = errors.New("no docker client available") + var ExposePostgresPort = "5432/tcp" + var KafkaBrokerImage = "confluentinc/cp-server:7.5.0" + var MigrationPath = "script/migrations" + var PostgresImage = "postgres:16.4" + type DatabaseContainer struct + func NewDatabaseContainer(ctx context.Context, cfg DatabaseContainerConfig, log Logger) (*DatabaseContainer, error) + func (db *DatabaseContainer) Close(ctx context.Context) + func (db *DatabaseContainer) ConnectionString(ctx context.Context) string + func (db *DatabaseContainer) Port(ctx context.Context) int + func (db *DatabaseContainer) PrepareDB(ctx context.Context) error + type DatabaseContainerConfig struct + DatabaseName string + SchemaOwner string + SchemaOwnerPass string + ServiceUser string + ServiceUserPass string + Timeout time.Duration + func (c *DatabaseContainerConfig) Validate() error + type KafkaContainer struct + func NewKafkaContainer(ctx context.Context, cfg KafkaContainerConfig, logger Logger) (*KafkaContainer, error) + func (target *KafkaContainer) Close(ctx context.Context) + func (target *KafkaContainer) GetBrokerList(ctx context.Context) ([]string, error) + type KafkaContainerConfig struct + Kafka string + Network string + Timeout time.Duration + Waiting time.Duration + func (c *KafkaContainerConfig) Validate() error + type Logger interface + LogDebug func(ctx context.Context, msg string) + LogError func(ctx context.Context, msg string, err error) + LogPanic func(ctx context.Context, msg string, err error) + type MetadataWaitStrategy struct + func NewMetadataWaitStrategy(startupTimeout time.Duration, logger Logger) *MetadataWaitStrategy + func (mw *MetadataWaitStrategy) WaitUntilReady(ctx context.Context, target wait.StrategyTarget) error + type MigrationApplyFunc func(dsn string) error + var MigrationApplyFn MigrationApplyFunc = func(dsn string) error { ... }
Go to main page