Function TestEventsExecDie

integration/system/event_test.go:21–57

(t *testing.T)

)

func TestEventsExecDie(t *testing.T) {
	skip.If(t, testEnv.DaemonInfo.OSType == "windows", "FIXME. Suspect may need to wait until container is running before exec")
	ctx := setupTest(t)
	apiClient := testEnv.APIClient()

	cID := container.Run(ctx, t, apiClient)

	res, err := apiClient.ExecCreate(ctx, cID, client.ExecCreateOptions{
		Cmd: []string{"echo", "hello"},
	})
	assert.NilError(t, err)

	result := apiClient.Events(ctx, client.EventsListOptions{
		Filters: make(client.Filters).Add("container", cID).Add("event", string(events.ActionExecDie)),
	})
	msg := result.Messages
	errs := result.Err

	_, err = apiClient.ExecStart(ctx, res.ID, client.ExecStartOptions{
		Detach: true,
		TTY:    false,
	})
	assert.NilError(t, err)

	select {
	case m := <-msg:
		assert.Equal(t, m.Type, events.ContainerEventType)
		assert.Equal(t, m.Actor.ID, cID)
		assert.Equal(t, m.Action, events.ActionExecDie)
		assert.Equal(t, m.Actor.Attributes["execID"], res.ID)
		assert.Equal(t, m.Actor.Attributes["exitCode"], "0")
	case err = <-errs:
		assert.NilError(t, err)
	case <-time.After(time.Second * 3):
		t.Fatal("timeout hit")
	}
}

// TestEventsNonBlocking verifies that the API responds immediately (not blocking),
// if there are no events.