[Live Now] Join the 1-day Testing & QA Summit featuring 15+ Expert Speakers.Join for FREE! Join TestMu Conference

How to use Health method of testcontainers Package

Best Testcontainers-go code snippet using testcontainers.Health

dbcheck_test.go

Source:dbcheck_test.go

...41	}42	uri := fmt.Sprintf("postgres://root@%s:%s", hostIP, mappedPort.Port())43	return &cockroachDBContainer{Container: container, URI: uri}, nil44}45func TestBuildDBHealthCheckFuncStateDown(t *testing.T) {46	if testing.Short() {47		t.Skip("skipping integration test")48	}49	ctx := context.Background()50	cdbContainer, err := setupCockroachDB(ctx)51	require.NoError(t, err, "Failed to start up CockroachDB container")52	defer cdbContainer.Terminate(ctx)53	db, err := sql.Open("pgx", cdbContainer.URI+"/projectmanagement")54	require.NoError(t, err, "Failed to open connection to CockroachDB")55	defer db.Close()56	dbHealthCheckFunc := healthcheck.BuildDBHealthCheckFunc(db)57	require.NotNil(t, dbHealthCheckFunc)58	// Simulate a database outage59	cdbContainer.Terminate(ctx)60	healthStatus := dbHealthCheckFunc(ctx)61	assert.Equal(t, health.StateDown, healthStatus.State)62	assert.Nil(t, healthStatus.Details)63}64func TestBuildDBHealthCheckFuncStateUp(t *testing.T) {65	if testing.Short() {66		t.Skip("skipping integration test")67	}68	ctx := context.Background()69	cdbContainer, err := setupCockroachDB(ctx)70	require.NoError(t, err, "Failed to start up CockroachDB container")71	defer cdbContainer.Terminate(ctx)72	db, err := sql.Open("pgx", cdbContainer.URI+"/projectmanagement")73	require.NoError(t, err, "Failed to open connection to CockroachDB")74	defer db.Close()75	dbHealthCheckFunc := healthcheck.BuildDBHealthCheckFunc(db)76	require.NotNil(t, dbHealthCheckFunc)77	healthStatus := dbHealthCheckFunc(ctx)78	assert.Equal(t, health.StateUp, healthStatus.State)79	assert.Equal(t, healthcheck.DBDetails{ConnectionsInUse: 0, ConnectionsIdle: 1}, healthStatus.Details)80}...

setupdb_docker_test.go

Source:setupdb_docker_test.go

...28			WithStartupTimeout(1 * time.Minute).29			WithPollInterval(1 * time.Second).30			WithResponseMatcher(func(body io.Reader) bool {31				jd := json.NewDecoder(body)32				var result api.HealthStatus33				if err := jd.Decode(&result); err != nil {34					return false35				}36				return result.Ok37			}),38	}39	typesenseC, err = testcontainers.GenericContainer(ctx,40		testcontainers.GenericContainerRequest{41			ContainerRequest: req,42			Started:          true,43		})44	if err != nil {45		log.Println("container error!")46		return nil, err...

health_cmd.go

Source:health_cmd.go

...5	"io"6	"github.com/testcontainers/testcontainers-go/wait"7	"go.nhat.io/testcontainers-extra"8)9func healthCheckTestCmd(cmd []string) HealthCheckTestFunc {10	return func(ctx context.Context, target wait.StrategyTarget) (success bool, err error) {11		state, err := target.State(ctx)12		if err != nil {13			return false, err14		}15		if !isCmdTestable(state.Status) {16			logs, err := target.Logs(ctx)17			if err != nil {18				return false, fmt.Errorf("container is %s and unable to get logs: %w", state.Status, err)19			}20			if logs != nil {21				out, err := io.ReadAll(logs)22				if err != nil {23					return false, fmt.Errorf("container is %s and unable to read logs: %w", state.Status, err)24				}25				return false, fmt.Errorf("container is %s, logs:\n%s", state.Status, string(out))26			}27			return false, fmt.Errorf("container is %s and no logs", state.Status)28		}29		if !state.Running {30			return false, nil31		}32		code, _, err := target.Exec(ctx, cmd)33		if err != nil {34			return false, err35		}36		return code == 0, nil37	}38}39// ForHealthCheckCmd checks by running a command in the container.40func ForHealthCheckCmd(cmd string, args ...string) *HealthCheckStrategy {41	test := make([]string, 0, len(args)+1)42	test = append(test, cmd)43	test = append(test, args...)44	return ForHealthCheck(healthCheckTestCmd(test))45}46func isCmdTestable(status string) bool {47	return testcontainers.ContainerStatusCreated.Equal(status) ||48		testcontainers.ContainerStatusRunning.Equal(status) ||49		testcontainers.ContainerStatusRestarting.Equal(status)50}...

