influxdb

// runInfluxContainer {
ctx := context.Background()

influxdbContainer, err := influxdb.Run(ctx,
	"influxdb:1.8.10",
	influxdb.WithDatabase("influx"),
	influxdb.WithUsername("root"),
	influxdb.WithPassword("password"),
)
defer func() {
	if err := testcontainers.TerminateContainer(influxdbContainer); err != nil {
		log.Printf("failed to terminate container: %s", err)
	}
}()
if err != nil {
	log.Printf("failed to start container: %s", err)
	return
}
// }

state, err := influxdbContainer.State(ctx)
if err != nil {
	log.Printf("failed to get container state: %s", err)
	return
}

fmt.Println(state.Running)

Output:

true

// runInfluxV2Container {
ctx := context.Background()

username := "username"
password := "password"
org := "org"
bucket := "bucket"
token := "influxdbv2token"

influxdbContainer, err := influxdb.Run(ctx, "influxdb:2.7.11",
	influxdb.WithV2Auth(org, bucket, username, password), // Set the username and password
	influxdb.WithV2AdminToken(token),                     // Set the admin token
)
defer func() {
	if err := testcontainers.TerminateContainer(influxdbContainer); err != nil {
		log.Printf("failed to terminate container: %s", err)
	}
}()
if err != nil {
	log.Printf("failed to start container: %s", err)
	return
}
// }

state, err := influxdbContainer.State(ctx)
if err != nil {
	log.Printf("failed to get container state: %s", err)
	return
}

fmt.Println(state.Running)

// Query the InfluxDB API to verify the setup
url, err := influxdbContainer.ConnectionUrl(ctx)
if err != nil {
	log.Printf("failed to get host: %s", err)
	return
}

// Initialize a new InfluxDB client
client := influxclient2.NewClientWithOptions(url, token, influxclient2.DefaultOptions())
defer client.Close()

// Get the bucket
influxBucket, err := client.BucketsAPI().FindBucketByName(ctx, bucket)
if err != nil {
	log.Printf("failed to get bucket: %s", err)
	return
}

fmt.Println(influxBucket.Name)

Output:

true
bucket