[Live Now] Join the 1-day Testing & QA Summit featuring 15+ Expert Speakers.Join for FREE! 
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.
LambdaTest Learning Hubs:
- JUnit Tutorial
- TestNG Tutorial
- Webdriver Tutorial
- WebDriverIO Tutorial
- Protractor Tutorial
- Selenium 4 Tutorial
- Jenkins Tutorial
- NUnit Tutorial
- Jest Tutorial
- Playwright Tutorial
- Cypress Tutorial
- PyTest Tutorial
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.
Most used method in
- WithStackFiles
- NewDockerCompose
- NewDockerComposeWith
- NewLocalDockerCompose
- applyToStackUp
- applyToStackDown
- RunServices
- applyToComposeStack
- String
- ServiceContainer
- Services
- Down
- Up
- WaitForService
- WithEnv
- WithOsEnv
- lookupContainer
- compileProject
- makeClient
- TestDockerComposeAPI
- TestDockerComposeAPIStrategyForInvalidService
- TestDockerComposeAPIWithWaitLogStrategy
- TestDockerComposeAPIWithRunServices
- TestDockerComposeAPIWithWaitForService
- TestDockerComposeAPIWithWaitHTTPStrategy
- TestDockerComposeAPIWithContainerName
- TestDockerComposeAPIWithWaitStrategy_NoExposedPorts
- TestDockerComposeAPIWithMultipleWaitStrategies
- TestDockerComposeAPIWithFailedStrategy
- TestDockerComposeAPIComplex
- TestDockerComposeAPIWithEnvironment
- TestDockerComposeAPIWithMultipleComposeFiles
- TestDockerComposeAPIWithVolume
- TestDockerComposeAPIWithBuild
- TestDockerComposeApiWithWaitForShortLifespanService
- testNameHash
- Format
- ApplyToLocalCompose
- getDockerComposeEnvironment
- containerNameFromServiceName
- applyStrategyToRunningContainer
- Invoke
- WithCommand
- WithExposedService
- determineVersion
- Validate
- execute
- executeCompose
- newCapturingPassThroughWriter
- Write
- Bytes
- which
- ExampleNewLocalDockerCompose
- ExampleLocalDockerCompose
- ExampleLocalDockerCompose_Down
- ExampleLocalDockerCompose_Invoke
- ExampleLocalDockerCompose_WithCommand
- ExampleLocalDockerCompose_WithEnv
- TestLocalDockerCompose
- TestDockerComposeStrategyForInvalidService
- TestDockerComposeWithWaitLogStrategy
- TestDockerComposeWithWaitForService
- TestDockerComposeWithWaitForShortLifespanService
- TestDockerComposeWithWaitHTTPStrategy
- TestDockerComposeWithContainerName
- TestDockerComposeWithWaitStrategy_NoExposedPorts
- TestDockerComposeWithMultipleWaitStrategies
- TestDockerComposeWithFailedStrategy
- TestLocalDockerComposeComplex
- TestLocalDockerComposeWithEnvironment
- TestLocalDockerComposeWithMultipleComposeFiles
- TestLocalDockerComposeWithVolume
- assertVolumeDoesNotExist
- assertContainerEnvironmentVariables
- checkIfError
- ApplyGenericTo
- GetProvider
- GetContext
- GetBuildArgs
- GetDockerfile
- ShouldBuildImage
- ShouldPrintBuildLog
- validateContextAndImage
- validateContextOrImageIsSpecified
- validateMounts
- Test_ContainerValidation
- Test_GetDockerfile
- Test_BuildImageWithContexts
- Test_GetLogsFromFailedContainer
- TestShouldStartContainersInParallel
- createTestContainer
- TestBindMount
- TestVolumeMount
- GetContainerID
- IsRunning
- Endpoint
- PortEndpoint
- Host
- MappedPort
- Ports
- sessionID
- Start
- Stop
- Terminate
- inspectRawContainer
- inspectContainer
- Logs
- FollowOutput
- Name
- State
- Networks
- ContainerIP
- ContainerIPs
- NetworkAliases
- Exec
- Read
- Close
- CopyFileFromContainer
- CopyDirToContainer
- CopyFileToContainer
- CopyToContainer
- StartLogProducer
- StopLogProducer
- Remove
- ApplyDockerTo
- Generic2DockerOptions
- WithDefaultBridgeNetwork
- NewDockerClient
- NewDockerProvider
- logDockerServerInfo
- configureTC
- BuildImage
- CreateContainer
- findContainerByName
- ReuseOrCreateContainer
- attemptToPullImage
- Health
- RunContainer
- Config
- daemonHost
- CreateNetwork
- GetNetwork
- GetGatewayIP
- printReaperBanner
- inAContainer
- getDefaultGatewayIP
- getDefaultNetwork
- Source
- Type
- GetBindOptions
- GetVolumeOptions
- GetTmpfsOptions
- mapToDockerMounts
- init
- TestContainerAttachedToNewNetwork
- TestContainerWithHostNetworkOptions
- TestContainerWithHostNetworkOptions_UseExposePortsFromImageConfigs
- TestContainerWithNetworkModeAndNetworkTogether
- TestContainerWithHostNetworkOptionsAndWaitStrategy
- TestContainerWithHostNetworkAndEndpoint
- TestContainerWithHostNetworkAndPortEndpoint
- TestContainerReturnItsContainerID
- TestContainerStartsWithoutTheReaper
- TestContainerStartsWithTheReaper
- TestContainerTerminationResetsState
- TestContainerStopWithReaper
- TestContainerTerminationWithReaper
- TestContainerTerminationWithoutReaper
- TestContainerTerminationRemovesDockerImage
- TestTwoContainersExposingTheSamePort
- TestContainerCreation
- TestContainerIPs
- TestContainerCreationWithName
- TestContainerCreationAndWaitForListeningPortLongEnough
- TestContainerCreationTimesOut
- TestContainerRespondsWithHttp200ForIndex
- TestContainerCreationTimesOutWithHttp
- TestContainerCreationWaitsForLogContextTimeout
- TestContainerCreationWaitsForLog
- Test_BuildContainerFromDockerfile
- Test_BuildContainerFromDockerfileWithBuildArgs
- Test_BuildContainerFromDockerfileWithBuildLog
- TestContainerCreationWaitsForLogAndPortContextTimeout
- TestContainerCreationWaitingForHostPort
- TestContainerCreationWaitingForHostPortWithoutBashThrowsAnError
- TestContainerCreationWaitsForLogAndPort
- TestCMD
- TestEntrypoint
- TestReadTCPropsFile
- ExampleDockerProvider_CreateContainer
- ExampleContainer_Host
- ExampleContainer_Start
- ExampleContainer_Stop
- ExampleContainer_MappedPort
- TestContainerCreationWithBindAndVolume
- TestContainerWithTmpFs
- TestContainerNonExistentImage
- TestContainerCustomPlatformImage
- TestContainerWithCustomHostname
- readHostname
- TestDockerContainerCopyFileToContainer
- TestDockerContainerCopyDirToContainer
- TestDockerCreateContainerWithFiles
- TestDockerCreateContainerWithDirs
- TestDockerContainerCopyToContainer
- TestDockerContainerCopyFileFromContainer
- TestDockerContainerCopyEmptyFileFromContainer
- TestDockerContainerResources
- TestContainerWithReaperNetwork
- TestContainerCapAdd
- TestContainerRunningCheckingStatusCode
- TestContainerWithUserID
- TestContainerWithNoUserID
- TestGetGatewayIP
- TestProviderHasConfig
- TestNetworkModeWithContainerReference
- assertExtractedFiles
- terminateContainerOnEnd
- randomString
- TestDockerProviderFindContainerByName
- isDir
- tarDir
- tarFile
- Test_IsDir
- Test_TarDir
- Test_TarFile
- untar
- GenericNetwork
- GenericContainer
- TestGenericReusableContainer
- Accept
- Test_LogConsumerGetsCalled
- Test_ShouldRecognizeLogTypes
- TestContainerLogWithErrClosed
- TestContainerLogsShouldBeWithoutStreamHeader
- TestLogger
- WithLogger
- Printf
- Target
- BindMount
- VolumeMount
- Mounts
- TestContainerMounts_PrepareMounts
- ExampleNetworkProvider_CreateNetwork
- Test_NetworkWithIPAM
- Test_MultipleContainersInTheNewNetwork
- Error
- parallelContainersRunner
- ParallelContainers
- TestParallelContainers
- TestParallelContainersWithReuse
- NewReaper
- Connect
- Labels
- extractDockerHost
- reaperImage
- createContainerRequest
- Test_NewReaper
- Test_ExtractDockerHost
- SkipIfProviderIsNotHealthy
- ExampleSkipIfProviderIsNotHealthy
Try LambdaTest Now !!
Get 100 minutes of automation test minutes FREE!!
Was this article helpful?
