dockertest

package

v0.0.0-...-9451de5 Latest Latest Go to latest Published: Feb 27, 2019 License: BSD-3-Clause Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/morpheu/tsuru

Links

Open Source Insights

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)
type Push
type StartContainersArgs
type TestHealerIaaS
- func NewHealerIaaSConstructorWithInst(addr string) (func(string) iaas.IaaS, *TestHealerIaaS)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL