How to use TestDockerComposeAPI method of testcontainers Package

Best Testcontainers-go code snippet using testcontainers.TestDockerComposeAPI

compose_api_test.go

Source:compose_api_test.go Github

copy

Full Screen

...7 "time"8 "github.com/stretchr/testify/assert"9 "github.com/testcontainers/testcontainers-go/wait"10)11func TestDockerComposeAPI(t *testing.T) {12 compose, err := NewDockerCompose("./testresources/docker-compose-simple.yml")13 assert.NoError(t, err, "NewDockerCompose()")14 t.Cleanup(func() {15 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")16 })17 ctx, cancel := context.WithCancel(context.Background())18 t.Cleanup(cancel)19 assert.NoError(t, compose.Up(ctx, Wait(true)), "compose.Up()")20}21func TestDockerComposeAPIStrategyForInvalidService(t *testing.T) {22 compose, err := NewDockerCompose("./testresources/docker-compose-simple.yml")23 assert.NoError(t, err, "NewDockerCompose()")24 t.Cleanup(func() {25 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")26 })27 ctx, cancel := context.WithCancel(context.Background())28 t.Cleanup(cancel)29 err = compose.30 // Appending with _1 as given in the Java Test-Containers Example31 WaitForService("mysql-1", wait.NewLogStrategy("started").WithStartupTimeout(10*time.Second).WithOccurrence(1)).32 Up(ctx, Wait(true))33 assert.Error(t, err, "Expected error to be thrown because service with wait strategy is not running")34 assert.Equal(t, err.Error(), "no container found for service name mysql-1")35 serviceNames := compose.Services()36 assert.Equal(t, 1, len(serviceNames))37 assert.Contains(t, serviceNames, "nginx")38}39func TestDockerComposeAPIWithWaitLogStrategy(t *testing.T) {40 compose, err := NewDockerCompose("./testresources/docker-compose-complex.yml")41 assert.NoError(t, err, "NewDockerCompose()")42 t.Cleanup(func() {43 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")44 })45 ctx, cancel := context.WithCancel(context.Background())46 t.Cleanup(cancel)47 err = compose.48 WaitForService("mysql", wait.NewLogStrategy("started").WithStartupTimeout(10*time.Second).WithOccurrence(1)).49 Up(ctx, Wait(true))50 assert.NoError(t, err, "compose.Up()")51 serviceNames := compose.Services()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())81 t.Cleanup(cancel)82 err = compose.83 WithEnv(map[string]string{84 "bar": "BAR",85 }).86 WaitForService("nginx", wait.NewHTTPStrategy("/").WithPort("80/tcp").WithStartupTimeout(10*time.Second)).87 Up(ctx, Wait(true))88 assert.NoError(t, err, "compose.Up()")89 serviceNames := compose.Services()90 assert.Equal(t, 1, len(serviceNames))91 assert.Contains(t, serviceNames, "nginx")92}93func TestDockerComposeAPIWithWaitHTTPStrategy(t *testing.T) {94 compose, err := NewDockerCompose("./testresources/docker-compose-simple.yml")95 assert.NoError(t, err, "NewDockerCompose()")96 t.Cleanup(func() {97 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")98 })99 ctx, cancel := context.WithCancel(context.Background())100 t.Cleanup(cancel)101 err = compose.102 WithEnv(map[string]string{103 "bar": "BAR",104 }).105 WaitForService("nginx", wait.NewHTTPStrategy("/").WithPort("80/tcp").WithStartupTimeout(10*time.Second)).106 Up(ctx, Wait(true))107 assert.NoError(t, err, "compose.Up()")108 serviceNames := compose.Services()109 assert.Equal(t, 1, len(serviceNames))110 assert.Contains(t, serviceNames, "nginx")111}112func TestDockerComposeAPIWithContainerName(t *testing.T) {113 compose, err := NewDockerCompose("./testresources/docker-compose-container-name.yml")114 assert.NoError(t, err, "NewDockerCompose()")115 t.Cleanup(func() {116 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")117 })118 ctx, cancel := context.WithCancel(context.Background())119 t.Cleanup(cancel)120 err = compose.121 WithEnv(map[string]string{122 "bar": "BAR",123 }).124 WaitForService("nginx", wait.NewHTTPStrategy("/").WithPort("80/tcp").WithStartupTimeout(10*time.Second)).125 Up(ctx, Wait(true))126 assert.NoError(t, err, "compose.Up()")127 serviceNames := compose.Services()128 assert.Equal(t, 1, len(serviceNames))129 assert.Contains(t, serviceNames, "nginx")130}131func TestDockerComposeAPIWithWaitStrategy_NoExposedPorts(t *testing.T) {132 compose, err := NewDockerCompose("./testresources/docker-compose-no-exposed-ports.yml")133 assert.NoError(t, err, "NewDockerCompose()")134 t.Cleanup(func() {135 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")136 })137 ctx, cancel := context.WithCancel(context.Background())138 t.Cleanup(cancel)139 err = compose.140 WaitForService("nginx", wait.ForLog("Configuration complete; ready for start up")).141 Up(ctx, Wait(true))142 assert.NoError(t, err, "compose.Up()")143 serviceNames := compose.Services()144 assert.Equal(t, 1, len(serviceNames))145 assert.Contains(t, serviceNames, "nginx")146}147func TestDockerComposeAPIWithMultipleWaitStrategies(t *testing.T) {148 compose, err := NewDockerCompose("./testresources/docker-compose-complex.yml")149 assert.NoError(t, err, "NewDockerCompose()")150 t.Cleanup(func() {151 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")152 })153 ctx, cancel := context.WithCancel(context.Background())154 t.Cleanup(cancel)155 err = compose.156 WaitForService("mysql", wait.NewLogStrategy("started").WithStartupTimeout(10*time.Second)).157 WaitForService("nginx", wait.NewHTTPStrategy("/").WithPort("80/tcp").WithStartupTimeout(10*time.Second)).158 Up(ctx, Wait(true))159 assert.NoError(t, err, "compose.Up()")160 serviceNames := compose.Services()161 assert.Equal(t, 2, len(serviceNames))162 assert.Contains(t, serviceNames, "nginx")163 assert.Contains(t, serviceNames, "mysql")164}165func TestDockerComposeAPIWithFailedStrategy(t *testing.T) {166 compose, err := NewDockerCompose("./testresources/docker-compose-simple.yml")167 assert.NoError(t, err, "NewDockerCompose()")168 t.Cleanup(func() {169 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")170 })171 ctx, cancel := context.WithCancel(context.Background())172 t.Cleanup(cancel)173 err = compose.174 WithEnv(map[string]string{175 "bar": "BAR",176 }).177 WaitForService("nginx_1", wait.NewHTTPStrategy("/").WithPort("8080/tcp").WithStartupTimeout(5*time.Second)).178 Up(ctx, Wait(true))179 // Verify that an error is thrown and not nil180 // A specific error message matcher is not asserted since the docker library can change the return message, breaking this test181 assert.Error(t, err, "Expected error to be thrown because of a wrong suplied wait strategy")182 serviceNames := compose.Services()183 assert.Equal(t, 1, len(serviceNames))184 assert.Contains(t, serviceNames, "nginx")185}186func TestDockerComposeAPIComplex(t *testing.T) {187 compose, err := NewDockerCompose("./testresources/docker-compose-complex.yml")188 assert.NoError(t, err, "NewDockerCompose()")189 t.Cleanup(func() {190 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")191 })192 ctx, cancel := context.WithCancel(context.Background())193 t.Cleanup(cancel)194 assert.NoError(t, compose.Up(ctx, Wait(true)), "compose.Up()")195 serviceNames := compose.Services()196 assert.Equal(t, 2, len(serviceNames))197 assert.Contains(t, serviceNames, "nginx")198 assert.Contains(t, serviceNames, "mysql")199}200func TestDockerComposeAPIWithEnvironment(t *testing.T) {201 identifier := testNameHash(t.Name())202 compose, err := NewDockerComposeWith(WithStackFiles("./testresources/docker-compose-simple.yml"), identifier)203 assert.NoError(t, err, "NewDockerCompose()")204 t.Cleanup(func() {205 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")206 })207 ctx, cancel := context.WithCancel(context.Background())208 t.Cleanup(cancel)209 err = compose.210 WithEnv(map[string]string{211 "bar": "BAR",212 }).213 Up(ctx, Wait(true))214 assert.NoError(t, err, "compose.Up()")215 serviceNames := compose.Services()216 assert.Equal(t, 1, len(serviceNames))217 assert.Contains(t, serviceNames, "nginx")218 present := map[string]string{219 "bar": "BAR",220 }221 absent := map[string]string{}222 assertContainerEnvironmentVariables(t, identifier.String(), "nginx", present, absent)223}224func TestDockerComposeAPIWithMultipleComposeFiles(t *testing.T) {225 composeFiles := ComposeStackFiles{226 "testresources/docker-compose-simple.yml",227 "testresources/docker-compose-postgres.yml",228 "testresources/docker-compose-override.yml",229 }230 identifier := testNameHash(t.Name())231 compose, err := NewDockerComposeWith(composeFiles, identifier)232 assert.NoError(t, err, "NewDockerCompose()")233 t.Cleanup(func() {234 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")235 })236 ctx, cancel := context.WithCancel(context.Background())237 t.Cleanup(cancel)238 err = compose.239 WithEnv(map[string]string{240 "bar": "BAR",241 "foo": "FOO",242 }).243 Up(ctx, Wait(true))244 assert.NoError(t, err, "compose.Up()")245 serviceNames := compose.Services()246 assert.Equal(t, 3, len(serviceNames))247 assert.Contains(t, serviceNames, "nginx")248 assert.Contains(t, serviceNames, "mysql")249 assert.Contains(t, serviceNames, "postgres")250 present := map[string]string{251 "bar": "BAR",252 "foo": "FOO",253 }254 absent := map[string]string{}255 assertContainerEnvironmentVariables(t, identifier.String(), "nginx", present, absent)256}257func TestDockerComposeAPIWithVolume(t *testing.T) {258 compose, err := NewDockerCompose("./testresources/docker-compose-volume.yml")259 assert.NoError(t, err, "NewDockerCompose()")260 t.Cleanup(func() {261 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")262 })263 ctx, cancel := context.WithCancel(context.Background())264 t.Cleanup(cancel)265 err = compose.Up(ctx, Wait(true))266 assert.NoError(t, err, "compose.Up()")267}268func TestDockerComposeAPIWithBuild(t *testing.T) {269 compose, err := NewDockerCompose("./testresources/docker-compose-build.yml")270 assert.NoError(t, err, "NewDockerCompose()")271 t.Cleanup(func() {272 assert.NoError(t, compose.Down(context.Background(), RemoveOrphans(true), RemoveImagesLocal), "compose.Down()")273 })274 ctx, cancel := context.WithCancel(context.Background())275 t.Cleanup(cancel)276 err = compose.277 WaitForService("echo", wait.ForHTTP("/env").WithPort("8080/tcp")).278 Up(ctx, Wait(true))279 assert.NoError(t, err, "compose.Up()")280}281func TestDockerComposeApiWithWaitForShortLifespanService(t *testing.T) {282 compose, err := NewDockerCompose("./testresources/docker-compose-short-lifespan.yml")...

