cluster

package
v1.2.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 11, 2017 License: Apache-2.0, CC-BY-SA-4.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

View Source 
const SwarmLabelNamespace = "com.docker.swarm"

SwarmLabelNamespace defines the key prefix in all custom labels

Variables

This section is empty.

Functions

func ConsolidateResourceFields added in v1.2.1 

func ConsolidateResourceFields(c *OldContainerConfig)

ConsolidateResourceFields is a temporary fix to handle forward/backward compatibility between Docker <1.6 and >=1.7

func FullStateString added in v1.2.1 

func FullStateString(state *types.ContainerState) string

FullStateString returns human-readable description of the state

func IsConnectionError added in v1.2.6 

func IsConnectionError(err error) bool

IsConnectionError returns true when err is connection problem

func NewHTTPClientTimeout added in v1.2.4 

func NewHTTPClientTimeout(daemonURL string, tlsConfig *tls.Config, timeout time.Duration, setUserTimeout tcpFunc) (*http.Client, *url.URL, error)

NewHTTPClientTimeout is used to create the HTTP Client and URL

func ParseRepositoryTag added in v1.1.0 

func ParseRepositoryTag(repos string) (string, string)

ParseRepositoryTag gets a repos name and returns the right reposName + tag|digest The tag can be confusing because of a port in a repository name. 

Ex: localhost.localdomain:5000/samalba/hipache:latest
Digest ex: localhost:5000/foo/bar@sha256:bc8813ea7b3603864987522f02a76101c17ad122e1c46d790efc0fca78ca7bfb

func StateString added in v1.2.1 

func StateString(state *types.ContainerState) string

StateString returns a single string to describe state

Types

type Cluster 

type Cluster interface {
	// CreateContainer creates a container.
	CreateContainer(config *ContainerConfig, name string, authConfig *types.AuthConfig) (*Container, error)

	// RemoveContainer removes a container.
	RemoveContainer(container *Container, force, volumes bool) error

	// Images returns all images.
	Images() Images

	// Image returns one image matching `IDOrName`.
	Image(IDOrName string) *Image

	// RemoveImages removes images from the cluster.
	RemoveImages(name string, force bool) ([]types.ImageDeleteResponseItem, error)

	// Containers returns all containers.
	Containers() Containers

	// StartContainer starts a container.
	StartContainer(container *Container, hostConfig *dockerclient.HostConfig) error

	// Container returns the container matching `IDOrName`.
	// TODO: remove this method from the interface as we can use
	// cluster.Containers().Get(IDOrName).
	Container(IDOrName string) *Container

	// Networks returns all networks.
	Networks() Networks

	// CreateNetwork creates a network.
	CreateNetwork(name string, request *types.NetworkCreate) (*types.NetworkCreateResponse, error)

	// RemoveNetwork removes a network from the cluster.
	RemoveNetwork(network *Network) error

	// CreateVolume creates a volume.
	CreateVolume(request *volume.VolumesCreateBody) (*types.Volume, error)

	// Volumes returns all volumes.
	Volumes() Volumes

	// RemoveVolumes removes volumes from the cluster.
	RemoveVolumes(name string) (bool, error)

	// Pull images
	// `callback` can be called multiple time
	Pull(name string, authConfig *types.AuthConfig, callback func(msg JSONMessageWrapper))

	// Import image
	// `callback` can be called multiple time
	Import(source string, ref string, tag string, imageReader io.Reader, callback func(msg JSONMessageWrapper))

	// Load images
	// `callback` can be called multiple time
	Load(imageReader io.Reader, callback func(msg JSONMessageWrapper))

	// Info returns some info about the cluster, like nb of containers / images.
	// It is pretty open, so the implementation decides what to return.
	Info() [][2]string

	// TotalMemory returns the total memory of the cluster.
	TotalMemory() int64

	// TotalCpus returns the number of CPUs in the cluster.
	TotalCpus() int64

	// RegisterEventHandler registers an event handler for cluster-wide events.
	RegisterEventHandler(h EventHandler, q *watch.Queue) error

	// UnregisterEventHandler unregisters an event handler.
	UnregisterEventHandler(h EventHandler)

	// CloseWatchQueue closes the watchQueue when the manager shuts down.
	CloseWatchQueue()

	// FIXME: remove this method
	// RANDOMENGINE returns a random engine.
	RANDOMENGINE() (*Engine, error)

	// RenameContainer renames a container.
	RenameContainer(container *Container, newName string) error

	// BuildImage builds an image.
	BuildImage(io.Reader, *types.ImageBuildOptions, func(msg JSONMessageWrapper)) error

	// TagImage tags an image.
	TagImage(IDOrName string, ref string, force bool) error

	// RefreshEngine refreshes a single cluster engine.
	RefreshEngine(hostname string) error

	// RefreshEngines refreshes all engines in the cluster.
	RefreshEngines() error
}

