package testutils

import "github.com/moby/swarmkit/v2/manager/orchestrator/testutils"

Index ¶

• func EnsureRuns(closure func()) <-chan struct{}
• func Expect(t *testing.T, watch chan events.Event, specifiers ...api.Event)
• func FatalStack(t *testing.T, msg string, args ...interface{})
• func WatchShutdownTask(t *testing.T, watch chan events.Event) *api.Task
• func WatchTaskCreate(t *testing.T, watch chan events.Event) *api.Task
• func WatchTaskDelete(t *testing.T, watch chan events.Event) *api.Task
• func WatchTaskUpdate(t *testing.T, watch chan events.Event) *api.Task

Functions ¶

func EnsureRuns ¶

func EnsureRuns(closure func()) <-chan struct{}

EnsureRuns takes a closure and runs it in a goroutine, blocking until the goroutine has had an opportunity to run. It returns a channel which will be closed when the provided closure exits.

func Expect ¶

func Expect(t *testing.T, watch chan events.Event, specifiers ...api.Event)

Expect fails the test if the next event is not one of the specified events.

func FatalStack ¶

func FatalStack(t *testing.T, msg string, args ...interface{})

FatalStack logs the stacks of all goroutines and immediately fails the test.

func WatchShutdownTask ¶

func WatchShutdownTask(t *testing.T, watch chan events.Event) *api.Task

WatchShutdownTask fails the test if the next event is not a task having its desired state changed to Shutdown.

func WatchTaskCreate ¶

func WatchTaskCreate(t *testing.T, watch chan events.Event) *api.Task

WatchTaskCreate waits for a task to be created.

func WatchTaskDelete ¶

func WatchTaskDelete(t *testing.T, watch chan events.Event) *api.Task

WatchTaskDelete waits for a task to be deleted.

func WatchTaskUpdate ¶

func WatchTaskUpdate(t *testing.T, watch chan events.Event) *api.Task

WatchTaskUpdate waits for a task to be updated.

Source Files ¶

testutils.go