Full Screen

Full Screen

TestDockerComposeAPI

Using AI Code Generation

copy

Full Screen

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.Println(ip, port.Int())23}

Full Screen

Full Screen

TestDockerComposeAPI

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 ctx := context.Background()4 req := testcontainers.ContainerRequest{5 ExposedPorts: []string{"9200/tcp"},6 WaitingFor: wait.ForListeningPort("9200/tcp"),7 }8 elasticsearchContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9 })10 if err != nil {11 panic(err)12 }13 ip, err := elasticsearchContainer.Host(ctx)14 if err != nil {15 panic(err)16 }17 port, err := elasticsearchContainer.MappedPort(ctx, "9200/tcp")18 if err != nil {19 panic(err)20 }21 fmt.Println(ip, port.Int())22}

Full Screen

Full Screen

TestDockerComposeAPI

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 ctx := context.Background()4 req := testcontainers.ContainerRequest{5 ExposedPorts: []string{"9200/tcp", "9300/tcp"},6 WaitingFor: wait.ForLog("started"),7 }8 elasticsearchContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9 })10 if err != nil {11 panic(err)12 }13 defer elasticsearchContainer.Terminate(ctx)14 ip, err := elasticsearchContainer.Host(ctx)15 if err != nil {16 panic(err)17 }18 port, err := elasticsearchContainer.MappedPort(ctx, "9200")19 if err != nil {20 panic(err)21 }22 fmt.Println("Elasticsearch is listening on ", ip, ":", port.Int())23}

