dockertest

Documentation

Index

• func NewFakeLocker() *fakeLocker
• func NewHealerIaaSConstructor(addr string, err error) func(string) iaas.IaaS
• func NewMultiHealerIaaSConstructor(addrs []string, ports []int, err error) func(string) iaas.IaaS
• func URLPort(uStr string) int
• type ContainerMoving
• type FakeDockerProvisioner
  • func NewFakeDockerProvisioner(servers ...string) (*FakeDockerProvisioner, error)
  • func StartMultipleServersCluster() (*FakeDockerProvisioner, error)
  • func (p *FakeDockerProvisioner) ActionLimiter() provision.ActionLimiter
  • func (p *FakeDockerProvisioner) AllContainers() []container.Container
  • func (p *FakeDockerProvisioner) Cluster() *cluster.Cluster
  • func (p *FakeDockerProvisioner) ClusterClient() provision.BuilderDockerClient
  • func (p *FakeDockerProvisioner) Collection() *storage.Collection
  • func (p *FakeDockerProvisioner) Containers(host string) []container.Container
  • func (p *FakeDockerProvisioner) DeleteContainer(id string)
  • func (p *FakeDockerProvisioner) Destroy()
  • func (p *FakeDockerProvisioner) FailMove(errs ...error)
  • func (p *FakeDockerProvisioner) FailPush(errs ...error)
  • func (p *FakeDockerProvisioner) GetContainer(id string) (*container.Container, error)
  • func (p *FakeDockerProvisioner) GetName() string
  • func (p *FakeDockerProvisioner) HandleMoveErrors(errors chan error, w io.Writer) error
  • func (p *FakeDockerProvisioner) ListContainers(query bson.M) ([]container.Container, error)
  • func (p *FakeDockerProvisioner) MoveContainers(fromHost, toHost string, w io.Writer) error
  • func (p *FakeDockerProvisioner) MoveOneContainer(cont container.Container, toHost string, errors chan error, wg *sync.WaitGroup, ...) container.Container
  • func (p *FakeDockerProvisioner) Movings() []ContainerMoving
  • func (p *FakeDockerProvisioner) PrepareListResult(containers []container.Container, err error)
  • func (p *FakeDockerProvisioner) PushImage(name, tag string) error
  • func (p *FakeDockerProvisioner) Pushes() []Push
  • func (p *FakeDockerProvisioner) Queries() []bson.M
  • func (p *FakeDockerProvisioner) Servers() []*testing.DockerServer
  • func (p *FakeDockerProvisioner) SetContainers(host string, containers []container.Container)
  • func (p *FakeDockerProvisioner) StartContainers(args StartContainersArgs) ([]container.Container, error)
• type Push
• type StartContainersArgs
• type TestHealerIaaS
  • func NewHealerIaaSConstructorWithInst(addr string) (func(string) iaas.IaaS, *TestHealerIaaS)
  • func (t *TestHealerIaaS) CreateMachine(params map[string]string) (*iaas.Machine, error)
  • func (t *TestHealerIaaS) DeleteMachine(m *iaas.Machine) error
  • func (t *TestHealerIaaS) Describe() string

Functions

func NewFakeLocker

func NewFakeLocker() *fakeLocker

func NewHealerIaaSConstructor

func NewHealerIaaSConstructor(addr string, err error) func(string) iaas.IaaS

func NewMultiHealerIaaSConstructor

func NewMultiHealerIaaSConstructor(addrs []string, ports []int, err error) func(string) iaas.IaaS

func URLPort

func URLPort(uStr string) int

URLPort extracts the port from a given URL.

Types

type ContainerMoving

type ContainerMoving struct {
	ContainerID string
	HostFrom    string
	HostTo      string
}

type FakeDockerProvisioner

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

func NewFakeDockerProvisioner

func NewFakeDockerProvisioner(servers ...string) (*FakeDockerProvisioner, error)

func StartMultipleServersCluster

func StartMultipleServersCluster() (*FakeDockerProvisioner, error)

func (*FakeDockerProvisioner) ActionLimiter

func (p *FakeDockerProvisioner) ActionLimiter() provision.ActionLimiter

func (*FakeDockerProvisioner) AllContainers

func (p *FakeDockerProvisioner) AllContainers() []container.Container

