testutil

package
v2.1.1 Latest Latest
Warning

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

 Go to latest Published: May 12, 2025 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FedoraESGZImage = "ghcr.io/stargz-containers/fedora:30-esgz"            // eStargz
	FfmpegSociImage = "public.ecr.aws/soci-workshop-examples/ffmpeg:latest" // SOCI
	UbuntuImage     = "public.ecr.aws/docker/library/ubuntu:23.10"          // Large enough for testing soci index creation
)
View Source 
const Namespace = "nerdctl-test"

Variables

View Source 
var (
	BusyboxImage                = "ghcr.io/containerd/busybox:1.36"
	AlpineImage                 = mirrorOf("alpine:3.13")
	NginxAlpineImage            = mirrorOf("nginx:1.19-alpine")
	NginxAlpineIndexHTMLSnippet = "<title>Welcome to nginx!</title>"
	RegistryImageStable         = mirrorOf("registry:2")
	RegistryImageNext           = "ghcr.io/distribution/distribution:"
	WordpressImage              = mirrorOf("wordpress:5.7")
	WordpressIndexHTMLSnippet   = "<title>WordPress &rsaquo; Installation</title>"
	MariaDBImage                = mirrorOf("mariadb:10.5")
	DockerAuthImage             = mirrorOf("cesanta/docker_auth:1.7")
	FluentdImage                = "fluent/fluentd:v1.17.0-debian-1.0"
	KuboImage                   = mirrorOf("ipfs/kubo:v0.16.0")
	SystemdImage                = "ghcr.io/containerd/stargz-snapshotter:0.15.1-kind"
	GolangImage                 = mirrorOf("golang:1.18")

	// Source: https://gist.github.com/cpuguy83/fcf3041e5d8fb1bb5c340915aabeebe0
	NonDistBlobImage = "ghcr.io/cpuguy83/non-dist-blob:latest"
	// Foreign layer digest
	NonDistBlobDigest = "sha256:be691b1535726014cdf3b715ff39361b19e121ca34498a9ceea61ad776b9c215"

	CommonImage = AlpineImage

	// This error string is expected when attempting to connect to a TCP socket
	// for a service which actively refuses the connection.
	// (e.g. attempting to connect using http to an https endpoint).
	// It should be "connection refused" as per the TCP RFC.
	// https://www.rfc-editor.org/rfc/rfc793
	ExpectedConnectionRefusedError = "connection refused"
)

Functions

func DockerIncompatible 

func DockerIncompatible(t testing.TB)

func GetAllowModifyUsers added in v2.1.0 

func GetAllowModifyUsers() bool

func GetDaemonIsKillable 

func GetDaemonIsKillable() bool

func GetEnableIPv6 

func GetEnableIPv6() bool

func GetEnableKubernetes 

func GetEnableKubernetes() bool

func GetFlakyEnvironment 

func GetFlakyEnvironment() bool

func GetTarget 

func GetTarget() string

func Identifier 

func Identifier(t testing.TB) string

Identifier can be used as a name of container, image, volume, network, etc.

func ImageRepo 

func ImageRepo(s string) string

ImageRepo returns the image repo that can be used to, e.g, validate output from `nerdctl images`.

func IsDocker 

func IsDocker() bool

func LoadProject 

func LoadProject(fileName, projectName string, envMap map[string]string) (*compose.Project, error)

Load is used only for unit testing.

func M 

func M(m *testing.M)

func RegisterBuildCacheCleanup 

func RegisterBuildCacheCleanup(t *testing.T)

RegisterBuildCacheCleanup adds a 'builder prune --all --force' cleanup function to run on test teardown.

func RequireContainerdPlugin 

func RequireContainerdPlugin(base *Base, requiredType, requiredID string, requiredCaps []string)

func RequireExecPlatform 

func RequireExecPlatform(t testing.TB, ss ...string)

func RequireExecutable 

func RequireExecutable(t testing.TB, name string)

RequireExecutable skips tests when executable `name` is not present in PATH.

func RequireKernelVersion 

func RequireKernelVersion(t testing.TB, constraint string)

func RequireSystemService 

func RequireSystemService(t testing.TB, sv string)

func RequiresBuild 

func RequiresBuild(t testing.TB)

func WithStdin 

func WithStdin(r io.Reader) func(*Cmd)

WithStdin sets the standard input of Cmd to the specified reader

Types

type Base 

type Base struct {
	T                    testing.TB
	Target               string
	DaemonIsKillable     bool
	EnableIPv6           bool
	IPv6Compatible       bool
	EnableKubernetes     bool
	KubernetesCompatible bool
	Binary               string
	Args                 []string
	Env                  []string
	Dir                  string
}

func NewBase 

func NewBase(t *testing.T) *Base

func NewBaseWithIPv6Compatible 

func NewBaseWithIPv6Compatible(t *testing.T) *Base

func NewBaseWithNamespace 

func NewBaseWithNamespace(t *testing.T, ns string) *Base

func (*Base) Cmd 

func (b *Base) Cmd(args ...string) *Cmd

func (*Base) CmdWithHelper 

func (b *Base) CmdWithHelper(helper []string, args ...string) *Cmd

