cluster

Jul 28, 2016

Changes in this version

+ func NewHTTPClientTimeout(daemonUrl string, tlsConfig *tls.Config, timeout time.Duration, ...) (*http.Client, *url.URL, error)

type Engine

+ DeltaDuration time.Duration

+ func (e *Engine) CreateContainer(config *ContainerConfig, name string, pullImage bool, ...) (*Container, error)

May 3, 2016

Changes in this version

+ func ConsolidateResourceFields(c *OldContainerConfig)

+ func FullStateString(state *types.ContainerState) string

+ func StateString(state *types.ContainerState) string

type ContainerConfig

+ HostConfig container.HostConfig

+ NetworkingConfig network.NetworkingConfig

+ type EventsMonitor struct

+ func NewEventsMonitor(cli client.APIClient, handler func(msg events.Message) error) *EventsMonitor

+ func (em *EventsMonitor) Start(ec chan error)

+ func (em *EventsMonitor) Stop()

+ type OldContainerConfig struct

+ CPUSet string

+ CPUShares int64

+ Memory int64

+ MemorySwap int64

Apr 13, 2016

Changes in this version

type Engine

+ Version string

type Network

+ func (network *Network) RemoveDuplicateEndpoints() *Network

Mar 2, 2016

Changes in this version

type ContainerConfig

+ func (c *ContainerConfig) AddConstraint(constraint string) error

Feb 17, 2016

Changes in this version

type Engine

+ func (e *Engine) AddNetwork(network *Network)

+ func (e *Engine) DeleteNetwork(network *Network)

+ func (e *Engine) HTTPClientAndScheme() (*http.Client, string)

Feb 4, 2016

Changes in this version

+ func ParseRepositoryTag(repos string) (string, string)

type Cluster

+ StartContainer func(container *Container) error

+ UnregisterEventHandler func(h EventHandler)

type ContainerConfig

+ func (c *ContainerConfig) HasReschedulePolicy(p string) bool

+ func (c *ContainerConfig) RemoveAffinity(affinity string) error

+ func (c *ContainerConfig) Validate() error

type DriverOpts

+ func (do DriverOpts) Bool(key, env string) (bool, bool)

type Engine

+ func (e *Engine) CheckConnectionErr(err error)

+ func (e *Engine) ErrMsg() string

+ func (e *Engine) HandleIDConflict(otherAddr string)

+ func (e *Engine) HealthIndicator() int64

+ func (e *Engine) StartContainer(id string) error

+ func (e *Engine) StartMonitorEvents()

+ func (e *Engine) TimeToValidate() bool

+ func (e *Engine) UpdatedAt() time.Time

+ func (e *Engine) ValidationComplete()

type EngineOpts

+ FailureRetry int

+ type EventHandlers struct

+ func NewEventHandlers() *EventHandlers

+ func (eh *EventHandlers) Handle(e *Event)

+ func (eh *EventHandlers) RegisterEventHandler(h EventHandler) error

+ func (eh *EventHandlers) UnregisterEventHandler(h EventHandler)

+ type Volumes []*Volume

+ func (volumes Volumes) Get(name string) *Volume

+ type Watchdog struct

+ func NewWatchdog(cluster Cluster) *Watchdog

+ func (w *Watchdog) Handle(e *Event) error

Dec 9, 2015

Changes in this version

type Engine

+ func (e *Engine) Status() string

+ type EngineOpts struct

+ RefreshMaxInterval time.Duration

+ RefreshMinInterval time.Duration

+ RefreshRetry int

Nov 3, 2015

Changes in this version

type Cluster

+ CreateNetwork func(request *dockerclient.NetworkCreate) (*dockerclient.NetworkCreateResponse, error)

+ CreateVolume func(request *dockerclient.VolumeCreateRequest) (*Volume, error)

+ Networks func() Networks

+ RemoveNetwork func(network *Network) error

+ RemoveVolumes func(name string) (bool, error)

+ TagImage func(IDOrName string, repo string, tag string, force bool) error

