How to use Logs method of testcontainers Package

Best Testcontainers-go code snippet using testcontainers.Logs

e2e_test.go

Source:e2e_test.go

...112			ContainerRequest: jaegerReq,113		})114		require.NoError(t, err)115		defer func() {116			logs, errLogs := jaegerContainer.Logs(ctx)117			require.NoError(t, errLogs)118			all, errLogs := ioutil.ReadAll(logs)119			require.NoError(t, errLogs)120			fmt.Printf("Jaeger logs:\n---->\n%s<----\n\n", string(all))121			jaegerContainer.Terminate(ctx)122		}()123		err = jaegerContainer.Start(ctx)124		require.NoError(t, err)125		jaegerContainers = append(jaegerContainers, jaegerContainer)126	}127	for _, jaegerContainer := range jaegerContainers {128		jaegerQueryPort, err := jaegerContainer.MappedPort(ctx, jaegerQueryPort)129		require.NoError(t, err)130		err = awaitility.Await(100*time.Millisecond, time.Second*3, func() bool {131			// Jaeger traces itself so this request generates some spans132			response, errHTTP := http.Get(fmt.Sprintf("http://localhost:%d/api/services", jaegerQueryPort.Int()))133			require.NoError(t, errHTTP)...

main_test.go

Source:main_test.go

...55	t.Run("Container can start", func(t *testing.T) {56		if err != nil {57			t.Fatalf("[Container creation] %s: %v", w, err)58		}59		logs, err := redisC.Logs(ctx)60		if err != nil {61			t.Fatalf("Logs: %s: %v", w, err)62		}63		bytes, err := io.ReadAll(logs)64		if err != nil {65			t.Fatalf("%s: %v", w, err)66		}67		t.Logf("Container logs: \n%s", string(bytes))68		if redisC.GetContainerID() == "" {69			t.Error("Container ID is empty, something went wrong starting the redis container")70		}71	})72	t.Run("Connected to Testcontainers Cloud", func(t *testing.T) {73		if err != nil {74			t.Skip("Container can't be started, seems there is an issue connecting to Testcontainers Cloud")75		}...

container.go

Source:container.go

...25	Image        string26	Name         string27	Address      string28	ExposedPorts []string29	Logs         TestLogConsumer30	Networks     []string31	Entrypoint   []string32}33func (c *Container) Start() error {34	c.ctx = context.Background()35	containerMounts := make([]testcontainers.ContainerMount, 0, len(c.BindMounts))36	for k, v := range c.BindMounts {37		containerMounts = append(containerMounts, testcontainers.BindMount(v, testcontainers.ContainerMountTarget(k)))38	}39	req := testcontainers.GenericContainerRequest{40		ContainerRequest: testcontainers.ContainerRequest{41			Mounts:       testcontainers.Mounts(containerMounts...),42			Entrypoint:   c.Entrypoint,43			Env:          c.Env,44			ExposedPorts: c.ExposedPorts,45			Image:        c.Image,46			Name:         c.Name,47			Networks:     c.Networks,48			WaitingFor:   c.WaitingFor,49		},50		Started: true,51	}52	container, err := testcontainers.GenericContainer(c.ctx, req)53	if err != nil {54		return fmt.Errorf("container failed to start: %w", err)55	}56	c.container = container57	c.Logs = TestLogConsumer{58		Msgs: []string{},59	}60	c.container.FollowOutput(&c.Logs)61	err = c.container.StartLogProducer(c.ctx)62	if err != nil {63		return fmt.Errorf("log producer failed: %w", err)64	}65	c.Address = "localhost"66	err = c.LookupMappedPorts()67	if err != nil {68		_ = c.Terminate()69		return fmt.Errorf("port lookup failed: %w", err)70	}71	return nil72}73// create a lookup table of exposed ports to mapped ports74func (c *Container) LookupMappedPorts() error {75	if len(c.ExposedPorts) == 0 {76		return nil77	}78	if len(c.Ports) == 0 {79		c.Ports = make(map[string]string)80	}81	for _, port := range c.ExposedPorts {82		// strip off leading host port: 80:8080 -> 808083		if strings.Contains(port, ":") {84			port = strings.Split(port, ":")[1]85		}86		// strip off the transport: 80/tcp -> 8087		if strings.Contains(port, "/") {88			port = strings.Split(port, "/")[0]89		}90		p, err := c.container.MappedPort(c.ctx, nat.Port(port))91		if err != nil {92			return fmt.Errorf("failed to find '%s' - %w", port, err)93		}94		fmt.Printf("mapped container port '%s' to host port '%s'\n", port, p.Port())95		c.Ports[port] = p.Port()96	}97	return nil98}99func (c *Container) Exec(cmds []string) (int, error) {100	return c.container.Exec(c.ctx, cmds)101}102func (c *Container) PrintLogs() {103	fmt.Println("--- Container Logs Start ---")104	for _, msg := range c.Logs.Msgs {105		fmt.Print(msg)106	}107	fmt.Println("--- Container Logs End ---")108}109func (c *Container) Terminate() error {110	err := c.container.StopLogProducer()111	if err != nil {112		fmt.Println(err)113	}114	err = c.container.Terminate(c.ctx)115	if err != nil {116		fmt.Printf("failed to terminate the container: %s", err)117	}118	c.PrintLogs()119	return nil120}...

Logs

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"80/tcp"},6		Cmd:          []string{"sh", "-c", "while true; do echo hello world; sleep 1; done"},7		WaitingFor:   wait.ForLog("hello world"),8	}9	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		log.Fatal(err)13	}14	defer c.Terminate(ctx)15	logs, err := c.Logs(ctx)16	if err != nil {17		log.Fatal(err)18	}19	fmt.Println(logs)20}