func (*FakeDockerProvisioner) Cluster

func (p *FakeDockerProvisioner) Cluster() *cluster.Cluster

func (*FakeDockerProvisioner) ClusterClient

func (p *FakeDockerProvisioner) ClusterClient() provision.BuilderDockerClient

func (*FakeDockerProvisioner) Collection

func (p *FakeDockerProvisioner) Collection() *storage.Collection

func (*FakeDockerProvisioner) Containers

func (p *FakeDockerProvisioner) Containers(host string) []container.Container

func (*FakeDockerProvisioner) DeleteContainer

func (p *FakeDockerProvisioner) DeleteContainer(id string)

func (*FakeDockerProvisioner) Destroy

func (p *FakeDockerProvisioner) Destroy()

func (*FakeDockerProvisioner) FailMove

func (p *FakeDockerProvisioner) FailMove(errs ...error)

func (*FakeDockerProvisioner) FailPush

func (p *FakeDockerProvisioner) FailPush(errs ...error)

func (*FakeDockerProvisioner) GetContainer

func (p *FakeDockerProvisioner) GetContainer(id string) (*container.Container, error)

func (*FakeDockerProvisioner) GetName

func (p *FakeDockerProvisioner) GetName() string

func (*FakeDockerProvisioner) HandleMoveErrors

func (p *FakeDockerProvisioner) HandleMoveErrors(errors chan error, w io.Writer) error

func (*FakeDockerProvisioner) ListContainers

func (p *FakeDockerProvisioner) ListContainers(query bson.M) ([]container.Container, error)

func (*FakeDockerProvisioner) MoveContainers

func (p *FakeDockerProvisioner) MoveContainers(fromHost, toHost string, w io.Writer) error

func (*FakeDockerProvisioner) MoveOneContainer

func (p *FakeDockerProvisioner) MoveOneContainer(cont container.Container, toHost string, errors chan error, wg *sync.WaitGroup, w io.Writer, locker container.AppLocker) container.Container

func (*FakeDockerProvisioner) Movings

func (p *FakeDockerProvisioner) Movings() []ContainerMoving

func (*FakeDockerProvisioner) PrepareListResult

func (p *FakeDockerProvisioner) PrepareListResult(containers []container.Container, err error)

PrepareListResult prepares a result or a failure in the next ListContainers call. If err is not nil, it will prepare a failure. Otherwise it will prepare a valid result with the provided list of containers.

func (*FakeDockerProvisioner) PushImage

func (p *FakeDockerProvisioner) PushImage(name, tag string) error

func (*FakeDockerProvisioner) Pushes

func (p *FakeDockerProvisioner) Pushes() []Push

func (*FakeDockerProvisioner) Queries

func (p *FakeDockerProvisioner) Queries() []bson.M

func (*FakeDockerProvisioner) Servers

func (p *FakeDockerProvisioner) Servers() []*testing.DockerServer

func (*FakeDockerProvisioner) SetContainers

func (p *FakeDockerProvisioner) SetContainers(host string, containers []container.Container)

func (*FakeDockerProvisioner) StartContainers

func (p *FakeDockerProvisioner) StartContainers(args StartContainersArgs) ([]container.Container, error)

StartContainers starts the provided amount of containers in the provided endpoint.

The amount is specified using a map of processes. The started containers will be both returned and stored internally.

type Push

type Push struct {
	Name string
	Tag  string
}

type StartContainersArgs

type StartContainersArgs struct {
	Endpoint  string
	App       provision.App
	Amount    map[string]int
	Image     string
	PullImage bool
}

type TestHealerIaaS

type TestHealerIaaS struct {
	sync.Mutex
	Addr   string
	Err    error
	DelErr error
	Addrs  []string
	Ports  []int
	AddrId int
}

func NewHealerIaaSConstructorWithInst

func NewHealerIaaSConstructorWithInst(addr string) (func(string) iaas.IaaS, *TestHealerIaaS)

func (*TestHealerIaaS) CreateMachine

func (t *TestHealerIaaS) CreateMachine(params map[string]string) (*iaas.Machine, error)

func (*TestHealerIaaS) DeleteMachine

func (t *TestHealerIaaS) DeleteMachine(m *iaas.Machine) error

func (*TestHealerIaaS) Describe

func (t *TestHealerIaaS) Describe() string