Documentation
¶
Index ¶
- Constants
- func BridgeNetwork(_ context.Context, name string) (testcontainers.Network, error)
- func Mongo(ctx context.Context, opts ...MongoOption) (db *mongo.Database, terminate func(), err error)
- func Redis(ctx context.Context, opts ...RedisOption) (cli *redis.Client, terminate func(), err error)
- type ContainerNames
- type KafkaBroker
- type KafkaOption
- type MongoOption
- func MongoContainerBootstrapTimeout(timeout time.Duration) MongoOption
- func MongoContainerEnv(envs map[string]string) MongoOption
- func MongoContainerName(name string) MongoOption
- func MongoContainerNetwork(networks []string) MongoOption
- func MongoContainerPort(port int) MongoOption
- func MongoEnableLogger() MongoOption
- func MongoEnableReplicaSet() MongoOption
- func MongoImageTag(tag string) MongoOption
- type RedisOption
- func RedisContainerBootstrapTimeout(timeout time.Duration) RedisOption
- func RedisContainerEnv(envs map[string]string) RedisOption
- func RedisContainerName(name string) RedisOption
- func RedisContainerNetwork(networks []string) RedisOption
- func RedisContainerPort(port int) RedisOption
- func RedisEnableLogger() RedisOption
- func RedisImageTag(tag string) RedisOption
- func RedisServerOptions(serverOpts *redis.Options) RedisOption
- type Sets
- func (i *Sets) Close()
- func (i *Sets) Err() error
- func (i *Sets) KafkaAddr() []string
- func (i *Sets) KafkaVersion() string
- func (i *Sets) MongoDB() *mongo.Database
- func (i *Sets) RedisClient() *redis.Client
- func (i *Sets) RemoveNetwork(ctx context.Context) error
- func (i *Sets) SetupBridgeNetwork(ctx context.Context)
- func (i *Sets) SetupKafka(ctx context.Context)
- func (i *Sets) SetupMongo(ctx context.Context)
- func (i *Sets) SetupMongoReplicaSet(ctx context.Context)
- func (i *Sets) SetupRedis(ctx context.Context)
Constants ¶
View Source
const ( DefaultMongo = "test-mongo" DefaultRedis = "test-redis" DefaultKafka = "test-kafka" DefaultZookeeper = "test-zoo" DefaultNetwork = "test-network" )
Variables ¶
This section is empty.
Functions ¶
func BridgeNetwork ¶
Types ¶
type ContainerNames ¶
type KafkaBroker ¶
func Kafka ¶
func Kafka(ctx context.Context, opts ...KafkaOption) (broker KafkaBroker, terminate func(), err error)
type KafkaOption ¶
type KafkaOption func(options *kafkaOptions)
func KafkaContainerName ¶
func KafkaContainerName(name string) KafkaOption
func KafkaContainerNetwork ¶
func KafkaContainerNetwork(networks []string) KafkaOption
func KafkaEnableLogger ¶
func KafkaEnableLogger() KafkaOption
func KafkaImageTag ¶
func KafkaImageTag(tag string) KafkaOption
func ZookeeperContainerName ¶
func ZookeeperContainerName(name string) KafkaOption
func ZookeeperImageTag ¶
func ZookeeperImageTag(tag string) KafkaOption
type MongoOption ¶
type MongoOption func(options *mongoOptions)
func MongoContainerBootstrapTimeout ¶
func MongoContainerBootstrapTimeout(timeout time.Duration) MongoOption
func MongoContainerEnv ¶
func MongoContainerEnv(envs map[string]string) MongoOption
func MongoContainerName ¶
func MongoContainerName(name string) MongoOption
func MongoContainerNetwork ¶
func MongoContainerNetwork(networks []string) MongoOption
func MongoContainerPort ¶
func MongoContainerPort(port int) MongoOption
func MongoEnableLogger ¶
func MongoEnableLogger() MongoOption
func MongoEnableReplicaSet ¶ added in v0.2.5
func MongoEnableReplicaSet() MongoOption
func MongoImageTag ¶
func MongoImageTag(tag string) MongoOption
type RedisOption ¶
type RedisOption func(*redisOptions)
func RedisContainerBootstrapTimeout ¶
func RedisContainerBootstrapTimeout(timeout time.Duration) RedisOption
func RedisContainerEnv ¶
func RedisContainerEnv(envs map[string]string) RedisOption
func RedisContainerName ¶
func RedisContainerName(name string) RedisOption
func RedisContainerNetwork ¶
func RedisContainerNetwork(networks []string) RedisOption
func RedisContainerPort ¶
func RedisContainerPort(port int) RedisOption
func RedisEnableLogger ¶
func RedisEnableLogger() RedisOption
func RedisImageTag ¶
func RedisImageTag(tag string) RedisOption
func RedisServerOptions ¶
func RedisServerOptions(serverOpts *redis.Options) RedisOption
type Sets ¶
type Sets struct { ContainerNames ContainerNames // contains filtered or unexported fields }
func (*Sets) KafkaVersion ¶
func (*Sets) RedisClient ¶
func (*Sets) SetupBridgeNetwork ¶
func (*Sets) SetupKafka ¶
func (*Sets) SetupMongo ¶
func (*Sets) SetupMongoReplicaSet ¶ added in v0.2.5
func (*Sets) SetupRedis ¶
Click to show internal directories.
Click to hide internal directories.