Logs

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        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    log.Printf("Redis container is ready to accept connections at %s:%s", ip, port.Port())23}

Logs

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		Cmd:          []string{"echo", "hello world"},6		ExposedPorts: []string{"80/tcp"},7		WaitingFor:   wait.ForLog("hello world"),8	}9	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		panic(err)13	}14	defer container.Terminate(ctx)15	logs, err := container.Logs(ctx)16	if err != nil {17		panic(err)18	}19	fmt.Println(logs)20	logsAsString, err := container.LogsToString(ctx)21	if err != nil {22		panic(err)23	}24	fmt.Println(logsAsString)25}

Logs

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		Cmd:          []string{"sh", "-c", "while true; do date; sleep 1; done"},6		ExposedPorts: []string{"80/tcp"},7		WaitingFor:   wait.ForLog("date"),8	}9	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		log.Fatal(err)13	}14	id, err := container.ContainerID(ctx)15	if err != nil {16		log.Fatal(err)17	}18	fmt.Println(id)19	host, err := container.Host(ctx)20	if err != nil {21		log.Fatal(err)22	}23	fmt.Println(host)24	mappedPort, err := container.MappedPort(ctx, "80")25	if err != nil {26		log.Fatal(err)27	}28	fmt.Println(mappedPort.Int())29	exitCode, err := container.Exec(ctx, []string{"echo", "hello world"})30	if err != nil {31		log.Fatal(err)32	}33	fmt.Println(exitCode)34	err = container.CopyFileToContainer(ctx, "/tmp/file.txt", "/file.txt")35	if err != nil {36		log.Fatal(err)37	}38	logs, err := container.Logs(ctx)39	if err != nil {40		log.Fatal(err)41	}42	defer logs.Close()43	logsFile, err := os.Create("/tmp/logs.txt")44	if err != nil {45		log.Fatal(err)46	}47	defer logsFile.Close()48	_, err = io.Copy(logsFile, logs)49	if err != nil {50		log.Fatal(err)51	}

Logs

Using AI Code Generation

