Skip to content

HostPort Wait strategy

The host-port wait strategy will check if the container is listening to a specific port and allows to set the following conditions:

  • a port exposed by the container. The port and protocol to be used, which is represented by a string containing the port number and protocol in the format "80/tcp".
  • alternatively, wait for the lowest exposed port in the container.
  • the startup timeout to be used, default is 60 seconds.
  • the poll interval to be used, default is 100 milliseconds.
  • skip the internal check.

Variations on the HostPort wait strategy are supported, including:

Listening port in the container

req := ContainerRequest{
    Image:        "docker.io/nginx:alpine",
    ExposedPorts: []string{"80/tcp"},
    WaitingFor:   wait.ForListeningPort("80/tcp"),
}

Lowest exposed port in the container

The wait strategy will use the lowest exposed port from the container configuration.

req := ContainerRequest{
    Image:        "docker.io/nginx:alpine",
    WaitingFor:   wait.ForExposedPort(),
}

Said that, it could be the case that the container request included ports to be exposed. Therefore using wait.ForExposedPort will wait for the lowest exposed port in the request, because the container configuration retrieved from Docker will already include them.

req := ContainerRequest{
    Image:        "docker.io/nginx:alpine",
    ExposedPorts: []string{"80/tcp", "9080/tcp"},
    WaitingFor:   wait.ForExposedPort(),
}

Skipping the internal check

Testcontainers for Go checks if the container is listening to the port internally before returning the control to the caller. For that it uses a shell command to check the port status:

command := `(
                cat /proc/net/tcp* | awk '{print $2}' | grep -i :%04x ||
                nc -vz -w 1 localhost %d ||
                /bin/sh -c '</dev/tcp/localhost/%d'
            )
            `
return "true && " + fmt.Sprintf(command, internalPort, internalPort, internalPort)

But there are cases where this internal check is not needed, for example when a shell is not available in the container or when the container doesn't bind the port internally until additional conditions are met. In this case, the wait.ForExposedPort.SkipInternalCheck can be used to skip the internal check.

req := ContainerRequest{
    Image:        "docker.io/nginx:alpine",
    ExposedPorts: []string{"80/tcp", "9080/tcp"},
    WaitingFor:   wait.ForExposedPort().SkipInternalCheck(),
}