Function TestContainerWait

client/container_wait_test.go:54–76

(t *testing.T)

}

func TestContainerWait(t *testing.T) {
	ctx, cancel := context.WithCancel(t.Context())
	defer cancel()

	const expectedURL = "/containers/container_id/wait"
	client, err := New(WithMockClient(func(req *http.Request) (*http.Response, error) {
		if err := assertRequest(req, http.MethodPost, expectedURL); err != nil {
			return nil, err
		}
		return mockJSONResponse(http.StatusOK, nil, container.WaitResponse{
			StatusCode: 15,
		})(req)
	}))
	assert.NilError(t, err)

	wait := client.ContainerWait(ctx, "container_id", ContainerWaitOptions{})
	select {
	case err := <-wait.Error:
		assert.NilError(t, err)
	case result := <-wait.Result:
		assert.Check(t, is.Equal(result.StatusCode, int64(15)))
	}
}

func TestContainerWaitProxyInterrupt(t *testing.T) {
	ctx, cancel := context.WithCancel(t.Context())