Full Screen

Full Screen

TestDockerComposeAPI

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 ctx := context.Background()4 req := testcontainers.ContainerRequest{5 ExposedPorts: []string{"8091-8094", "11210-11211"},6 WaitingFor: wait.ForLog("The default bucket has been created and is ready for use"),7 }8 couchbaseContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9 })10 if err != nil {11 log.Fatal(err)12 }13 defer couchbaseContainer.Terminate(ctx)14 ip, err := couchbaseContainer.Host(ctx)15 if err != nil {16 log.Fatal(err)17 }18 port, err := couchbaseContainer.MappedPort(ctx, "8091")19 if err != nil {20 log.Fatal(err)21 }22 id, err := couchbaseContainer.ContainerID(ctx)23 if err != nil {24 log.Fatal(err)25 }26 fmt.Printf("Container ID: %s27", ip, port.Port())28 time.Sleep(2 * time.Second)29}30import (31func main() {32 ctx := context.Background()33 req := testcontainers.ContainerRequest{34 ExposedPorts: []string{"8091-8094", "11210-11211"},35 WaitingFor: wait.ForLog("The default bucket has been created and is ready for use"),36 }37 couchbaseContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{38 })39 if err != nil {

Full Screen

Full Screen

TestDockerComposeAPI

Using AI Code Generation

copy

Full Screen

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 postgresContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9 })10 if err != nil {11 panic(err)12 }13 defer postgresContainer.Terminate(ctx)14 ip, err := postgresContainer.Host(ctx)15 if err != nil {16 panic(err)17 }18 port, err := postgresContainer.MappedPort(ctx, "5432")19 if err != nil {20 panic(err)21 }22 fmt.Printf("postgresql port is %s23", port.Port())24 fmt.Printf("postgresql ip is %s25}26import (27func main() {28 ctx := context.Background()29 req := testcontainers.ContainerRequest{30 ExposedPorts: []string{"5432/tcp"},31 WaitingFor: wait.ForLog("database system is ready to accept connections"),32 }33 postgresContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{34 })35 if err != nil {36 panic(err)37 }38 defer postgresContainer.Terminate(ctx)39 ip, err := postgresContainer.Host(ctx)40 if err != nil {41 panic(err)42 }43 port, err := postgresContainer.MappedPort(ctx, "5432")44 if err != nil {45 panic(err)46 }47 fmt.Printf("postgresql port is %s48", port.Port())49 fmt.Printf("postgresql ip is %s50}

