package node

import "k8s.io/kubernetes/contrib/mesos/pkg/node"

Package node provides utilities to create and update nodes

Index ¶

• func Create( client unversionedcore.NodesGetter, hostName string, slaveAttrLabels, annotations map[string]string, ) (*api.Node, error)
• func CreateOrUpdate( client unversionedcore.NodesGetter, hostname string, slaveAttrLabels, annotations map[string]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 unversionedcore.NodesGetter, lookupNode LookupFunc) *clientRegistrator
• func SlaveAttributesToLabels(attrs []*mesos.Attribute) map[string]string
• func Update( client unversionedcore.NodesGetter, hostname string, slaveAttrLabels, annotations map[string]string, ) (n *api.Node, err error)
• type LookupFunc
• type Registrator
• type StatusUpdater
• func NewStatusUpdater(client *clientset.Clientset, relistPeriod time.Duration, nowFunc func() time.Time) *StatusUpdater
• func (u *StatusUpdater) Run(terminate <-chan struct{}) error

Functions ¶

func Create ¶

func Create(
	client unversionedcore.NodesGetter,
	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 unversionedcore.NodesGetter,
	hostname string,
	slaveAttrLabels,
	annotations map[string]string,
) (*api.Node, error)

CreateOrUpdate creates a node api object or updates an existing one

func IsNotSlaveAttributeLabel ¶

func IsNotSlaveAttributeLabel(key, value string) bool

IsNotSlaveAttributeLabel returns true iff the given label is not derived from a slave attribute

func IsSlaveAttributeLabel ¶

func IsSlaveAttributeLabel(key, value string) bool

IsSlaveAttributeLabel returns true iff the given label is derived from a slave attribute

func IsUpToDate ¶

func IsUpToDate(n *api.Node, labels map[string]string) bool

IsUpToDate returns true iff the node's slave labels match the given attributes labels

func NewRegistrator ¶

func NewRegistrator(client unversionedcore.NodesGetter, lookupNode LookupFunc) *clientRegistrator

func SlaveAttributesToLabels ¶

func SlaveAttributesToLabels(attrs []*mesos.Attribute) map[string]string

SlaveAttributesToLabels converts slave attributes into string key/value labels

func Update ¶

func Update(
	client unversionedcore.NodesGetter,
	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 LookupFunc func(hostName string) *api.Node

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 NewStatusUpdater(client *clientset.Clientset, relistPeriod time.Duration, nowFunc func() time.Time) *StatusUpdater

func (*StatusUpdater) Run ¶

func (u *StatusUpdater) Run(terminate <-chan struct{}) error

Source Files ¶

doc.go node.go registrator.go statusupdater.go