Cluster is exported

type Container 

type Container struct {
	types.Container

	Config *ContainerConfig
	Info   types.ContainerJSON
	Engine *Engine
}

Container is exported

func (*Container) Refresh added in v0.3.0 

func (c *Container) Refresh() (*Container, error)

Refresh container

type ContainerConfig added in v0.3.0 

type ContainerConfig struct {
	container.Config
	HostConfig       container.HostConfig
	NetworkingConfig network.NetworkingConfig
}

ContainerConfig is exported TODO store affinities and constraints in their own fields

func BuildContainerConfig added in v0.3.0 

func BuildContainerConfig(c container.Config, h container.HostConfig, n network.NetworkingConfig) *ContainerConfig

BuildContainerConfig creates a cluster.ContainerConfig from a Config, HostConfig, and NetworkingConfig

func (*ContainerConfig) AddAffinity added in v0.4.0 

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

AddAffinity to config

func (*ContainerConfig) AddConstraint added in v1.1.3 

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

AddConstraint to config

func (*ContainerConfig) AddWhitelist added in v1.2.6 

func (c *ContainerConfig) AddWhitelist(whitelist string) error

AddWhitelist to config

func (*ContainerConfig) Affinities added in v0.3.0 

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

Affinities returns all the affinities from the ContainerConfig

func (*ContainerConfig) Constraints added in v0.3.0 

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

Constraints returns all the constraints from the ContainerConfig

func (*ContainerConfig) HasReschedulePolicy added in v1.1.0 

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

HasReschedulePolicy returns true if the specified policy is part of the config

func (*ContainerConfig) HaveNodeConstraint added in v1.0.0 

func (c *ContainerConfig) HaveNodeConstraint() bool

HaveNodeConstraint in config

func (*ContainerConfig) RemoveAffinity added in v1.1.0 

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

RemoveAffinity from config

func (*ContainerConfig) RemoveWhitelist added in v1.2.6 

func (c *ContainerConfig) RemoveWhitelist(whitelist string) error

RemoveWhitelist from config

func (*ContainerConfig) SetSwarmID added in v0.3.0 

func (c *ContainerConfig) SetSwarmID(id string)

SetSwarmID sets or overrides the Swarm ID in the Config.

func (*ContainerConfig) SwarmID added in v0.3.0 

func (c *ContainerConfig) SwarmID() string

SwarmID extracts the Swarm ID from the Config. May return an empty string if not set.

func (*ContainerConfig) Validate added in v1.1.0 

func (c *ContainerConfig) Validate() error

Validate returns an error if the config isn't valid

func (*ContainerConfig) Whitelists added in v1.2.6 

func (c *ContainerConfig) Whitelists() []string

Whitelists returns all the whitelists from the ContainerConfig

type Containers added in v0.3.0 

type Containers []*Container

Containers represents a list of containers

func (Containers) Get added in v0.3.0 

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

Get returns a container using its ID or Name

type DriverOpts added in v0.3.0 

type DriverOpts []string

DriverOpts are key=values options

func (DriverOpts) Bool added in v1.1.0 

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

Bool returns a boolean from the driver options

