KaneAI - World’s First E2E Software Testing Agent.Book a Demo Join TestMu Conference

How to use RunServices method of testcontainers Package

Best Testcontainers-go code snippet using testcontainers.RunServices

compose_api_test.go

Source:compose_api_test.go

...52	assert.Equal(t, 2, len(serviceNames))53	assert.Contains(t, serviceNames, "nginx")54	assert.Contains(t, serviceNames, "mysql")55}56func TestDockerComposeAPIWithRunServices(t *testing.T) {57	compose, err := NewDockerCompose("./testresources/docker-compose-complex.yml")58	assert.NoError(t, err, "NewDockerCompose()")59	t.Cleanup(func() {60		assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")61	})62	ctx, cancel := context.WithCancel(context.Background())63	t.Cleanup(cancel)64	err = compose.65		WaitForService("nginx", wait.NewHTTPStrategy("/").WithPort("80/tcp").WithStartupTimeout(10*time.Second)).66		Up(ctx, Wait(true), RunServices("nginx"))67	assert.NoError(t, err, "compose.Up()")68	serviceNames := compose.Services()69	_, err = compose.ServiceContainer(context.Background(), "mysql")70	assert.Error(t, err, "Make sure there is no mysql container")71	assert.Equal(t, 1, len(serviceNames))72	assert.Contains(t, serviceNames, "nginx")73}74func TestDockerComposeAPIWithWaitForService(t *testing.T) {75	compose, err := NewDockerCompose("./testresources/docker-compose-simple.yml")76	assert.NoError(t, err, "NewDockerCompose()")77	t.Cleanup(func() {78		assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")79	})80	ctx, cancel := context.WithCancel(context.Background())...

compose_api.go

Source:compose_api.go

...22type stackDownOptionFunc func(do *api.DownOptions)23func (f stackDownOptionFunc) applyToStackDown(do *api.DownOptions) {24	f(do)25}26// RunServices is comparable to 'docker-compose run' as it only creates a subset of containers27// instead of all services defined by the project28func RunServices(serviceNames ...string) StackUpOption {29	return stackUpOptionFunc(func(o *stackUpOptions) {30		o.Services = serviceNames31	})32}33// IgnoreOrphans - Ignore legacy containers for services that are not defined in the project34type IgnoreOrphans bool35func (io IgnoreOrphans) applyToStackUp(co *api.CreateOptions, _ *api.StartOptions) {36	co.IgnoreOrphans = bool(io)37}38// RemoveOrphans will cleanup containers that are not declared on the compose model but own the same labels39type RemoveOrphans bool40func (ro RemoveOrphans) applyToStackUp(o *stackUpOptions) {41	o.RemoveOrphans = bool(ro)42}...

RunServices

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	redis, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		panic(err)12	}13	defer redis.Terminate(ctx)14	ip, err := redis.Host(ctx)15	if err != nil {16		panic(err)17	}18	port, err := redis.MappedPort(ctx, "6379/tcp")19	if err != nil {20		panic(err)21	}22	fmt.Printf("Redis is available at %s:%s", ip, port.Port())23}

RunServices

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, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatal(err)12	}13	ip, err := postgres.Host(ctx)14	if err != nil {15		log.Fatal(err)16	}17	port, err := postgres.MappedPort(ctx, "5432")18	if err != nil {19		log.Fatal(err)20	}21	fmt.Println("postgres is ready at", ip, port.Int())22	err = postgres.Terminate(ctx)23	if err != nil {24		log.Fatal(err)25	}26}