+ Volume func(name string) *Volume

+ Volumes func() []*Volume

type ContainerConfig

+ func (c *ContainerConfig) HaveNodeConstraint() bool

type Engine

+ func (e *Engine) CreateNetwork(request *dockerclient.NetworkCreate) (*dockerclient.NetworkCreateResponse, error)

+ func (e *Engine) CreateVolume(request *dockerclient.VolumeCreateRequest) (*Volume, error)

+ func (e *Engine) Networks() Networks

+ func (e *Engine) RefreshNetworks() error

+ func (e *Engine) RefreshVolumes() error

+ func (e *Engine) RemoveNetwork(network *Network) error

+ func (e *Engine) RemoveVolume(name string) error

+ func (e *Engine) TagImage(IDOrName string, repo string, tag string, force bool) error

+ func (e *Engine) Volumes() []*Volume

+ type ImageFilterOptions struct

+ All bool

+ Filters dockerfilters.Args

+ NameFilter string

+ type Images []*Image

+ func (images Images) Filter(opts ImageFilterOptions) Images

+ type Network struct

+ Engine *Engine

+ type Networks []*Network

+ func (networks Networks) Filter(names []string, ids []string) Networks

+ func (networks Networks) Get(IDOrName string) *Network

+ func (networks Networks) Uniq() Networks

+ type Volume struct

+ Engine *Engine

Aug 7, 2015

Changes in this version

type Cluster

+ BuildImage func(*dockerclient.BuildImage, io.Writer) error

type ContainerConfig

+ func (c *ContainerConfig) AddAffinity(affinity string) error

type Engine

+ func (e *Engine) BuildImage(buildImage *dockerclient.BuildImage) (io.ReadCloser, error)

Jun 16, 2015

Changes in this version

+ const SwarmLabelNamespace

type Cluster

+ Import func(source string, repository string, tag string, imageReader io.Reader, ...)

+ Load func(imageReader io.Reader, callback func(what, status string))

+ RANDOMENGINE func() (*Engine, error)

+ RegisterEventHandler func(h EventHandler) error

+ RemoveImages func(name string) ([]*dockerclient.ImageDelete, error)

+ RenameContainer func(container *Container, newName string) error

+ TotalCpus func() int64

+ TotalMemory func() int64

type Container

+ Config *ContainerConfig

+ Engine *Engine

+ func (c *Container) Refresh() error

+ type ContainerConfig struct

+ func BuildContainerConfig(c dockerclient.ContainerConfig) *ContainerConfig

+ func (c *ContainerConfig) Affinities() []string

+ func (c *ContainerConfig) Constraints() []string

+ func (c *ContainerConfig) SetSwarmID(id string)

+ func (c *ContainerConfig) SwarmID() string

+ type Containers []*Container

+ func (containers Containers) Get(IDOrName string) *Container

+ type DriverOpts []string

+ func (do DriverOpts) Float(key, env string) (float64, bool)

+ func (do DriverOpts) IP(key, env string) (net.IP, bool)

+ func (do DriverOpts) Int(key, env string) (int64, bool)

+ func (do DriverOpts) String(key, env string) (string, bool)

+ func (do DriverOpts) Uint(key, env string) (uint64, bool)

+ type Engine struct

+ Addr string

+ Cpus int64

+ ID string

+ IP string

+ Labels map[string]string

+ Memory int64

+ Name string

+ func NewEngine(addr string, overcommitRatio float64) *Engine

+ func (e *Engine) AddContainer(container *Container) error

+ func (e *Engine) Connect(config *tls.Config) error

+ func (e *Engine) ConnectWithClient(client dockerclient.Client) error

+ func (e *Engine) Containers() Containers

+ func (e *Engine) Create(config *ContainerConfig, name string, pullImage bool) (*Container, error)

+ func (e *Engine) Disconnect()

+ func (e *Engine) Image(IDOrName string) *Image

+ func (e *Engine) Images() []*Image

+ func (e *Engine) Import(source string, repository string, tag string, imageReader io.Reader) error

