Function assertContainerExitCode

integration/container/restart_test.go:299–310

(t *testing.T, wait client.ContainerWaitResult, expected int64, timeout time.Duration)

}

func assertContainerExitCode(t *testing.T, wait client.ContainerWaitResult, expected int64, timeout time.Duration) {
	t.Helper()

	select {
	case err := <-wait.Error:
		assert.NilError(t, err)
	case res := <-wait.Result:
		assert.Check(t, is.Equal(res.StatusCode, expected))
	case <-time.After(timeout):
		t.Fatal("timeout waiting for container exit")
	}
}

func TestContainerRestartPolicyOnFailure(t *testing.T) {
	ctx := setupTest(t)