node

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
  • func NewStatusUpdater(client *client.Client, relistPeriod time.Duration, nowFunc func() time.Time) *StatusUpdater
  • func (u *StatusUpdater) Run(terminate <-chan struct{}) error

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

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

func (*StatusUpdater) Run

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