RunServices

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	redis, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatalf("Could not start container: %v", err)12	}13	defer redis.Terminate(ctx)14	redisPort, err := redis.MappedPort(ctx, "6379")15	if err != nil {16		log.Fatalf("Could not map port: %v", err)17	}18	fmt.Printf("Redis port is %d19", redisPort.Int())20	redisHost, err := redis.Host(ctx)21	if err != nil {22		log.Fatalf("Could not get host: %v", err)23	}24	fmt.Printf("Redis host is %s25	redisIP, err := redis.ContainerIP(ctx)26	if err != nil {27		log.Fatalf("Could not get IP: %v", err)28	}29	fmt.Printf("Redis IP is %s30	redisID, err := redis.ContainerID(ctx)31	if err != nil {32		log.Fatalf("Could not get ID: %v", err)33	}34	fmt.Printf("Redis ID is %s35	redisInfo, err := redis.Inspect(ctx)36	if err != nil {37		log.Fatalf("Could not inspect container: %v", err)38	}39	fmt.Printf("Redis container info is %#v40	redisLogs, err := redis.Logs(ctx)41	if err != nil {42		log.Fatalf("Could not get logs: %v", err)43	}44	fmt.Printf("Redis logs are %s

RunServices

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	redis, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatalf("Could not start resource: %s", err)12	}13	defer redis.Terminate(ctx)14	ip, err := redis.Host(ctx)15	if err != nil {16		log.Fatalf("Could not get container IP: %s", err)17	}18	port, err := redis.MappedPort(ctx, "6379")19	if err != nil {20		log.Fatalf("Could not get container port: %s", err)21	}22	log.Printf("Container port is %s", port.Port())23	stop := make(chan os.Signal, 1)24	signal.Notify(stop, syscall.SIGTERM, syscall.SIGINT)25}26import (27func main() {28	ctx := context.Background()29	req := testcontainers.ContainerRequest{30		ExposedPorts: []string{"6379/tcp"},31		WaitingFor:   wait.ForListeningPort("6379/tcp"),32	}33	redis, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{34	})35	if err != nil {36		log.Fatalf("Could not start resource: %s", err)37	}38	defer redis.Terminate(ctx)39	ip, err := redis.Host(ctx)40	if err != nil {41		log.Fatalf("Could not get container IP: %s", err)

RunServices

Using AI Code Generation

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

RunServices

Using AI Code Generation

1func main() {2    ctx := context.Background()3    req := testcontainers.ContainerRequest{4        ExposedPorts: []string{"80/tcp"},5        WaitingFor:   wait.ForHTTP("/"),6    }7    container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{8    })9    if err != nil {10        panic(err)11    }12    defer container.Terminate(ctx)13    ip, err := container.Host(ctx)14    if err != nil {15        panic(err)16    }17    port, err := container.MappedPort(ctx, "80")18    if err != nil {19        panic(err)20    }21    fmt.Printf("Container is listening on %s:%s22", ip, port.Port())23}24func main() {25    ctx := context.Background()26    req := testcontainers.ContainerRequest{27        ExposedPorts: []string{"80/tcp"},28        WaitingFor:   wait.ForHTTP("/"),29    }30    container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{31    })32    if err != nil {33        panic(err)34    }35    defer container.Terminate(ctx)36    ip, err := container.Host(ctx)37    if err != nil {38        panic(err)39    }40    port, err := container.MappedPort(ctx, "80")41    if err != nil {42        panic(err)43    }44    fmt.Printf("Container is listening on %s:%s45", ip, port.Port())46}47func main() {48    ctx := context.Background()49    req := testcontainers.ContainerRequest{50        ExposedPorts: []string{"80/tcp"},51        WaitingFor:   wait.ForHTTP("/"),52    }53    container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{54    })55    if err != nil {56        panic(err)57    }58    defer container.Terminate(ctx)59    ip, err := container.Host(ctx)60    if err != nil {61        panic(err)62    }

RunServices

Using AI Code Generation

1import (2func TestRunServices(t *testing.T) {3	ctx := context.Background()4	redisContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{5		ContainerRequest: testcontainers.ContainerRequest{6			ExposedPorts: []string{"6379/tcp"},7			WaitingFor:   wait.ForListeningPort("6379/tcp"),8		},9	})10	if err != nil {11		log.Fatal(err)12	}13	redisHost, err := redisContainer.Host(ctx)14	if err != nil {15		log.Fatal(err)16	}17	redisPort, err := redisContainer.MappedPort(ctx, "6379/tcp")18	if err != nil {19		log.Fatal(err)20	}21	postgresContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{22		ContainerRequest: testcontainers.ContainerRequest{23			ExposedPorts: []string{"5432/tcp"},24			WaitingFor:   wait.ForListeningPort("5432/tcp"),25		},26	})27	if err != nil {28		log.Fatal(err)29	}30	postgresHost, err := postgresContainer.Host(ctx)31	if err != nil {32		log.Fatal(err)33	}34	postgresPort, err := postgresContainer.MappedPort(ctx, "5432/tcp")35	if err != nil {36		log.Fatal(err)37	}38	os.Setenv("REDIS_HOST", redisHost)39	os.Setenv("REDIS_PORT", redisPort.Port())40	os.Setenv("POSTGRES_HOST", postgresHost)41	os.Setenv("POSTGRES_PORT", postgresPort.Port())42	os.Exit(m.Run())43}44import (45func TestRunServices(t *testing.T) {46	ctx := context.Background()

RunServices

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"6379/tcp"},6		WaitingFor:   testcontainers.WaitingForLog("Ready to accept connections"),7	}8	redisContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatal(err)12	}13	containerIP, err := redisContainer.Host(ctx)14	if err != nil {15		log.Fatal(err)16	}17	containerPort, err := redisContainer.MappedPort(ctx, "6379")18	if err != nil {19		log.Fatal(err)20	}21	fmt.Println(containerIP, containerPort.Port())22	err = redisContainer.Terminate(ctx)23	if err != nil {24		log.Fatal(err)25	}26}

RunServices

Using AI Code Generation

1func main() {2    ctx := context.Background()3    req := testcontainers.ContainerRequest{4        Cmd:   []string{"echo", "Hello, world!"},5    }6    resp, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{7    })8    if err != nil {9        panic(err)10    }11    defer resp.Terminate(ctx)12    logs, err := resp.Logs(ctx)13    if err != nil {14        panic(err)15    }16    fmt.Println(logs)17}18func main() {19    ctx := context.Background()20    req := testcontainers.ContainerRequest{21        Cmd:   []string{"echo", "Hello, world!"},22    }23    resp, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{24    })25    if err != nil {26        panic(err)27    }28    defer resp.Terminate(ctx)29    logs, err := resp.Logs(ctx)30    if err != nil {31        panic(err)32    }33    fmt.Println(logs)34}35func main() {36    ctx := context.Background()37    req := testcontainers.ContainerRequest{38        Cmd:   []string{"echo", "Hello, world!"},39    }40    resp, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{41    })42    if err != nil {43        panic(err

RunServices

Using AI Code Generation

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

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.