Documentation
¶
Index ¶
Constants ¶
View Source
const ( InfluxUsername = "admin" InfluxPassword = "examplePassword" InfluxOrg = "dev" InfluxBucket = "integration" InfluxToken = "adminToken" )
Variables ¶
This section is empty.
Functions ¶
func CreateRedisClient ¶
Types ¶
type EmqxContainer ¶
type EmqxContainer struct {
testcontainers.Container
URI string
}
func NewEmqxContainer ¶
func NewEmqxContainer(ctx context.Context, networkName string) (*EmqxContainer, error)
func (*EmqxContainer) GetMqttClient ¶
type InfluxContainer ¶
type InfluxContainer struct {
testcontainers.Container
URI string
}
func NewInfluxContainer ¶
func NewInfluxContainer(ctx context.Context, opts ...testcontainers.ContainerCustomizer) (*InfluxContainer, error)
Creates and runs an InfluxDB V2 container with the following environment variables: "DOCKER_INFLUXDB_INIT_USERNAME": "admin", "DOCKER_INFLUXDB_INIT_PASSWORD": "examplePassword", "DOCKER_INFLUXDB_INIT_ORG": "dev", "DOCKER_INFLUXDB_INIT_BUCKET": "integration", "DOCKER_INFLUXDB_INIT_ADMIN_TOKEN": "adminToken",
func (*InfluxContainer) GetConnectionString ¶
func (i *InfluxContainer) GetConnectionString(ctx context.Context) (string, error)
func (*InfluxContainer) GetInfluxClient ¶
type MongoContainer ¶
type MongoContainer struct {
*mongodb.MongoDBContainer
// contains filtered or unexported fields
}
func NewMongoContainer ¶
func NewMongoContainer(ctx context.Context) (*MongoContainer, error)
func (*MongoContainer) Client ¶
func (c *MongoContainer) Client() *mongo.Client
func (*MongoContainer) CreateClient ¶
func (c *MongoContainer) CreateClient(ctx context.Context, databaseName string) (*mongo.Client, *checks.MongoCheck, func(), error)
type RedisContainer ¶
type RedisContainer struct {
*redisT.RedisContainer
}
func NewRedisContainer ¶
func NewRedisContainer(ctx context.Context) (*RedisContainer, error)
func (*RedisContainer) CreateRedisClient ¶
Source Files
Click to show internal directories.
Click to hide internal directories.