daemon

Documentation

Index

• func WaitInspectWithArgs(dockerBinary, name, expr, expected string, timeout time.Duration, ...) error
• type Daemon
  • func New(t testing.TB, dockerBinary string, dockerdBinary string, ops ...daemon.Option) *Daemon
  • func (d *Daemon) CheckActiveContainerCount(ctx context.Context) func(t *testing.T) (interface{}, string)
  • func (d *Daemon) CheckControlAvailable(ctx context.Context) func(t *testing.T) (interface{}, string)
  • func (d *Daemon) CheckLeader(ctx context.Context) func(t *testing.T) (interface{}, string)
  • func (d *Daemon) CheckLocalNodeState(ctx context.Context) func(t *testing.T) (interface{}, string)
  • func (d *Daemon) CheckNodeReadyCount(ctx context.Context) func(t *testing.T) (interface{}, string)
  • func (d *Daemon) CheckPluginImage(ctx context.Context, plugin string) func(c *testing.T) (interface{}, string)
  • func (d *Daemon) CheckPluginRunning(ctx context.Context, plugin string) func(c *testing.T) (interface{}, string)
  • func (d *Daemon) CheckRunningTaskImages(ctx context.Context) func(t *testing.T) (interface{}, string)
  • func (d *Daemon) CheckRunningTaskNetworks(ctx context.Context) func(t *testing.T) (interface{}, string)
  • func (d *Daemon) CheckServiceRunningTasks(ctx context.Context, service string) func(*testing.T) (interface{}, string)
  • func (d *Daemon) CheckServiceTasks(ctx context.Context, service string) func(*testing.T) (interface{}, string)
  • func (d *Daemon) CheckServiceTasksInState(ctx context.Context, service string, state swarm.TaskState, message string) func(*testing.T) (interface{}, string)
  • func (d *Daemon) CheckServiceTasksInStateWithError(ctx context.Context, service string, state swarm.TaskState, ...) func(*testing.T) (interface{}, string)
  • func (d *Daemon) CheckServiceUpdateState(ctx context.Context, service string) func(*testing.T) (interface{}, string)
  • func (d *Daemon) Cmd(args ...string) (string, error)
  • func (d *Daemon) CmdRetryOutOfSequence(args ...string) (string, error)
  • func (d *Daemon) Command(args ...string) icmd.Cmd
  • func (d *Daemon) GetIDByName(name string) (string, error)
  • func (d *Daemon) InspectField(name, filter string) (string, error)
  • func (d *Daemon) PrependHostArg(args []string) []string
  • func (d *Daemon) WaitRun(contID string) error

Functions

func WaitInspectWithArgs

func WaitInspectWithArgs(dockerBinary, name, expr, expected string, timeout time.Duration, arg ...string) error

WaitInspectWithArgs waits for the specified expression to be equals to the specified expected string in the given time. Deprecated: use cli.WaitCmd instead

Types

type Daemon

type Daemon struct {
	*daemon.Daemon
	// contains filtered or unexported fields
}

Daemon represents a Docker daemon for the testing framework.

func New

func New(t testing.TB, dockerBinary string, dockerdBinary string, ops ...daemon.Option) *Daemon

New returns a Daemon instance to be used for testing. This will create a directory such as d123456789 in the folder specified by $DOCKER_INTEGRATION_DAEMON_DEST or $DEST. The daemon will not automatically start.

func (*Daemon) CheckActiveContainerCount

func (d *Daemon) CheckActiveContainerCount(ctx context.Context) func(t *testing.T) (interface{}, string)

CheckActiveContainerCount returns the number of active containers FIXME(vdemeester) should re-use ActivateContainers in some way

func (*Daemon) CheckControlAvailable

func (d *Daemon) CheckControlAvailable(ctx context.Context) func(t *testing.T) (interface{}, string)

CheckControlAvailable returns the current swarm control available

func (*Daemon) CheckLeader

func (d *Daemon) CheckLeader(ctx context.Context) func(t *testing.T) (interface{}, string)

CheckLeader returns whether there is a leader on the swarm or not

func (*Daemon) CheckLocalNodeState

func (d *Daemon) CheckLocalNodeState(ctx context.Context) func(t *testing.T) (interface{}, string)

CheckLocalNodeState returns the current swarm node state

func (*Daemon) CheckNodeReadyCount

func (d *Daemon) CheckNodeReadyCount(ctx context.Context) func(t *testing.T) (interface{}, string)

CheckNodeReadyCount returns the number of ready node on the swarm

func (*Daemon) CheckPluginImage

func (d *Daemon) CheckPluginImage(ctx context.Context, plugin string) func(c *testing.T) (interface{}, string)

CheckPluginImage returns the runtime state of the plugin

func (*Daemon) CheckPluginRunning

func (d *Daemon) CheckPluginRunning(ctx context.Context, plugin string) func(c *testing.T) (interface{}, string)

CheckPluginRunning returns the runtime state of the plugin

func (*Daemon) CheckRunningTaskImages

func (d *Daemon) CheckRunningTaskImages(ctx context.Context) func(t *testing.T) (interface{}, string)

CheckRunningTaskImages returns the times each image is running as a task.

func (*Daemon) CheckRunningTaskNetworks

func (d *Daemon) CheckRunningTaskNetworks(ctx context.Context) func(t *testing.T) (interface{}, string)

CheckRunningTaskNetworks returns the number of times each network is referenced from a task.

func (*Daemon) CheckServiceRunningTasks

func (d *Daemon) CheckServiceRunningTasks(ctx context.Context, service string) func(*testing.T) (interface{}, string)

CheckServiceRunningTasks returns the number of running tasks for the specified service

func (*Daemon) CheckServiceTasks

func (d *Daemon) CheckServiceTasks(ctx context.Context, service string) func(*testing.T) (interface{}, string)

CheckServiceTasks returns the number of tasks for the specified service

func (*Daemon) CheckServiceTasksInState

func (d *Daemon) CheckServiceTasksInState(ctx context.Context, service string, state swarm.TaskState, message string) func(*testing.T) (interface{}, string)

CheckServiceTasksInState returns the number of tasks with a matching state, and optional message substring.

func (*Daemon) CheckServiceTasksInStateWithError

func (d *Daemon) CheckServiceTasksInStateWithError(ctx context.Context, service string, state swarm.TaskState, errorMessage string) func(*testing.T) (interface{}, string)

CheckServiceTasksInStateWithError returns the number of tasks with a matching state, and optional message substring.

func (*Daemon) CheckServiceUpdateState

func (d *Daemon) CheckServiceUpdateState(ctx context.Context, service string) func(*testing.T) (interface{}, string)

CheckServiceUpdateState returns the current update state for the specified service

func (*Daemon) Cmd

func (d *Daemon) Cmd(args ...string) (string, error)

Cmd executes a docker CLI command against this daemon. Example: d.Cmd("version") will run docker -H unix://path/to/unix.sock version

func (*Daemon) CmdRetryOutOfSequence

func (d *Daemon) CmdRetryOutOfSequence(args ...string) (string, error)

CmdRetryOutOfSequence tries the specified command against the current daemon up to 10 times, retrying if it encounters an "update out of sequence" error.

func (*Daemon) Command

func (d *Daemon) Command(args ...string) icmd.Cmd

Command creates a docker CLI command against this daemon, to be executed later. Example: d.Command("version") creates a command to run "docker -H unix://path/to/unix.sock version"

func (*Daemon) GetIDByName

func (d *Daemon) GetIDByName(name string) (string, error)

GetIDByName returns the ID of an object (container, volume, …) given its name

func (*Daemon) InspectField

func (d *Daemon) InspectField(name, filter string) (string, error)

InspectField returns the field filter by 'filter'

func (*Daemon) PrependHostArg

func (d *Daemon) PrependHostArg(args []string) []string

PrependHostArg prepend the specified arguments by the daemon host flags

func (*Daemon) WaitRun

func (d *Daemon) WaitRun(contID string) error

WaitRun waits for a container to be running for 10s