func (DriverOpts) Float added in v0.3.0 

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

Float returns a float64 from the driver options

func (DriverOpts) IP added in v0.3.0 

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

IP returns an IP address from the driver options

func (DriverOpts) Int added in v0.3.0 

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

Int returns an int64 from the driver options

func (DriverOpts) String added in v0.3.0 

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

String returns a string from the driver options

func (DriverOpts) Uint added in v0.3.0 

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

Uint returns an int64 from the driver options

type Engine added in v0.3.0 

type Engine struct {
	sync.RWMutex

	ID      string
	IP      string
	Addr    string
	Name    string
	Cpus    int64
	Memory  int64
	Labels  map[string]string
	Version string

	DeltaDuration time.Duration // swarm's systime - engine's systime
	// contains filtered or unexported fields
}

Engine represents a docker engine

func NewEngine added in v0.3.0 

func NewEngine(addr string, overcommitRatio float64, opts *EngineOpts) *Engine

NewEngine is exported

func (*Engine) AddContainer added in v0.3.0 

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

AddContainer injects a container into the internal state.

func (*Engine) AddNetwork added in v1.1.1 

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

AddNetwork adds a network to the internal engine state.

func (*Engine) BuildImage added in v0.4.0 

func (e *Engine) BuildImage(buildContext io.Reader, buildImage *types.ImageBuildOptions, callback func(msg JSONMessage)) error

BuildImage builds an image

func (*Engine) CheckConnectionErr added in v1.1.0 

func (e *Engine) CheckConnectionErr(err error)

CheckConnectionErr checks error from client response and adjusts engine healthy indicators

func (*Engine) Connect added in v0.3.0 

func (e *Engine) 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 (*Engine) ConnectWithClient added in v0.3.0 

func (e *Engine) ConnectWithClient(client dockerclient.Client, apiClient swarmclient.SwarmAPIClient) error

ConnectWithClient is exported

func (*Engine) Containers added in v0.3.0 

func (e *Engine) Containers() Containers

Containers returns all the containers in the engine.

func (*Engine) CreateContainer added in v1.2.4 

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

CreateContainer creates a new container

func (*Engine) CreateContainerExec added in v1.2.7 

func (e *Engine) CreateContainerExec(id string, config types.ExecConfig) (types.IDResponse, error)

CreateContainerExec creates a container exec

func (*Engine) CreateNetwork added in v1.0.0 

func (e *Engine) CreateNetwork(name string, request *types.NetworkCreate) (*types.NetworkCreateResponse, error)

CreateNetwork creates a network in the engine

func (*Engine) CreateVolume added in v1.0.0 

func (e *Engine) CreateVolume(request *volume.VolumesCreateBody) (*types.Volume, error)

CreateVolume creates a volume in the engine

func (*Engine) DeleteNetwork added in v1.1.1 

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

DeleteNetwork deletes a network from the internal engine state.

func (*Engine) Disconnect added in v0.3.0 

func (e *Engine) Disconnect()

Disconnect will stop all monitoring of the engine. The Engine object cannot be further used without reconnecting it first.

func (*Engine) EngineToContainerNode added in v1.2.7 

func (e *Engine) EngineToContainerNode() *types.ContainerNode

EngineToContainerNode constructs types.ContainerNode from engine

func (*Engine) ErrMsg added in v1.1.0 

func (e *Engine) ErrMsg() string

ErrMsg returns error message for the engine

func (*Engine) HTTPClientAndScheme added in v1.1.1 

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

HTTPClientAndScheme returns the underlying HTTPClient and the scheme used by the engine

func (*Engine) HandleIDConflict added in v1.1.0 

func (e *Engine) HandleIDConflict(otherAddr string)

HandleIDConflict handles ID duplicate with existing engine

func (*Engine) HealthIndicator added in v1.1.0 

func (e *Engine) HealthIndicator() int64

HealthIndicator returns degree of healthiness between 0 and 100. 0 means node is not healthy (unhealthy, pending), 100 means last connectivity was successful other values indicate recent failures but haven't moved engine out of healthy state

