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

How to use ReuseOrCreateContainer method of testcontainers Package

Best Testcontainers-go code snippet using testcontainers.ReuseOrCreateContainer

docker.go

Source:docker.go

...976		return &containers[0], nil977	}978	return nil, nil979}980func (p *DockerProvider) ReuseOrCreateContainer(ctx context.Context, req ContainerRequest) (Container, error) {981	c, err := p.findContainerByName(ctx, req.Name)982	if err != nil {983		return nil, err984	}985	if c == nil {986		return p.CreateContainer(ctx, req)987	}988	sessionID := sessionID()989	var termSignal chan bool990	if !req.SkipReaper {991		r, err := NewReaper(context.WithValue(ctx, dockerHostContextKey, p.host), sessionID.String(), p, req.ReaperImage)992		if err != nil {993			return nil, fmt.Errorf("%w: creating reaper failed", err)994		}...

container.go

Source:container.go

...21}22// ContainerProvider allows the creation of containers on an arbitrary system23type ContainerProvider interface {24	CreateContainer(context.Context, ContainerRequest) (Container, error)        // create a container without starting it25	ReuseOrCreateContainer(context.Context, ContainerRequest) (Container, error) // reuses a container if it exists or creates a container without starting26	RunContainer(context.Context, ContainerRequest) (Container, error)           // create a container and start it27	Health(context.Context) error28	Config() TestContainersConfig29}30// Container allows getting info about and controlling a single container instance31type Container interface {32	GetContainerID() string                                         // get the container id from the provider33	Endpoint(context.Context, string) (string, error)               // get proto://ip:port string for the first exposed port34	PortEndpoint(context.Context, nat.Port, string) (string, error) // get proto://ip:port string for the given exposed port35	Host(context.Context) (string, error)                           // get host where the container port is exposed36	MappedPort(context.Context, nat.Port) (nat.Port, error)         // get externally mapped port for a container port37	Ports(context.Context) (nat.PortMap, error)                     // get all exposed ports38	SessionID() string                                              // get session id39	IsRunning() bool...

generic.go

Source:generic.go

...52		// we must protect the reusability of the container in the case it's invoked53		// in a parallel execution, via ParallelContainers or t.Parallel()54		reuseContainerMx.Lock()55		defer reuseContainerMx.Unlock()56		c, err = provider.ReuseOrCreateContainer(ctx, req.ContainerRequest)57	} else {58		c, err = provider.CreateContainer(ctx, req.ContainerRequest)59	}60	if err != nil {61		return nil, fmt.Errorf("%w: failed to create container", err)62	}63	if req.Started && !c.IsRunning() {64		if err := c.Start(ctx); err != nil {65			return c, fmt.Errorf("%w: failed to start container", err)66		}67	}68	return c, nil69}70// GenericProvider represents an abstraction for container and network providers...

ReuseOrCreateContainer

Using AI Code Generation

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

ReuseOrCreateContainer

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"80/tcp"},6		WaitingFor:   wait.ForListeningPort("80/tcp"),7	}8	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatalf("Could not create container: %v", err)12	}13	defer c.Terminate(ctx)14	ip, err := c.Host(ctx)15	if err != nil {16		log.Fatalf("Could not get container IP: %v", err)17	}18	port, err := c.MappedPort(ctx, "80/tcp")19	if err != nil {20		log.Fatalf("Could not get mapped port: %v", err)21	}22	fmt.Println("Container IP is", ip)23	fmt.Println("Container port is", port.Int())24	time.Sleep(5 * time.Minute)25}

