cluster

Documentation

Index

• Variables
• type Cluster
  • func NewCluster(tlsConfig *tls.Config) *Cluster
  • func (c *Cluster) AddNode(n *Node) error
  • func (c *Cluster) Container(IdOrName string) *Container
  • func (c *Cluster) Containers() []*Container
  • func (c *Cluster) Events(h EventHandler) error
  • func (c *Cluster) Handle(e *Event) error
  • func (c *Cluster) Node(addr string) *Node
  • func (c *Cluster) Nodes() []*Node
  • func (c *Cluster) UpdateNodes(nodes []*discovery.Node)
• type Container
  • func (c *Container) Node() *Node
• type Event
• type EventHandler
• type Node
  • func NewNode(addr string) *Node
  • func (n *Node) AddContainer(container *Container) error
  • func (n *Node) CleanupContainers()
  • func (n *Node) Connect(config *tls.Config) error
  • func (n *Node) Containers() []*Container
  • func (n *Node) Create(config *dockerclient.ContainerConfig, name string, pullImage bool) (*Container, error)
  • func (n *Node) Destroy(container *Container, force bool) error
  • func (n *Node) Events(h EventHandler) error
  • func (n *Node) IsConnected() bool
  • func (n *Node) IsHealthy() bool
  • func (n *Node) ListImages() ([]string, error)
  • func (n *Node) Pull(image string) error
  • func (n *Node) RemoveContainer(container *Container) error
  • func (n *Node) ReservedCpus() int64
  • func (n *Node) ReservedMemory() int64
  • func (n *Node) String() string

Variables

var (
	ErrNodeNotConnected      = errors.New("node is not connected to docker's REST API")
	ErrNodeAlreadyRegistered = errors.New("node was already added to the cluster")
)

Types

type Cluster

type Cluster struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewCluster

func NewCluster(tlsConfig *tls.Config) *Cluster

func (*Cluster) AddNode

func (c *Cluster) AddNode(n *Node) error

Register a node within the cluster. The node must have been already initialized.

func (*Cluster) Container

func (c *Cluster) Container(IdOrName string) *Container

Container returns the container with ID in the cluster

func (*Cluster) Containers

func (c *Cluster) Containers() []*Container

Containers returns all the containers in the cluster.

func (*Cluster) Events

func (c *Cluster) Events(h EventHandler) error

func (*Cluster) Handle

func (c *Cluster) Handle(e *Event) error

func (*Cluster) Node

func (c *Cluster) Node(addr string) *Node

func (*Cluster) Nodes

func (c *Cluster) Nodes() []*Node

Nodes returns the list of nodes in the cluster

func (*Cluster) UpdateNodes

func (c *Cluster) UpdateNodes(nodes []*discovery.Node)

type Container

type Container struct {
	dockerclient.Container

	Info dockerclient.ContainerInfo
	// contains filtered or unexported fields
}

func (*Container) Node

func (c *Container) Node() *Node

type Event

type Event struct {
	dockerclient.Event
	Node *Node
}

type EventHandler

type EventHandler interface {
	Handle(*Event) error
}

type Node

type Node struct {
	sync.RWMutex

	ID     string
	IP     string
	Addr   string
	Name   string
	Cpus   int64
	Memory int64
	Labels map[string]string
	// contains filtered or unexported fields
}

func NewNode

func NewNode(addr string) *Node

func (*Node) AddContainer

func (n *Node) AddContainer(container *Container) error

Inject a container into the internal state.

func (*Node) CleanupContainers

func (n *Node) CleanupContainers()

Wipes the internal container state.

func (*Node) Connect

func (n *Node) Connect(config *tls.Config) error

Connect will initialize a connection to the Docker daemon running on the host, gather machine specs (memory, cpu, ...) and monitor state changes.

func (*Node) Containers

func (n *Node) Containers() []*Container

func (*Node) Create

func (n *Node) Create(config *dockerclient.ContainerConfig, name string, pullImage bool) (*Container, error)

func (*Node) Destroy

func (n *Node) Destroy(container *Container, force bool) error

Destroy and remove a container from the node.

func (*Node) Events

func (n *Node) Events(h EventHandler) error

Register an event handler.

func (*Node) IsConnected

func (n *Node) IsConnected() bool

IsConnected returns true if the engine is connected to a remote docker API

func (*Node) IsHealthy

func (n *Node) IsHealthy() bool

func (*Node) ListImages

func (n *Node) ListImages() ([]string, error)

func (*Node) Pull

func (n *Node) Pull(image string) error

func (*Node) RemoveContainer

func (n *Node) RemoveContainer(container *Container) error

Remove a container from the internal test.

func (*Node) ReservedCpus

func (n *Node) ReservedCpus() int64

Return the sum of CPUs reserved by containers.

func (*Node) ReservedMemory

func (n *Node) ReservedMemory() int64

Return the sum of memory reserved by containers.

func (*Node) String

func (n *Node) String() string