Documentation
¶
Overview ¶
Package node provides utilities to create and update nodes
Index ¶
- func Create(client *client.Client, hostName string, ...) (*api.Node, error)
- func CreateOrUpdate(client *client.Client, hostname string, ...) (*api.Node, error)
- func IsNotSlaveAttributeLabel(key, value string) bool
- func IsSlaveAttributeLabel(key, value string) bool
- func IsUpToDate(n *api.Node, labels map[string]string) bool
- func NewRegistrator(client *client.Client, lookupNode LookupFunc) *clientRegistrator
- func SlaveAttributesToLabels(attrs []*mesos.Attribute) map[string]string
- func Update(client *client.Client, hostname string, ...) (n *api.Node, err error)
- type LookupFunc
- type Registrator
- type StatusUpdater
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Create ¶
func Create( client *client.Client, hostName string, slaveAttrLabels, annotations map[string]string, ) (*api.Node, error)
Create creates a new node api object with the given hostname, slave attribute labels and annotations
func CreateOrUpdate ¶
func CreateOrUpdate( client *client.Client, hostname string, slaveAttrLabels, annotations map[string]string, ) (*api.Node, error)
CreateOrUpdate creates a node api object or updates an existing one
func IsNotSlaveAttributeLabel ¶
IsNotSlaveAttributeLabel returns true iff the given label is not derived from a slave attribute
func IsSlaveAttributeLabel ¶
IsSlaveAttributeLabel returns true iff the given label is derived from a slave attribute
func IsUpToDate ¶
IsUpToDate returns true iff the node's slave labels match the given attributes labels
func NewRegistrator ¶
func NewRegistrator(client *client.Client, lookupNode LookupFunc) *clientRegistrator
func SlaveAttributesToLabels ¶
SlaveAttributesToLabels converts slave attributes into string key/value labels
func Update ¶
func Update( client *client.Client, hostname string, slaveAttrLabels, annotations map[string]string, ) (n *api.Node, err error)
Update updates an existing node api object by looking up the given hostname. The updated node merges the given slave attribute labels and annotations with the found api object.
Types ¶
type LookupFunc ¶
type Registrator ¶
type Registrator interface {
// Register checks whether the node is registered with the given labels. If it
// is not, it is created or updated on the apiserver. If an the node was up-to-date,
// false is returned.
Register(hostName string, labels map[string]string) (bool, error)
// Start the registration loop and return immediately.
Run(terminate <-chan struct{}) error
}
type StatusUpdater ¶
type StatusUpdater struct {
// contains filtered or unexported fields
}
func NewStatusUpdater ¶
func (*StatusUpdater) Run ¶
func (u *StatusUpdater) Run(terminate <-chan struct{}) error
Source Files