cluster

Documentation

Index

• Variables
• type Cluster
  • func New(manager citadel.ResourceManager, engines ...*citadel.Engine) (*Cluster, error)
  • func (c *Cluster) AddEngine(e *citadel.Engine) error
  • func (c *Cluster) Close() error
  • func (c *Cluster) ClusterInfo() *citadel.ClusterInfo
  • func (c *Cluster) Engines() []*citadel.Engine
  • func (c *Cluster) Events(handler citadel.EventHandler) error
  • func (c *Cluster) Kill(container *citadel.Container, sig int) error
  • func (c *Cluster) ListContainers(all bool) []*citadel.Container
  • func (c *Cluster) Logs(container *citadel.Container, stdout bool, stderr bool) (io.ReadCloser, error)
  • func (c *Cluster) RegisterScheduler(tpe string, s citadel.Scheduler) error
  • func (c *Cluster) Remove(container *citadel.Container) error
  • func (c *Cluster) RemoveEngine(e *citadel.Engine) error
  • func (c *Cluster) Restart(container *citadel.Container, timeout int) error
  • func (c *Cluster) Start(image *citadel.Image, pull bool) (*citadel.Container, error)
  • func (c *Cluster) Stop(container *citadel.Container) error

Variables

var (
	ErrEngineNotConnected = errors.New("engine is not connected to docker's REST API")
)

Types

type Cluster

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

func New

func New(manager citadel.ResourceManager, engines ...*citadel.Engine) (*Cluster, error)

func (*Cluster) AddEngine

func (c *Cluster) AddEngine(e *citadel.Engine) error

func (*Cluster) Close

func (c *Cluster) Close() error

Close signals to the cluster that no other actions will be applied

func (*Cluster) ClusterInfo

func (c *Cluster) ClusterInfo() *citadel.ClusterInfo

Info returns information about the cluster

func (*Cluster) Engines

func (c *Cluster) Engines() []*citadel.Engine

Engines returns the engines registered in the cluster

func (*Cluster) Events

func (c *Cluster) Events(handler citadel.EventHandler) error

func (*Cluster) Kill

func (c *Cluster) Kill(container *citadel.Container, sig int) error

func (*Cluster) ListContainers

func (c *Cluster) ListContainers(all bool) []*citadel.Container

ListContainers returns all the containers running in the cluster

func (*Cluster) Logs

func (c *Cluster) Logs(container *citadel.Container, stdout bool, stderr bool) (io.ReadCloser, error)

func (*Cluster) RegisterScheduler

func (c *Cluster) RegisterScheduler(tpe string, s citadel.Scheduler) error

func (*Cluster) Remove

func (c *Cluster) Remove(container *citadel.Container) error

func (*Cluster) RemoveEngine

func (c *Cluster) RemoveEngine(e *citadel.Engine) error

func (*Cluster) Restart

func (c *Cluster) Restart(container *citadel.Container, timeout int) error

func (*Cluster) Start

func (c *Cluster) Start(image *citadel.Image, pull bool) (*citadel.Container, error)

func (*Cluster) Stop

func (c *Cluster) Stop(container *citadel.Container) error