func (*Base) ComposeCmd 

func (b *Base) ComposeCmd(args ...string) *Cmd

ComposeCmd executes `nerdctl -n nerdctl-test compose` or `docker-compose`

func (*Base) ComposeCmdWithHelper 

func (b *Base) ComposeCmdWithHelper(helper []string, args ...string) *Cmd

func (*Base) ContainerdAddress 

func (b *Base) ContainerdAddress() string

func (*Base) DumpDaemonLogs 

func (b *Base) DumpDaemonLogs(minutes int)

func (*Base) EnsureContainerExited 

func (b *Base) EnsureContainerExited(con string, expectedExitCode int)

func (*Base) EnsureContainerStarted 

func (b *Base) EnsureContainerStarted(con string)

func (*Base) EnsureDaemonActive 

func (b *Base) EnsureDaemonActive()

func (*Base) Info 

func (b *Base) Info() dockercompat.Info

func (*Base) InfoNative 

func (b *Base) InfoNative() native.Info

func (*Base) InspectContainer 

func (b *Base) InspectContainer(name string) dockercompat.Container

func (*Base) InspectImage 

func (b *Base) InspectImage(name string) dockercompat.Image

func (*Base) InspectNetwork 

func (b *Base) InspectNetwork(name string) dockercompat.Network

func (*Base) InspectVolume 

func (b *Base) InspectVolume(name string, args ...string) native.Volume

func (*Base) KillDaemon 

func (b *Base) KillDaemon()

type Cmd 

type Cmd struct {
	icmd.Cmd
	*Base
	// contains filtered or unexported fields
}

func (*Cmd) Assert 

func (c *Cmd) Assert(expected icmd.Expected)

func (*Cmd) AssertCombinedOutContains 

func (c *Cmd) AssertCombinedOutContains(s string)

func (*Cmd) AssertExitCode 

func (c *Cmd) AssertExitCode(exitCode int)

func (*Cmd) AssertFail 

func (c *Cmd) AssertFail()

func (*Cmd) AssertOK 

func (c *Cmd) AssertOK()

func (*Cmd) AssertOutContains 

func (c *Cmd) AssertOutContains(s string)

func (*Cmd) AssertOutContainsAll 

func (c *Cmd) AssertOutContainsAll(strs ...string)

AssertOutContainsAll checks if command output contains All strings in `strs`.

func (*Cmd) AssertOutContainsAny 

func (c *Cmd) AssertOutContainsAny(strs ...string)

AssertOutContainsAny checks if command output contains Any string in `strs`.

func (*Cmd) AssertOutExactly 

func (c *Cmd) AssertOutExactly(s string)

func (*Cmd) AssertOutNotContains 

func (c *Cmd) AssertOutNotContains(s string)

func (*Cmd) AssertOutWithFunc 

func (c *Cmd) AssertOutWithFunc(fn func(stdout string) error)

func (*Cmd) CmdOption 

func (c *Cmd) CmdOption(cmdOptions ...func(*Cmd)) *Cmd

func (*Cmd) Out 

func (c *Cmd) Out() string

func (*Cmd) Run 

func (c *Cmd) Run() *icmd.Result

func (*Cmd) Start 

func (c *Cmd) Start() *icmd.Result

type ComposeDir 

type ComposeDir struct {
	// contains filtered or unexported fields
}

func NewComposeDir 

func NewComposeDir(t testing.TB, dockerComposeYAML string) *ComposeDir

func (*ComposeDir) CleanUp 

func (cd *ComposeDir) CleanUp()

func (*ComposeDir) Dir 

func (cd *ComposeDir) Dir() string

func (*ComposeDir) ProjectName 

func (cd *ComposeDir) ProjectName() string

func (*ComposeDir) WriteFile 

func (cd *ComposeDir) WriteFile(name, content string)

func (*ComposeDir) YAMLFullPath 

func (cd *ComposeDir) YAMLFullPath() string

Source Files

View all Source files

Directories

Path Synopsis
hoststoml
platform
registry
portlock provides a mechanism for containers to acquire and release ports they plan to expose, and a wait mechanism This allows tests dependent on running containers to always parallelize without having to worry about port collision with any other test Note that this does NOT protect against trying to use a port that is already used by an unrelated third-party service or container Also note that *generally* finding a free port is not easy: - to just "listen" and see if it works won't work for containerized services that are DNAT-ed (plus, that would be racy) - inspecting iptables instead (or in addition to) may work for containers, but this depends on how networking has been set (and yes, it is also racy) Our approach here is optimistic: tests are responsible for calling Acquire and Release
 portlock provides a mechanism for containers to acquire and release ports they plan to expose, and a wait mechanism This allows tests dependent on running containers to always parallelize without having to worry about port collision with any other test Note that this does NOT protect against trying to use a port that is already used by an unrelated third-party service or container Also note that *generally* finding a free port is not easy: - to just "listen" and see if it works won't work for containerized services that are DNAT-ed (plus, that would be racy) - inspecting iptables instead (or in addition to) may work for containers, but this depends on how networking has been set (and yes, it is also racy) Our approach here is optimistic: tests are responsible for calling Acquire and Release

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.