node

Documentation

Overview

Package node provides utilities to create and update nodes

Index

• func Create(client *client.Client, hostName string, labels map[string]string) (*api.Node, error)
• func CreateOrUpdate(client *client.Client, hostName string, labels map[string]string) (*api.Node, error)
• func IsSlaveAttributeLabel(l 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, n *api.Node, labels map[string]string) (*api.Node, error)
• type LookupFunc
• type Registrator

Functions

func Create

func Create(client *client.Client, hostName string, labels map[string]string) (*api.Node, error)

Create creates a new node api object with the given hostname and labels

func CreateOrUpdate

func CreateOrUpdate(client *client.Client, hostName string, labels map[string]string) (*api.Node, error)

CreateOrUpdate tries to create a node api object or updates an already existing one

func IsSlaveAttributeLabel

func IsSlaveAttributeLabel(l 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, n *api.Node, labels map[string]string) (*api.Node, error)

Update updates an existing node api object with new labels

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
}