func (*Engine) Image added in v0.3.0 

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

Image returns the image with IDOrName in the engine

func (*Engine) Images added in v0.3.0 

func (e *Engine) Images() Images

Images returns all the images in the engine

func (*Engine) Import added in v0.3.0 

func (e *Engine) Import(source string, ref string, tag string, imageReader io.Reader, callback func(msg JSONMessage)) error

Import image

func (*Engine) InspectContainer added in v1.2.7 

func (e *Engine) InspectContainer(id string) (*types.ContainerJSON, error)

InspectContainer inspects a container

func (*Engine) IsHealthy added in v0.3.0 

func (e *Engine) IsHealthy() bool

IsHealthy returns true if the engine is healthy

func (*Engine) Load added in v0.3.0 

func (e *Engine) Load(reader io.Reader, callback func(msg JSONMessage)) error

Load an image on the engine

func (*Engine) NetworkDisconnect added in v1.2.6 

func (e *Engine) NetworkDisconnect(container *Container, network string, force bool) error

NetworkDisconnect disconnects a container from a network

func (*Engine) Networks added in v1.0.0 

func (e *Engine) Networks() Networks

Networks returns all the networks in the engine

func (*Engine) Pull added in v0.3.0 

func (e *Engine) Pull(image string, authConfig *types.AuthConfig, callback func(msg JSONMessage)) error

Pull an image on the engine

func (*Engine) RefreshContainers added in v0.3.0 

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

RefreshContainers will refresh the list and status of containers running on the engine. If `full` is true, each container will be inspected. FIXME: unexport this method after mesos scheduler stops using it directly

func (*Engine) RefreshEngine added in v1.2.6 

func (e *Engine) RefreshEngine(hostname string) error

RefreshEngine refreshes container records from an engine

func (*Engine) RefreshImages added in v0.3.0 

func (e *Engine) RefreshImages() error

RefreshImages refreshes the list of images on the engine.

func (*Engine) RefreshNetworks added in v1.0.0 

func (e *Engine) RefreshNetworks() error

RefreshNetworks refreshes the list of networks on the engine.

func (*Engine) RefreshVolumes added in v1.0.0 

func (e *Engine) RefreshVolumes() error

RefreshVolumes refreshes the list of volumes on the engine.

func (*Engine) RegisterEventHandler added in v0.3.0 

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

RegisterEventHandler registers an event handler.

func (*Engine) RemoveContainer added in v0.3.0 

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

RemoveContainer removes a container from the engine.

func (*Engine) RemoveImage added in v0.3.0 

func (e *Engine) RemoveImage(name string, force bool) ([]types.ImageDeleteResponseItem, error)

RemoveImage deletes an image from the engine.

func (*Engine) RemoveNetwork added in v1.0.0 

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

RemoveNetwork removes a network from the engine.

func (*Engine) RemoveVolume added in v1.0.0 

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

RemoveVolume deletes a volume from the engine.

func (*Engine) RenameContainer added in v0.3.0 

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

RenameContainer renames a container

func (*Engine) StartContainer added in v1.1.0 

func (e *Engine) StartContainer(container *Container, hostConfig *dockerclient.HostConfig) error

StartContainer starts a container

func (*Engine) StartMonitorEvents added in v1.1.0 

func (e *Engine) StartMonitorEvents()

StartMonitorEvents monitors events from the engine

func (*Engine) Status added in v1.0.1 

func (e *Engine) Status() string

Status returns the health status of the Engine: Healthy or Unhealthy

func (*Engine) String added in v0.3.0 

func (e *Engine) String() string

func (*Engine) TagImage added in v1.0.0 

func (e *Engine) TagImage(IDOrName string, ref string, force bool) error

TagImage tags an image

func (*Engine) TimeToValidate added in v1.1.0 

func (e *Engine) TimeToValidate() bool

TimeToValidate returns true if a pending node is up for validation

func (*Engine) TotalCpus added in v0.3.0 

