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

How to use StartLogProducer method of testcontainers Package

Best Testcontainers-go code snippet using testcontainers.StartLogProducer

test_utils.go

Source:test_utils.go

...78	})79	if err != nil {80		return nil, err81	}82	container.StartLogProducer(ctx)83	container.FollowOutput(&TestLogConsumer{})84	return container, err85}86// RunJMXServiceContainerSSL will start a container running test-server configured with SSL JMX.87func RunJMXServiceContainerSSL(ctx context.Context) (testcontainers.Container, error) {88	var hostnameOpt string89	if !isRunningInDockerContainer() {90		hostnameOpt = "-Djava.rmi.server.hostname=0.0.0.0"91	}92	req := testcontainers.ContainerRequest{93		Image: "test-server:latest",94		ExposedPorts: []string{95			fmt.Sprintf("%[1]s:%[1]s", TestServerPort),96			fmt.Sprintf("%[1]s:%[1]s", TestServerJMXPort),97		},98		Env: map[string]string{99			"JAVA_OPTS": "-Dcom.sun.management.jmxremote.port=" + TestServerJMXPort + " " +100				"-Dcom.sun.management.jmxremote.authenticate=true " +101				"-Dcom.sun.management.jmxremote.ssl=true " +102				"-Dcom.sun.management.jmxremote.ssl.need.client.auth=true " +103				"-Dcom.sun.management.jmxremote.registry.ssl=true " +104				"-Dcom.sun.management.jmxremote=true " +105				"-Dcom.sun.management.jmxremote.rmi.port=" + TestServerJMXPort + " " +106				"-Dcom.sun.management.jmxremote.local.only=false " +107				"-Djavax.net.ssl.keyStore=/keystore  " +108				"-Djavax.net.ssl.keyStorePassword=password " +109				"-Djavax.net.ssl.trustStore=/truststore " +110				"-Djavax.net.ssl.trustStorePassword=password " +111				hostnameOpt,112		},113		WaitingFor: wait.ForListeningPort(TestServerPort),114	}115	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{116		ContainerRequest: req,117		Started:          true,118	})119	if err != nil {120		return nil, err121	}122	container.StartLogProducer(ctx)123	container.FollowOutput(&TestLogConsumer{})124	return container, err125}126// GetContainerServiceURL will return the url to the test-server running inside the container.127func GetContainerServiceURL(ctx context.Context, container testcontainers.Container, port nat.Port, endpoint string) (string, error) {128	mappedPort, err := container.MappedPort(ctx, port)129	if err != nil {130		return "", err131	}132	var hostIP string133	if isRunningInDockerContainer() {134		if hostIP, err = container.ContainerIP(ctx); err != nil {135			return "", err136		}137	} else {138		if hostIP, err = container.Host(ctx); err != nil {139			return "", err140		}141	}142	return fmt.Sprintf("http://%s:%s%s", hostIP, mappedPort.Port(), endpoint), nil143}144// CleanMBeans will remove all new added MBeans from test-server.145func CleanMBeans(ctx context.Context, container testcontainers.Container) ([]byte, error) {146	url, err := GetContainerServiceURL(ctx, container, TestServerPort, TestServerCleanDataEndpoint)147	if err != nil {148		return nil, err149	}150	return DoHttpRequest(http.MethodPut, url, nil)151}152// AddMBeansBatch will add new MBeans to the test-server.153func AddMBeansBatch(ctx context.Context, container testcontainers.Container, body []map[string]interface{}) ([]byte, error) {154	return addMBeans(ctx, container, body, TestServerAddDataBatchEndpoint)155}156// AddMBeans will add new MBeans to the test-server.157func AddMBeans(ctx context.Context, container testcontainers.Container, body map[string]interface{}) ([]byte, error) {158	return addMBeans(ctx, container, body, TestServerAddDataEndpoint)159}160// AddMBeans will add new MBeans to the test-server.161func AddMCompositeDataBeans(ctx context.Context, container testcontainers.Container, body map[string]interface{}) ([]byte, error) {162	return addMBeans(ctx, container, body, TestServerAddCompositeDataEndpoint)163}164// addMBeans will add new MBeans to the test-server.165func addMBeans(ctx context.Context, container testcontainers.Container, body interface{}, endpointPath string) ([]byte, error) {166	url, err := GetContainerServiceURL(ctx, container, TestServerPort, endpointPath)167	if err != nil {168		return nil, err169	}170	json, err := json.Marshal(body)171	if err != nil {172		return nil, err173	}174	return DoHttpRequest(http.MethodPost, url, json)175}176// TestLogConsumer is used to print container logs to stdout.177type TestLogConsumer struct {178}179func (g *TestLogConsumer) Accept(l testcontainers.Log) {180	fmt.Fprintf(os.Stdout, "[CONTAINER LOG] %s %s\n", time.Now().Format("2006/01/02 15:04:05"), l.Content)181}182// RunJbossStandaloneJMXContainer will start a container running a jboss instace with JMX.183func RunJbossStandaloneJMXContainer(ctx context.Context) (testcontainers.Container, error) {184	req := testcontainers.ContainerRequest{185		Image: "test_jboss",186		ExposedPorts: []string{187			fmt.Sprintf("%[1]s:%[1]s", JbossJMXPort),188		},189		WaitingFor: wait.ForListeningPort(JbossJMXPort),190	}191	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{192		ContainerRequest: req,193		Started:          true,194	})195	if err != nil {196		return nil, err197	}198	container.StartLogProducer(ctx)199	container.FollowOutput(&TestLogConsumer{})200	return container, err201}202// CopyFileFromContainer will copy a file from a given docker container.203func CopyFileFromContainer(ctx context.Context, container testcontainers.Container, srcPath, dstPath string) error {204	reader, err := container.CopyFileFromContainer(ctx, srcPath)205	if err != nil {206		return err207	}208	defer reader.Close()209	b, err := ioutil.ReadAll(reader)210	if err != nil {211		return err212	}...