1func TestLogs(t *testing.T) {2    ctx := context.Background()3    req := testcontainers.ContainerRequest{4        Cmd:          []string{"sh", "-c", "while true; do echo hello; sleep 1; done"},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    defer logs.Close()17    scanner := bufio.NewScanner(logs)18    for scanner.Scan() {19        t.Log(scanner.Text())20    }21}22func TestLogs2(t *testing.T) {23    ctx := context.Background()24    req := testcontainers.ContainerRequest{25        Cmd:          []string{"sh", "-c", "while true; do echo hello; sleep 1; done"},26    }27    resp, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{28    })29    if err != nil {30        panic(err)31    }32    defer resp.Terminate(ctx)33    logs, err := resp.Logs(ctx)34    if err != nil {35        panic(err)36    }37    defer logs.Close()38    scanner := bufio.NewScanner(logs)39    for scanner.Scan() {40        t.Log(scanner.Text())41    }42}43func TestLogs3(t *testing.T) {44    ctx := context.Background()45    req := testcontainers.ContainerRequest{46        Cmd:          []string{"sh", "-c", "while true; do echo hello; sleep 1; done"},47    }48    resp, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest

Logs

Using AI Code Generation

1import (2func main() {3	req := testcontainers.ContainerRequest{4		ExposedPorts: []string{"27017/tcp"},5		WaitingFor:   wait.ForListeningPort("27017/tcp"),6	}7	ctx := context.Background()8	mongo, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatal(err)12	}13	containerID, err := mongo.ContainerID(ctx)14	if err != nil {15		log.Fatal(err)16	}17	ip, err := mongo.Host(ctx)18	if err != nil {19		log.Fatal(err)20	}21	port, err := mongo.MappedPort(ctx, "27017/tcp")22	if err != nil {23		log.Fatal(err)24	}25	defer mongo.Terminate(ctx)26	fmt.Println("Container ID: ", containerID)27	fmt.Println("Container IP: ", ip)28	fmt.Println("Container Port: ", port.Int())29	logs, err := mongo.Logs(ctx)30	if err != nil {31		log.Fatal(err)32	}33	defer logs.Close()34	out, err := ioutil.ReadAll(logs)35	if err != nil {36		log.Fatal(err)37	}38	fmt.Println("Container Logs: ", string(out))39	logs, err = mongo.Logs(ctx, testcontainers.LogsOptions{40	})41	if err != nil {42		log.Fatal(err)43	}44	defer logs.Close()45	out, err = ioutil.ReadAll(logs)46	if err != nil {47		log.Fatal(err)48	}49	fmt.Println("Container Logs: ", string(out))

Logs

Using AI Code Generation

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

Logs

Using AI Code Generation

1func main() {2    ctx := context.Background()3    req := testcontainers.ContainerRequest{4        Cmd:          []string{"echo", "hello world"},5    }6    c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{7    })8    if err != nil {9        panic(err)10    }11    defer c.Terminate(ctx)12    logs, err := c.Logs(ctx)13    if err != nil {14        panic(err)15    }16    io.Copy(os.Stdout, logs)17}

Logs

Using AI Code Generation

1import (2func main() {3	containerRequest := testcontainers.ContainerRequest{4		ExposedPorts: []string{"80/tcp"},5		Cmd:          []string{"echo", "hello world"},6		WaitingFor:   wait.ForLog("hello world"),7	}8	ctx := context.Background()9	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		fmt.Println("Error while creating container: ", err)13	}14	defer container.Terminate(ctx)15	logs, err := container.Logs(ctx)16	if err != nil {17		fmt.Println("Error while getting logs: ", err)18	}19	fmt.Println("Logs: ", logs)20}21Your name to display (optional):

Logs

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"80/tcp"},6		Cmd:          []string{"echo", "hello world"},7		WaitingFor:   wait.ForLog("hello world"),8	}9	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		panic(err)13	}14	ip, err := container.Host(ctx)15	if err != nil {16		panic(err)17	}18	port, err := container.MappedPort(ctx, "80")19	if err != nil {20		panic(err)21	}22	fmt.Printf("Container IP: %s, Port: %s23", ip, port.Port())24	err = container.Terminate(ctx)25	if err != nil {26		panic(err)27	}28	logs, err := container.Logs(ctx)29	if err != nil {30		panic(err)31	}32	io.Copy(log.Writer(), logs)33	err = container.Remove(ctx)34	if err != nil {35		panic(err)36	}37}

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.