func (e *Engine) TotalCpus() int64

TotalCpus returns the total cpus + overcommit

func (*Engine) TotalMemory added in v0.3.0 

func (e *Engine) TotalMemory() int64

TotalMemory returns the total memory + overcommit

func (*Engine) UpdateNetworkContainers added in v1.2.7 

func (e *Engine) UpdateNetworkContainers(containerID string, full bool) error

The containerID argument can be provided along with a full argument can be used to limit the update as it concerns only one container instead of doing it for all containers. The idea is that sometimes only things about one container may have changed, and we don't need to run the loop over all containers.

func (*Engine) UpdatedAt added in v1.1.0 

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

UpdatedAt returns the previous updatedAt time

func (*Engine) UsedCpus added in v0.3.0 

func (e *Engine) UsedCpus() int64

UsedCpus returns the sum of CPUs reserved by containers.

func (*Engine) UsedMemory added in v0.3.0 

func (e *Engine) UsedMemory() int64

UsedMemory returns the sum of memory reserved by containers.

func (*Engine) ValidationComplete added in v1.1.0 

func (e *Engine) ValidationComplete()

ValidationComplete transitions engine state from statePending to stateHealthy

func (*Engine) Volumes added in v1.0.0 

func (e *Engine) Volumes() Volumes

Volumes returns all the volumes in the engine

type EngineOpts added in v1.0.1 

type EngineOpts struct {
	RefreshMinInterval time.Duration
	RefreshMaxInterval time.Duration
	FailureRetry       int
}

EngineOpts represents the options for an engine

type EngineSorter added in v0.3.0 

type EngineSorter []*Engine

EngineSorter implements the Sort interface to sort Cluster.Engine. It is not guaranteed to be a stable sort.

func (EngineSorter) Len added in v0.3.0 

func (s EngineSorter) Len() int

Len returns the number of engines to be sorted.

func (EngineSorter) Less added in v0.3.0 

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

Less reports whether the engine with index i should sort before the engine with index j. Engines are sorted chronologically by name.

func (EngineSorter) Swap added in v0.3.0 

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

Swap exchanges the engine elements with indices i and j.

type Event 

type Event struct {
	events.Message
	Engine *Engine `json:"-"`
}

Event is exported

type EventHandler 

type EventHandler interface {
	Handle(*Event) error
}

EventHandler is exported

type EventHandlers added in v1.1.0 

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

EventHandlers is a map of EventHandler

func NewEventHandlers added in v1.1.0 

func NewEventHandlers() *EventHandlers

NewEventHandlers returns an EventHandlers

func (*EventHandlers) Handle added in v1.1.0 

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

Handle callbacks for the events

func (*EventHandlers) RegisterEventHandler added in v1.1.0 

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

RegisterEventHandler registers an event handler.

func (*EventHandlers) UnregisterEventHandler added in v1.1.0 

func (eh *EventHandlers) UnregisterEventHandler(h EventHandler)

UnregisterEventHandler unregisters a previously registered event handler.

type EventsMonitor added in v1.2.1 

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

EventsMonitor monitors events

func NewEventsMonitor added in v1.2.1 

func NewEventsMonitor(cli swarmclient.SwarmAPIClient, handler func(msg events.Message) error) *EventsMonitor

NewEventsMonitor returns an EventsMonitor

func (*EventsMonitor) Start added in v1.2.1 

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

Start starts the EventsMonitor

func (*EventsMonitor) Stop added in v1.2.1 

func (em *EventsMonitor) Stop()

Stop stops the EventsMonitor

type Image added in v0.2.0 

type Image struct {
	types.ImageSummary

	Engine *Engine
}

Image is exported

func (*Image) Match added in v0.2.0 

func (image *Image) Match(IDOrName string, matchTag bool) bool

Match is exported

type ImageFilterOptions added in v1.0.0 

type ImageFilterOptions struct {
	types.ImageListOptions
}

ImageFilterOptions is the set of filtering options supported by Images.Filter()

type Images added in v1.0.0 