base.go

Source:base.go

...40		log.Panicf("Failed to retrive port %+v, with error: %v", containerRequest, err)41	}42	if printContainerLogs {43		logConsumer := TestLogConsumer{}44		err = container.StartLogProducer(ctx)45		if err != nil {46			log.Panicf("%s", err)47		}48		container.FollowOutput(&logConsumer)49	}50	return ContainerResult{51		Container: container,52		Host:      host,53		Port:      uint(port.Int()),54	}55}...

log.go

Source:log.go

...33	logger := LogCollector{34		LogChan:   make(chan testcontainers.Log, 10),35		container: c,36	}37	// reversed to avoid "race" since `StartLogProducer` starts a goroutine38	c.FollowOutput(&logger)39	err := c.StartLogProducer(ctx)40	return logger, err41}...

StartLogProducer

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"2181/tcp"},6		WaitingFor:   wait.ForListeningPort("2181/tcp"),7	}8	zookeeper, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatalf("Could not start container: %v", err)12	}13	defer zookeeper.Terminate(ctx)14	zookeeperIP, err := zookeeper.Host(ctx)15	if err != nil {16		log.Fatalf("Could not get container IP: %v", err)17	}18	zookeeperPort, err := zookeeper.MappedPort(ctx, "2181/tcp")19	if err != nil {20		log.Fatalf("Could not get container port: %v", err)21	}22	fmt.Printf("zookeeper is available at %s:%s", zookeeperIP, zookeeperPort.Port())23}24import (25func main() {26	ctx := context.Background()27	doSomething(ctx)28}29func doSomething(ctx context.Context) {30	fmt.Println("Doing something...")31	time.Sleep(2 * time.Second)32	fmt.Println("Done.")33}34import (35type MyStruct struct {36}37func main() {38	myStruct := &MyStruct{}39	myStruct.doSomething()40}41func (myStruct *MyStruct) doSomething() {42	ctx := context.Background()43	myStruct.doSomethingWithContext(ctx)44}45func (myStruct *MyStruct)

StartLogProducer

Using AI Code Generation

1import (2func main() {3    ctx := context.Background()4    req := testcontainers.ContainerRequest{5        ExposedPorts: []string{"9092/tcp"},6        WaitingFor:   wait.ForLog("started (kafka.server.KafkaServer)"),7    }8    kafka, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9    })10    if err != nil {11        log.Fatal(err)12    }13    defer kafka.Terminate(ctx)14    ip, err := kafka.Host(ctx)15    if err != nil {16        log.Fatal(err)17    }18    port, err := kafka.MappedPort(ctx, "9092")19    if err != nil {20        log.Fatal(err)21    }22    fmt.Printf("Kafka is listening on %s:%s23", ip, port.Port())24}

StartLogProducer

Using AI Code Generation

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

StartLogProducer

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"9200/tcp"},6		WaitingFor:   wait.ForLog("started"),7	}8	elastic, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		panic(err)12	}13	defer elastic.Terminate(ctx)14	ip, err := elastic.Host(ctx)15	if err != nil {16		panic(err)17	}18	port, err := elastic.MappedPort(ctx, "9200/tcp")19	if err != nil {20		panic(err)21	}22	fmt.Printf("Container IP: %s, Container Port: %s23", ip, port.Port())24	killSignal := make(chan os.Signal, 1)25	signal.Notify(killSignal, syscall.SIGINT, syscall.SIGTERM)26	elastic.Terminate(ctx)27}28import (29func main() {30	ctx := context.Background()31	req := testcontainers.ContainerRequest{32		ExposedPorts: []string{"9200/tcp"},

StartLogProducer

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		Cmd:          []string{"sh", "-c", "while true; do echo 'hello'; sleep 1; done"},6		ExposedPorts: []string{"80/tcp"},7		WaitingFor:   wait.ForLog("hello").WithStartupTimeout(10 * time.Second),8	}9	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		log.Fatal(err)13	}14	port, err := container.MappedPort(ctx, "80/tcp")15	if err != nil {16		log.Fatal(err)17	}18	fmt.Println(port.Int())19	err = container.Terminate(ctx)20	if err != nil {21		log.Fatal(err)22	}23}24import (25func main() {26	ctx := context.Background()27	req := testcontainers.ContainerRequest{28		Cmd:          []string{"sh", "-c", "while true; do echo 'hello'; sleep 1; done"},29		ExposedPorts: []string{"80/tcp"},30		WaitingFor:   wait.ForLog("hello").WithStartupTimeout(10 * time.Second),31	}

StartLogProducer

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		Cmd:          []string{"sh", "-c", "while true; do echo \"I'm still alive!\"; sleep 1; done"},6		ExposedPorts: []string{"80/tcp"},7		WaitingFor:   wait.ForLog("I'm still alive!"),8	}9	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		log.Fatal(err)13	}14	defer container.Terminate(ctx)15}16import (17func main() {18	ctx := context.Background()19	req := testcontainers.ContainerRequest{20		Cmd:          []string{"sh", "-c", "while true; do echo \"I'm still alive!\"; sleep 1; done"},21		ExposedPorts: []string{"80/tcp"},22		WaitingFor:   wait.ForLog("I'm still alive!"),23	}24	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{25	})26	if err != nil {27		log.Fatal(err)28	}29	defer container.Terminate(ctx)30}31import (32func main() {33	ctx := context.Background()34	req := testcontainers.ContainerRequest{35		Cmd:          []string{"sh", "-c", "while true; do echo \"I'm still alive!\"; sleep 1; done"},

StartLogProducer

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	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		log.Fatalf("Could not start container: %v", err)13	}14	defer c.Terminate(ctx)15	ip, err := c.Host(ctx)16	if err != nil {17		log.Fatalf("Could not get container IP: %v", err)18	}19	port, err := c.MappedPort(ctx, "80")20	if err != nil {21		log.Fatalf("Could not get mapped port: %v", err)22	}23	fmt.Printf("Container %s is listening on port %s", ip, port.Port())24}25import (26func main() {27	ctx := context.Background()28	req := testcontainers.ContainerRequest{29		Cmd:          []string{"sh", "-c", "while true; do date; sleep 1; done"},30		ExposedPorts: []string{"80/tcp"},31		WaitingFor:   wait.ForLog("date"),32	}33	c, err := testcontainers.GenericContainer(ctx, test

StartLogProducer

Using AI Code Generation

1import (2func main() {3	req := testcontainers.ContainerRequest{4		Cmd:          []string{"sh", "-c", "while true; do echo hello; sleep 1; done"},5		ExposedPorts: []string{"80/tcp"},6		WaitingFor:   testcontainers.WaitingForLog("hello"),7	}8	ctx := context.Background()9	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		log.Fatalf("Could not start container: %s", err)13	}14	defer c.Terminate(ctx)15	id, err := c.ContainerID(ctx)16	if err != nil {17		log.Fatalf("Could not get container ID: %s", err)18	}19	logs, err := c.StartLogProducer(ctx)20	if err != nil {21		log.Fatalf("Could not get container logs: %s", err)22	}23	fmt.Println(logs)24}

StartLogProducer

Using AI Code Generation

1import (2func main() {3	log.Println("Starting the application...")4	ctx := context.Background()5	req := testcontainers.ContainerRequest{6		ExposedPorts: []string{"9200/tcp", "9300/tcp"},7		WaitingFor:   wait.ForListeningPort("9300/tcp"),8	}9	elasticContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		log.Fatal(err)13	}14	defer elasticContainer.Terminate(ctx)15	elasticHost, err := elasticContainer.Host(ctx)16	if err != nil {17		log.Fatal(err)18	}19	elasticPort, err := elasticContainer.MappedPort(ctx, "9200")20	if err != nil {21		log.Fatal(err)22	}23	elasticPort2, err := elasticContainer.MappedPort(ctx, "9300")24	if err != nil {25		log.Fatal(err)26	}27	log.Println(elasticHost)28	log.Println(elasticPort.Int())29	log.Println(elasticPort2.Int())30	elasticContainer.FollowOutput(ctx, func(line []byte) {31		fmt.Println(string(line))32	})33	time.Sleep(10 * time.Second)34}

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.