Full Screen

Full Screen

TestDockerComposeAPI

Using AI Code Generation

copy

Full Screen

1import (2func TestDockerComposeAPI() {3 ctx := context.Background()4 compose := testcontainers.NewLocalDockerCompose([]string{"docker-compose.yml"}, "test")5 Invoke(ctx)6 if err != nil {7 panic(err)8 }9 Invoke(ctx)10 if err != nil {11 panic(err)12 }13 Invoke(ctx)14 if err != nil {15 panic(err)16 }17}18func main() {19 TestDockerComposeAPI()20}

Full Screen

Full Screen

TestDockerComposeAPI

Using AI Code Generation

copy

Full Screen

1import (2func TestDockerComposeAPI(t *testing.T) {3 ctx := context.Background()4 cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())5 if err != nil {6 panic(err)7 }8 pwd, err := os.Getwd()9 if err != nil {10 panic(err)11 }12 cmd := exec.Command("docker-compose", "-f", composePath, "up", "-d")13 if err := cmd.Run(); err != nil {14 t.Fatalf("Could not run docker-compose: %v", err)15 }16 fmt.Println("docker-compose stack started")17 defer func() {18 cmd = exec.Command("docker-compose", "-f", composePath, "down")19 if err := cmd.Run(); err != nil {20 t.Fatalf("Could not run docker-compose: %v", err)21 }22 fmt.Println("docker-compose stack stopped")23 }()24 time.Sleep(10 * time.Second)25 containers, err := cli.ContainerList(ctx, types.ContainerListOptions{})26 if err != nil {27 panic(err)28 }29 for _, container := range containers {30 fmt.Println(container.ID)31 }32}33import (34func TestDockerComposeAPI(t *testing.T) {35 ctx := context.Background()36 cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())37 if err != nil {38 panic(err)39 }40 pwd, err := os.Getwd()41 if err != nil {42 panic(err)43 }

Full Screen

Full Screen

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.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Testcontainers-go automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful