mockingmoby

package
v0.15.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 16, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package mockingmoby is a very minimalist Docker mock client designed for simple unit tests in the whalewatcher package. Only limited listing and inspecting containers is supported, as well as streaming container start and die events. Moreover, only very few container properties are mocked, just to the extend needed in the whalewatcher package.

But in contrast to using a real Docker client in unit tests mockingmoby offers service API hooks which get called at the beginning and end of service API calls. This can be used to synchronize certain "asynchronous" events with exact logical timing without the need to instrument production code under test with hooks. The service API hooks are passed in via (service) context values.

The mocked containers are not created and destroyed using the standard Docker client service API but instead using AddContainer and RemoveContainer. In addition, a mock container can be "stopped" using StopContainer, so it gets into the "exited" state but still exists.

Index

Constants

View Source 
const (
	ContainerListPre     = HookKey("containerlistpre")
	ContainerListPost    = HookKey("containerlistpost")
	ContainerInspectPre  = HookKey("containerinspectpre")
	ContainerInspectPost = HookKey("containerinspectpost")
)

The available API pre/post hook keys.

Variables

View Source 
var ErrEventStreamStopped = errors.New("event stream stopped")

ErrEventStreamStopped is the error send via the error stream after invoking StopEvents on a MockingMoby.

View Source 
var MockedStates = map[MockedContainerStatus]string{
	MockedCreated: "",
	MockedRunning: "up for ages",
	MockedPaused:  "pausing a moment",
	MockedDead:    "just sleeping",
	MockedExited:  "exit 42",
}

MockedStates maps the states of a mocked container to Docker's textual descriptive (and slightly chatty) container states, suitable for display to hoomans.

View Source 
var MockedStatus = map[MockedContainerStatus]string{
	MockedCreated: "created",
	MockedRunning: "running",
	MockedPaused:  "paused",
	MockedDead:    "dead",
	MockedExited:  "exited",
}

MockedStatus maps the states of a mocked container to Docker's container status strings that is better suited for code checks (no chatty additions and content variations).

Functions

func MockAttributes 

func MockAttributes(c MockedContainer) map[string]string

MockAttributes returns a mocked attributes map for the specified mock container, based on the container's labels and additional attributes (namely, the container name as opposed to its ID). The attributes map is suitable for direct emission in the Actor fields of Docker events.

func WithHook 

func WithHook(ctx context.Context, key HookKey, hook Hook) context.Context

WithHook returns a new context with the specific Hook added.

Types

type Hook 

type Hook func(HookKey) error

Hook is a hook function called in the processing of a service API request. Hook functions get passed HookKeys for the specific types of API requests. Hooks might return errors in order to either early abort an API request or make it override the API error return value (where applicable).

Please note: hooks never get called for API requests that were already called with a "Done" context (cancelled or timed out).

type HookKey 

type HookKey string

HookKey identifies a particular API pre or post hook.

type MockedContainer 

type MockedContainer struct {
	ID     string                // unique identifier of container
	Name   string                // name of container without any prefixing "/"
	Status MockedContainerStatus // container status (without any thrills)
	PID    int                   // PID of initial container process if container is "alive"
	Labels map[string]string     // container labels
}

MockedContainer is our very, very limited knowledge about a mocked container; it just stores the minimum of information we need in mocking our own unit tests.

type MockedContainerStatus 

type MockedContainerStatus int

MockedContainerStatus is a compressed, only-essentials, no-bulls version of Docker's types.ContainerStatus. 

const (
	MockedCreated MockedContainerStatus = iota
	MockedRunning
	MockedPaused
	MockedDead
	MockedExited
)

The available states of a mocked container.

type MockingMoby 

type MockingMoby struct {
	client.ContainerAPIClient
	client.SystemAPIClient
	// contains filtered or unexported fields
}

MockingMoby is a mock Docker client implementing only listing all containers, inspecting them (limited information only) and receiving container-related events. All other service API methods will return a not-implemented error when tried.

Please note that only a single call to the Events API method is supported per mock client instance.

func NewMockingMoby 

func NewMockingMoby() *MockingMoby

NewMockingMoby returns a new instance of a mock Docker client.

func (*MockingMoby) AddContainer 

func (mm *MockingMoby) AddContainer(c MockedContainer)

AddContainer adds a mocked container and optionally emits a container event if the container is in running or paused states.

func (*MockingMoby) Close 

func (mm *MockingMoby) Close() error

Close closes the mock client, releasing its internal resources.

func (*MockingMoby) ContainerAttach 

func (mm *MockingMoby) ContainerAttach(context.Context, string, container.AttachOptions) (types.HijackedResponse, error)

ContainerAttach is not implemented.

func (*MockingMoby) ContainerCommit 

func (mm *MockingMoby) ContainerCommit(context.Context, string, container.CommitOptions) (container.CommitResponse, error)

ContainerCommit is not implemented.

func (*MockingMoby) ContainerCreate 

func (mm *MockingMoby) ContainerCreate(context.Context, *container.Config, *container.HostConfig, *networktypes.NetworkingConfig, *specs.Platform, string) (container.CreateResponse, error)

ContainerCreate is not implemented.

func (*MockingMoby) ContainerDiff 

func (mm *MockingMoby) ContainerDiff(context.Context, string) ([]container.FilesystemChange, error)

ContainerDiff is not implemented.

func (*MockingMoby) ContainerExecAttach 

func (mm *MockingMoby) ContainerExecAttach(context.Context, string, container.ExecAttachOptions) (types.HijackedResponse, error)

ContainerExecAttach is not implemented.

func (*MockingMoby) ContainerExecCreate 

func (mm *MockingMoby) ContainerExecCreate(context.Context, string, container.ExecOptions) (container.ExecCreateResponse, error)

ContainerExecCreate is not implemented.

func (*MockingMoby) ContainerExecInspect 

func (mm *MockingMoby) ContainerExecInspect(context.Context, string) (container.ExecInspect, error)

ContainerExecInspect is not implemented.

func (*MockingMoby) ContainerExecResize 

func (mm *MockingMoby) ContainerExecResize(context.Context, string, container.ResizeOptions) error

ContainerExecResize is not implemented.

func (*MockingMoby) ContainerExecStart 

func (mm *MockingMoby) ContainerExecStart(context.Context, string, container.ExecStartOptions) error

ContainerExecStart is not implemented.

func (*MockingMoby) ContainerExport 

func (mm *MockingMoby) ContainerExport(context.Context, string) (io.ReadCloser, error)

ContainerExport is not implemented.

func (*MockingMoby) ContainerInspect 

func (mm *MockingMoby) ContainerInspect(ctx context.Context, nameorid string) (types.ContainerJSON, error)

ContainerInspect returns details about a particular mocked container.

func (*MockingMoby) ContainerInspectWithRaw 

func (mm *MockingMoby) ContainerInspectWithRaw(context.Context, string, bool) (container.InspectResponse, []byte, error)

ContainerInspectWithRaw is not implemented.

func (*MockingMoby) ContainerKill 

func (mm *MockingMoby) ContainerKill(context.Context, string, string) error

ContainerKill is not implemented.

func (*MockingMoby) ContainerList 

func (mm *MockingMoby) ContainerList(ctx context.Context, options container.ListOptions) ([]types.Container, error)

ContainerList returns the list of currently known containers, ignoring any list options.

func (*MockingMoby) ContainerLogs 

func (mm *MockingMoby) ContainerLogs(context.Context, string, container.LogsOptions) (io.ReadCloser, error)

ContainerLogs is not implemented.

func (*MockingMoby) ContainerPause 

func (mm *MockingMoby) ContainerPause(context.Context, string) error

ContainerPause is not implemented.

func (*MockingMoby) ContainerRemove 

func (mm *MockingMoby) ContainerRemove(context.Context, string, container.RemoveOptions) error

ContainerRemove is not implemented.

func (*MockingMoby) ContainerRename 

func (mm *MockingMoby) ContainerRename(context.Context, string, string) error

ContainerRename is not implemented.

func (*MockingMoby) ContainerResize 

func (mm *MockingMoby) ContainerResize(context.Context, string, container.ResizeOptions) error

ContainerResize is not implemented.

func (*MockingMoby) ContainerRestart 

func (mm *MockingMoby) ContainerRestart(context.Context, string, container.StopOptions) error

ContainerRestart is not implemented.

func (*MockingMoby) ContainerStart 

func (mm *MockingMoby) ContainerStart(context.Context, string, container.StartOptions) error

ContainerStart is not implemented.

func (*MockingMoby) ContainerStatPath 

func (mm *MockingMoby) ContainerStatPath(context.Context, string, string) (container.PathStat, error)

ContainerStatPath is not implemented.

func (*MockingMoby) ContainerStats 

func (mm *MockingMoby) ContainerStats(context.Context, string, bool) (container.StatsResponseReader, error)

ContainerStats is not implemented.

func (*MockingMoby) ContainerStatsOneShot 

func (mm *MockingMoby) ContainerStatsOneShot(context.Context, string) (container.StatsResponseReader, error)

ContainerStatsOneShot is not implemented.

func (*MockingMoby) ContainerStop 

func (mm *MockingMoby) ContainerStop(context.Context, string, container.StopOptions) error

ContainerStop is not implemented.

func (*MockingMoby) ContainerTop 

func (mm *MockingMoby) ContainerTop(context.Context, string, []string) (container.TopResponse, error)

ContainerTop is not implemented.

func (*MockingMoby) ContainerUnpause 

func (mm *MockingMoby) ContainerUnpause(context.Context, string) error

ContainerUnpause is not implemented.

func (*MockingMoby) ContainerUpdate 

func (mm *MockingMoby) ContainerUpdate(context.Context, string, container.UpdateConfig) (container.UpdateResponse, error)

ContainerUpdate is not implemented.

func (*MockingMoby) ContainerWait 

func (mm *MockingMoby) ContainerWait(context.Context, string, container.WaitCondition) (<-chan container.WaitResponse, <-chan error)

ContainerWait is not implemented.

func (*MockingMoby) ContainersPrune 

func (mm *MockingMoby) ContainersPrune(context.Context, filters.Args) (container.PruneReport, error)

ContainersPrune is not implemented.

func (*MockingMoby) CopyFromContainer 

func (mm *MockingMoby) CopyFromContainer(context.Context, string, string) (io.ReadCloser, container.PathStat, error)

CopyFromContainer is not implemented.

func (*MockingMoby) CopyToContainer 

func (mm *MockingMoby) CopyToContainer(context.Context, string, string, io.Reader, container.CopyToContainerOptions) error

CopyToContainer is not implemented.

func (*MockingMoby) DaemonHost added in v0.4.0 

func (mm *MockingMoby) DaemonHost() string

DaemonHost returns the host address used by the client

func (*MockingMoby) DiskUsage 

func (mm *MockingMoby) DiskUsage(ctx context.Context, options types.DiskUsageOptions) (types.DiskUsage, error)

DiskUsage is not implemented.

func (*MockingMoby) Events 

func (mm *MockingMoby) Events(ctx context.Context, options events.ListOptions) (<-chan events.Message, <-chan error)

Events returns a stream of fake events. It ignores all options, but checks ctx for being Done (with or without any error) and then mirrors the context error to the (events) error channel returned by Events. After an error the event channel will be closed automatically.

Please note that only a single call to the Events API method is supported per mock client instance.

func (*MockingMoby) Info 

func (mm *MockingMoby) Info(ctx context.Context) (system.Info, error)

Info returns engine information, consisting only of a fake engine ID, but nothing else.

func (*MockingMoby) NegotiateAPIVersion added in v0.7.1 

func (mm *MockingMoby) NegotiateAPIVersion(ctx context.Context)

NegotiateAPIVersion is a mock no-op.

func (*MockingMoby) PauseContainer added in v0.3.0 

func (mm *MockingMoby) PauseContainer(nameorid string)

PauseContainer pauses a container, if currently running, and emits a container pause event.

func (*MockingMoby) Ping 

func (mm *MockingMoby) Ping(ctx context.Context) (types.Ping, error)

Ping is not implemented.

func (*MockingMoby) RegistryLogin 

func (mm *MockingMoby) RegistryLogin(ctx context.Context, auth registry.AuthConfig) (registry.AuthenticateOKBody, error)

RegistryLogin is not implemented.

func (*MockingMoby) RemoveContainer 

func (mm *MockingMoby) RemoveContainer(nameorid string)

RemoveContainer removes a mocked container and emits a container event if the container was in running or paused states.

func (*MockingMoby) StopContainer 

func (mm *MockingMoby) StopContainer(nameorid string)

StopContainer stops a mocked container, but does not remove it yet. It emits a container event if the container was in running or paused state.

func (*MockingMoby) StopEvents 

func (mm *MockingMoby) StopEvents()

StopEvents closes down streaming events with an error on the error channel; it is used in unit tests to simulate event stream errors other than a cancelled context.

func (*MockingMoby) UnpauseContainer added in v0.3.0 

func (mm *MockingMoby) UnpauseContainer(nameorid string)

UnpauseContainer unpauses a container, if currently paused, and emits a container unpause event.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.