Health

Using AI Code Generation

1import (2func main() {3    ctx := context.Background()4    req := testcontainers.ContainerRequest{5        Cmd:          []string{"echo", "Hello world!"},6        WaitingFor:   wait.ForLog("Hello world!"),7    }8    container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9    })10    if err != nil {11        panic(err)12    }13    defer container.Terminate(ctx)14    ip, err := container.Host(ctx)15    if err != nil {16        panic(err)17    }18    port, err := container.MappedPort(ctx, "8080")19    if err != nil {20        panic(err)21    }22    fmt.Println(ip, port.Int())23}24import (25func main() {26    ctx := context.Background()27    req := testcontainers.ContainerRequest{28        Cmd:          []string{"echo", "Hello world!"},29        WaitingFor:   wait.ForLog("Hello world!"),30    }31    container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{32    })33    if err != nil {34        panic(err)35    }36    defer container.Terminate(ctx)37    ip, err := container.Host(ctx)38    if err != nil {39        panic(err)40    }41    port, err := container.MappedPort(ctx, "8080")42    if err != nil {43        panic(err)44    }45    fmt.Println(ip, port.Int())46}47import (48func main() {49    ctx := context.Background()50    req := testcontainers.ContainerRequest{51        Cmd:          []string{"echo", "Hello

Health

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"5432/tcp"},6		WaitingFor:   wait.ForLog("database system is ready to accept connections"),7	}8	postgres, _ := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	defer postgres.Terminate(ctx)11}

Health

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"6379/tcp"},6		WaitingFor:   wait.ForLog("Ready to accept connections"),7	}8	redis, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatal(err)12	}13	defer redis.Terminate(ctx)14	ip, err := redis.Host(ctx)15	if err != nil {16		log.Fatal(err)17	}18	port, err := redis.MappedPort(ctx, "6379")19	if err != nil {20		log.Fatal(err)21	}22	fmt.Println(ip, port.Int())23	time.Sleep(10 * time.Second)24}

Health

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"6379/tcp"},6		WaitingFor:   wait.ForListeningPort("6379/tcp"),7	}8	redisContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatal(err)12	}13	defer redisContainer.Terminate(ctx)14	redisHost, err := redisContainer.Host(ctx)15	if err != nil {16		log.Fatal(err)17	}18	redisPort, err := redisContainer.MappedPort(ctx, "6379")19	if err != nil {20		log.Fatal(err)21	}22	fmt.Println(redisHost)23	fmt.Println(redisPort.Int())24	time.Sleep(5 * time.Minute)25}

Health

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"5432/tcp"},6		WaitingFor:   wait.ForListeningPort("5432/tcp"),7	}8	postgresContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatal(err)12	}13	ip, err := postgresContainer.Host(ctx)14	if err != nil {15		log.Fatal(err)16	}17	port, err := postgresContainer.MappedPort(ctx, "5432/tcp")18	if err != nil {19		log.Fatal(err)20	}21	fmt.Println(ip, port.Int())22	err = postgresContainer.Terminate(ctx)23	if err != nil {24		log.Fatal(err)25	}26	_, err = postgresContainer.Wait(ctx)27	if err != nil {28		log.Fatal(err)29	}30}

Health

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"5432/tcp"},6		WaitingFor:   testcontainers.WaitingForLog("database system is ready to accept connections"),7	}8	postgresContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatal(err)12	}13	defer postgresContainer.Terminate(ctx)14	ip, err := postgresContainer.Host(ctx)15	if err != nil {16		log.Fatal(err)17	}18	port, err := postgresContainer.MappedPort(ctx, "5432")19	if err != nil {20		log.Fatal(err)21	}22	fmt.Println(ip, port.Int())23}

Health

Using AI Code Generation

1import (2func main() {3	cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())4	if err != nil {5		panic(err)6	}7	ctx := context.Background()

Health

Using AI Code Generation

1func   main ( )   { 2 }3 import   ( 4 func   TestStart ( t   * testing . T )   { 5 } 6 func   TestHealth ( t   * testing . T )   { 7 } 8 func   TestStop ( t   * testing . T )   { 9 }10 import   ( 11 func   TestStart ( t   * testing . T )   { 12 } 13 func   TestHealth ( t   * testing . T )   { 14 } 15 func   TestStop ( t   * testing . T )   { 16 }17 import   ( 18 func   TestStart ( t   * testing . T )   { 19 } 20 func   TestHealth ( t   * testing . T )   { 21 } 22 func   TestStop ( t   * testing . T )   { 23 }24 import   ( 25 func   TestStart ( t   * testing . T )   { 26 } 27 func   TestHealth ( t   * testing . T )   { 28 } 29 func   TestStop ( t   * testing . T )   { 30 }

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.