type Images []*Image

Images is a collection of Image objects that can be filtered

func (Images) Filter added in v1.0.0 

func (images Images) Filter(opts ImageFilterOptions) Images

Filter returns a new sequence of Images filtered to only the images that matched the filtering parameters

type JSONError added in v1.2.7 

type JSONError struct {
	Code    int    `json:"code,omitempty"`
	Message string `json:"message,omitempty"`
}

JSONError represents a JSON Error

type JSONMessage added in v1.2.7 

type JSONMessage struct {
	Stream          string        `json:"stream,omitempty"`
	Status          string        `json:"status,omitempty"`
	Progress        *JSONProgress `json:"progressDetail,omitempty"`
	ProgressMessage string        `json:"progress,omitempty"` //deprecated
	ID              string        `json:"id,omitempty"`
	From            string        `json:"from,omitempty"`
	Time            int64         `json:"time,omitempty"`
	TimeNano        int64         `json:"timeNano,omitempty"`
	Error           *JSONError    `json:"errorDetail,omitempty"`
	ErrorMessage    string        `json:"error,omitempty"` //deprecated
	// Aux contains out-of-band data, such as digests for push signing.
	Aux *json.RawMessage `json:"aux,omitempty"`
}

JSONMessage represents a JSON-encoded message regarding the status of a stream

type JSONMessageWrapper added in v1.2.7 

type JSONMessageWrapper struct {
	Msg        JSONMessage
	EngineName string
	Err        error
	Success    bool
}

JSONMessageWrapper is used in callback functions for API calls that send back JSONMessages; this allows us to pass info around within Swarm classic.

type JSONProgress added in v1.2.7 

type JSONProgress struct {
	//terminalFd uintptr
	Current int64 `json:"current,omitempty"`
	Total   int64 `json:"total,omitempty"`
	Start   int64 `json:"start,omitempty"`
}

JSONProgress represents a JSON-encoded progress instance

type Network added in v1.0.0 

type Network struct {
	types.NetworkResource

	Engine *Engine
}

Network is exported

func (*Network) RemoveDuplicateEndpoints added in v1.2.0 

func (network *Network) RemoveDuplicateEndpoints() *Network

RemoveDuplicateEndpoints returns a copy of input network where duplicate container endpoints in the network are removed. See https://github.com/docker/swarm/issues/1969 This function should be disabled when the bug is fixed in Docker network

type Networks added in v1.0.0 

type Networks []*Network

Networks represents an array of networks

func (Networks) Filter added in v1.0.0 

func (networks Networks) Filter(filter filters.Args) Networks

Filter returns networks filtered by names, IDs, nodes, labels, etc.

func (Networks) Get added in v1.0.0 

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

Get returns a network using its ID or Name

func (Networks) Uniq added in v1.0.0 

func (networks Networks) Uniq() Networks

Uniq returns all uniq networks

type OldContainerConfig added in v1.2.1 

type OldContainerConfig struct {
	ContainerConfig
	Memory     int64
	MemorySwap int64
	CPUShares  int64  `json:"CpuShares"`
	CPUSet     string `json:"Cpuset"`
}

OldContainerConfig contains additional fields for backward compatibility This should be removed after we stop supporting API versions <= 1.8 TODO(nishanttotla): Remove this field

type Volume added in v1.0.0 

type Volume struct {
	types.Volume

	Engine *Engine
}

Volume is exported

type Volumes added in v1.1.0 

type Volumes []*Volume

Volumes represents an array of volumes

func (Volumes) Get added in v1.1.0 

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

Get returns a volume using its ID or Name

type Watchdog added in v1.1.0 

type Watchdog struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Watchdog listens to cluster events and handles container rescheduling

func NewWatchdog added in v1.1.0 

func NewWatchdog(cluster Cluster) *Watchdog

NewWatchdog creates a new watchdog

func (*Watchdog) Handle added in v1.1.0 

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

Handle handles cluster callbacks

Source Files

View all Source files

Directories

Path Synopsis
task

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.