+ func (e *Engine) IsHealthy() bool

+ func (e *Engine) Load(reader io.Reader) error

+ func (e *Engine) Pull(image string, authConfig *dockerclient.AuthConfig) error

+ func (e *Engine) RefreshContainers(full bool) error

+ func (e *Engine) RefreshImages() error

+ func (e *Engine) RegisterEventHandler(h EventHandler) error

+ func (e *Engine) RemoveContainer(container *Container, force bool) error

+ func (e *Engine) RemoveImage(image *Image, name string) ([]*dockerclient.ImageDelete, error)

+ func (e *Engine) RenameContainer(container *Container, newName string) error

+ func (e *Engine) String() string

+ func (e *Engine) TotalCpus() int64

+ func (e *Engine) TotalMemory() int64

+ func (e *Engine) UsedCpus() int64

+ func (e *Engine) UsedMemory() int64

+ type EngineSorter []*Engine

+ func (s EngineSorter) Len() int

+ func (s EngineSorter) Less(i, j int) bool

+ func (s EngineSorter) Swap(i, j int)

type Event

+ Engine *Engine

type Image

+ Engine *Engine

Apr 6, 2015

Changes in this version

+ func SerializeNode(node Node) string

type Cluster

+ CreateContainer func(config *dockerclient.ContainerConfig, name string) (*Container, error)

+ Image func(IDOrName string) *Image

+ Images func() []*Image

+ Info func() [][2]string

+ Pull func(name string, callback func(what, status string))

+ RemoveContainer func(container *Container, force bool) error

+ RemoveImage func(image *Image) ([]*dockerclient.ImageDelete, error)

+ type Image struct

+ Node Node

+ func (image *Image) Match(IDOrName string) bool

type Node

+ TotalCpus func() int64

+ TotalMemory func() int64

+ UsedCpus func() int64

+ UsedMemory func() int64

+ type NodeSorter []Node

+ func (s NodeSorter) Len() int

+ func (s NodeSorter) Less(i, j int) bool

+ func (s NodeSorter) Swap(i, j int)

+ type Options struct

+ Discovery string

+ Heartbeat int

+ OvercommitRatio float64

+ TLSConfig *tls.Config

Feb 25, 2015

Changes in this version

+ var ErrNodeAlreadyRegistered = errors.New("node was already added to the cluster")

+ var ErrNodeNotConnected = errors.New("node is not connected to docker's REST API")

+ type Cluster struct

+ func NewCluster(store *state.Store, tlsConfig *tls.Config, overcommitRatio float64) *Cluster

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

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

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

+ func (c *Cluster) DeployContainer(node *Node, config *dockerclient.ContainerConfig, name string) (*Container, error)

+ func (c *Cluster) DestroyContainer(container *Container, force bool) error

+ 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(entries []*discovery.Entry)

+ type Container struct

+ Info dockerclient.ContainerInfo

+ Node *Node

+ type Event struct

+ Node *Node

+ type EventHandler interface

+ Handle func(*Event) error

+ type Node struct

+ Addr string

+ Cpus int64

+ ID string

+ IP string

+ Labels map[string]string

+ Memory int64

+ Name string

+ func NewNode(addr string, overcommitRatio float64) *Node

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

+ func (n *Node) AddImage(image *dockerclient.Image)

+ func (n *Node) CleanupContainers()

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

+ func (n *Node) Container(IdOrName string) *Container

+ 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) Image(IdOrName string) *dockerclient.Image

+ func (n *Node) Images() []*dockerclient.Image

+ func (n *Node) IsConnected() bool

+ func (n *Node) IsHealthy() bool

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

+ func (n *Node) RefreshContainer(ID string, full bool) error

+ func (n *Node) RefreshContainers(full bool) error

+ func (n *Node) RefreshContainersAsync()

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

+ func (n *Node) ReservedCpus() int64

+ func (n *Node) ReservedMemory() int64

+ func (n *Node) String() string

+ func (n *Node) UsableCpus() int64

+ func (n *Node) UsableMemory() int64