testutils

Documentation

Index

• func CheckTcp4Port(port int) (bool, error)
• func GetDefaultGWv4() (string, error)
• func GetDefaultGWv6() (string, error)
• func GetGW(iface string, family int) (string, error)
• func GetGWv4(iface string) (string, error)
• func GetGWv6(iface string) (string, error)
• func GetIPs(ifaceWanted string, familyWanted int) ([]string, error)
• func GetIPsv4(iface string) ([]string, error)
• func GetIPsv6(iface string) ([]string, error)
• func GetIfaceCount() (int, error)
• func GetNextFreePort4() (int, error)
• func GetNextFreePort4Banned(bannedPorts map[int]struct{}) (int, error)
• func GetNonLoIfaceIPv4() (string, error)
• func GetNonLoIfaceWithAddrs(ipFamily int) (iface net.Interface, addrs []string, err error)
• func GetUnprivilegedUidGid() (int, int)
• func GetValueFromEnvOrPanic(envVar string) string
• func HTTPGet(addr string) (string, error)
• func HTTPServe(addr string, timeout int) error
• func WaitOrTimeout(t *testing.T, timeout time.Duration, notify chan struct{})
• type GoroutineAssistant
  • func NewGoroutineAssistant(t *testing.T) *GoroutineAssistant
  • func (a *GoroutineAssistant) Add(n int)
  • func (a *GoroutineAssistant) Done()
  • func (a *GoroutineAssistant) Fatalf(s string, args ...interface{})
  • func (a *GoroutineAssistant) SpawnOrFail(cmd string) *gexpect.ExpectSubprocess
  • func (a *GoroutineAssistant) Wait()
  • func (a *GoroutineAssistant) WaitOrFail(child *gexpect.ExpectSubprocess)
• type RktRunCtx
  • func NewRktRunCtx() *RktRunCtx
  • func (ctx *RktRunCtx) Cleanup()
  • func (ctx *RktRunCtx) Cmd() string
  • func (ctx *RktRunCtx) CmdNoConfig() string
  • func (ctx *RktRunCtx) DataDir() string
  • func (ctx *RktRunCtx) ExecCmd(arg ...string) *exec.Cmd
  • func (ctx *RktRunCtx) GetUidGidRktBinOwnerNotRoot() (int, int)
  • func (ctx *RktRunCtx) LaunchMDS() error
  • func (ctx *RktRunCtx) LocalDir() string
  • func (ctx *RktRunCtx) RegisterChild(child *gexpect.ExpectSubprocess)
  • func (ctx *RktRunCtx) Reset()
  • func (ctx *RktRunCtx) RunGC()
  • func (ctx *RktRunCtx) SetupDataDir() error
  • func (ctx *RktRunCtx) SystemDir() string
  • func (ctx *RktRunCtx) UserDir() string
• type Test
• type TestFunc
  • func (f TestFunc) Execute(t *testing.T)

Functions

func CheckTcp4Port

func CheckTcp4Port(port int) (bool, error)

func GetDefaultGWv4

func GetDefaultGWv4() (string, error)

func GetDefaultGWv6

func GetDefaultGWv6() (string, error)

func GetGW

func GetGW(iface string, family int) (string, error)

func GetGWv4

func GetGWv4(iface string) (string, error)

func GetGWv6

func GetGWv6(iface string) (string, error)

func GetIPs

func GetIPs(ifaceWanted string, familyWanted int) ([]string, error)

func GetIPsv4

func GetIPsv4(iface string) ([]string, error)

func GetIPsv6

func GetIPsv6(iface string) ([]string, error)

func GetIfaceCount

func GetIfaceCount() (int, error)

func GetNextFreePort4

func GetNextFreePort4() (int, error)

func GetNextFreePort4Banned

func GetNextFreePort4Banned(bannedPorts map[int]struct{}) (int, error)

func GetNonLoIfaceIPv4

func GetNonLoIfaceIPv4() (string, error)

func GetNonLoIfaceWithAddrs

func GetNonLoIfaceWithAddrs(ipFamily int) (iface net.Interface, addrs []string, err error)

func GetUnprivilegedUidGid

func GetUnprivilegedUidGid() (int, int)

func GetValueFromEnvOrPanic

func GetValueFromEnvOrPanic(envVar string) string

func HTTPGet

func HTTPGet(addr string) (string, error)

func HTTPServe

func HTTPServe(addr string, timeout int) error

func WaitOrTimeout

func WaitOrTimeout(t *testing.T, timeout time.Duration, notify chan struct{})

Types

type GoroutineAssistant

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

func NewGoroutineAssistant

func NewGoroutineAssistant(t *testing.T) *GoroutineAssistant

func (*GoroutineAssistant) Add

func (a *GoroutineAssistant) Add(n int)

func (*GoroutineAssistant) Done

func (a *GoroutineAssistant) Done()

func (*GoroutineAssistant) Fatalf

func (a *GoroutineAssistant) Fatalf(s string, args ...interface{})

func (*GoroutineAssistant) SpawnOrFail

func (a *GoroutineAssistant) SpawnOrFail(cmd string) *gexpect.ExpectSubprocess

func (*GoroutineAssistant) Wait

func (a *GoroutineAssistant) Wait()

func (*GoroutineAssistant) WaitOrFail

func (a *GoroutineAssistant) WaitOrFail(child *gexpect.ExpectSubprocess)

type RktRunCtx

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

func NewRktRunCtx

func NewRktRunCtx() *RktRunCtx

func (*RktRunCtx) Cleanup

func (ctx *RktRunCtx) Cleanup()

func (*RktRunCtx) Cmd

func (ctx *RktRunCtx) Cmd() string

func (*RktRunCtx) CmdNoConfig

func (ctx *RktRunCtx) CmdNoConfig() string

TODO(jonboulle): clean this up

func (*RktRunCtx) DataDir

func (ctx *RktRunCtx) DataDir() string

func (*RktRunCtx) ExecCmd

func (ctx *RktRunCtx) ExecCmd(arg ...string) *exec.Cmd

func (*RktRunCtx) GetUidGidRktBinOwnerNotRoot

func (ctx *RktRunCtx) GetUidGidRktBinOwnerNotRoot() (int, int)

func (*RktRunCtx) LaunchMDS

func (ctx *RktRunCtx) LaunchMDS() error

func (*RktRunCtx) LocalDir

func (ctx *RktRunCtx) LocalDir() string

func (*RktRunCtx) RegisterChild

func (ctx *RktRunCtx) RegisterChild(child *gexpect.ExpectSubprocess)

func (*RktRunCtx) Reset

func (ctx *RktRunCtx) Reset()

func (*RktRunCtx) RunGC

func (ctx *RktRunCtx) RunGC()

func (*RktRunCtx) SetupDataDir

func (ctx *RktRunCtx) SetupDataDir() error

func (*RktRunCtx) SystemDir

func (ctx *RktRunCtx) SystemDir() string

func (*RktRunCtx) UserDir

func (ctx *RktRunCtx) UserDir() string

type Test

type Test interface {
	Execute(*testing.T)
}

Test is the interface that wraps a test. It is meant to be used for parametrized test fixtures.

Execute executes the test.

type TestFunc

type TestFunc func(*testing.T)

TestFunc is a functional adapter to allow ordinary functions as test wrappers.

func (TestFunc) Execute

func (f TestFunc) Execute(t *testing.T)