ReuseOrCreateContainer

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	redisContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatalf("Could not start container: %s", err)12	}13	defer redisContainer.Terminate(ctx)14	redisHost, err := redisContainer.Host(ctx)15	if err != nil {16		log.Fatalf("Could not get host: %s", err)17	}18	redisPort, err := redisContainer.MappedPort(ctx, "6379/tcp")19	if err != nil {20		log.Fatalf("Could not get port: %s", err)21	}22	fmt.Printf("Redis host: %s, port: %s23", redisHost, redisPort.Port())24	time.Sleep(10 * time.Second)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	redisContainer, err := testcontainers.ReuseOrCreateContainer(ctx, testcontainers.GenericContainerRequest{34	})35	if err != nil {36		log.Fatalf("Could not start container: %s", err)37	}38	defer redisContainer.Terminate(ctx)39	redisHost, err := redisContainer.Host(ctx)40	if err != nil {41		log.Fatalf("Could not get host: %s", err)42	}43	redisPort, err := redisContainer.MappedPort(ctx, "6379/tcp")44	if err != nil {45		log.Fatalf("Could not get port

ReuseOrCreateContainer

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	redisContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{9	})10	if err != nil {11		log.Fatal(err)12	}13	defer redisContainer.Terminate(ctx)14	redisHost, err := redisContainer.Host(ctx)15	if err != nil {16		log.Fatal(err)17	}18	redisPort, err := redisContainer.MappedPort(ctx, "6379")19	if err != nil {20		log.Fatal(err)21	}22	fmt.Println(redisHost, redisPort.Int())23	time.Sleep(5 * time.Second)24}

ReuseOrCreateContainer

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		Env:          map[string]string{"POSTGRES_PASSWORD": "password"},8	}9	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{10	})11	if err != nil {12		log.Fatal(err)13	}14	host, err := container.Host(ctx)15	if err != nil {16		log.Fatal(err)17	}18	port, err := container.MappedPort(ctx, "5432/tcp")19	if err != nil {20		log.Fatal(err)21	}22	fmt.Printf("host: %s, port: %s23", host, port.Port())24	time.Sleep(5 * time.Minute)25}

ReuseOrCreateContainer

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"80/tcp"},6		WaitingFor:   wait.ForLog("Ready to accept connections"),7	}8	container, err := testcontainers.ReuseOrCreateContainer(ctx, req, testcontainers.ReuseOrCreateContainerOptions{9	})10	if err != nil {11		log.Fatal(err)12	}13	err = container.Start(ctx)14	if err != nil {15		log.Fatal(err)16	}17	containerID, err := container.ContainerID(ctx)18	if err != nil {19		log.Fatal(err)20	}21	fmt.Println("Container ID: ", containerID)22	ip, err := container.Host(ctx)23	if err != nil {24		log.Fatal(err)25	}26	fmt.Println("Container IP: ", ip)27	mappedPort, err := container.MappedPort(ctx, "80")28	if err != nil {29		log.Fatal(err)30	}31	fmt.Println("Container mapped port: ", mappedPort.Int())32	status, err := container.ContainerStatus(ctx)33	if err != nil {34		log.Fatal(err)35	}36	fmt.Println("Container status: ",

ReuseOrCreateContainer

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.Fatal(err)12	}13	defer redis.Terminate(ctx)14	port, err := redis.MappedPort(ctx, "6379")15	if err != nil {16		log.Fatal(err)17	}18	fmt.Println(port.Int())19}20import (21func main() {22	ctx := context.Background()23	req := testcontainers.ContainerRequest{24		ExposedPorts: []string{"6379/tcp"},25		WaitingFor:   wait.ForListeningPort("6379/tcp"),26	}27	redis, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{28	})29	if err != nil {30		log.Fatal(err)31	}32	defer redis.Terminate(ctx)33	port, err := redis.MappedPort(ctx, "6379")34	if err != nil {35		log.Fatal(err)36	}37	fmt.Println(port.Int())38}39import (

ReuseOrCreateContainer

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	req := testcontainers.ContainerRequest{5		ExposedPorts: []string{"80/tcp"},6		WaitingFor:   wait.ForLog("listening on port 80"),7	}8	c, reused, err := testcontainers.ReuseOrCreateContainer(ctx, req, testcontainers.ReuseContainerOption{Reuse: true})9	if err != nil {10		log.Fatal(err)11	}12	if reused {13		fmt.Println("container was reused")14	}15	if !reused {16		fmt.Println("container was not reused")17	}18	ip, err := c.Host(ctx)19	if err != nil {20		log.Fatal(err)21	}22	port, err := c.MappedPort(ctx, "80")23	if err != nil {24		log.Fatal(err)25	}26	id, err := c.ContainerID(ctx)27	if err != nil {28		log.Fatal(err)29	}30	fmt.Printf("container's ip address: %s31	fmt.Printf("container's port: %s32", port.Port())33	fmt.Printf("container's id: %s34	time.Sleep(10 * time.Second)35	err = c.Terminate(ctx)36	if err != nil {37		log.Fatal(err)38	}39}

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.