k8s

Documentation

Index

• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) AddNodeLabels(nodeName string, labels map[string]string) error
  • func (c *Client) AddNodeResources(nodeName string, resources map[string]int) error
  • func (c *Client) RemoveNodeLabels(nodeName string, labels map[string]string) error
  • func (c *Client) RemoveNodeResources(nodeName string, resources map[string]int) error
• type Patch
• type WatchDog
  • func (w *WatchDog) CleanNode()
  • func (w *WatchDog) PatchNode(patch *Patch) error

Types

type Client

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

Client provides convenient API for interacting with k8s core API.

func NewClient

func NewClient() (*Client, error)

NewClient fetches k8s config and initializes core client based on it.

func (*Client) AddNodeLabels

func (c *Client) AddNodeLabels(nodeName string, labels map[string]string) error

AddNodeLabels adds passed labels to node labels.

func (*Client) AddNodeResources

func (c *Client) AddNodeResources(nodeName string, resources map[string]int) error

AddNodeResources adds passed resources to node capacity.

func (*Client) RemoveNodeLabels

func (c *Client) RemoveNodeLabels(nodeName string, labels map[string]string) error

RemoveNodeLabels removes nodes labels from node

func (*Client) RemoveNodeResources

func (c *Client) RemoveNodeResources(nodeName string, resources map[string]int) error

RemoveNodeResources removes passed resources from node capacity

type Patch

type Patch struct {
	NodeLabels    map[string]string `yaml:"labels"`
	NodeResources map[string]int    `yaml:"resources"`
}

Patch represents changes that need to be applied to the node.

type WatchDog

type WatchDog struct {
	NodeName       string
	NodeConfigPath string
	Client         *Client
	DefaultLabels  map[string]string
	// contains filtered or unexported fields
}

WatchDog is used to perform node patch and cleanup.

func (*WatchDog) CleanNode

func (w *WatchDog) CleanNode()

CleanNode reverts changes introduced with the latest PatchNode call.

func (*WatchDog) PatchNode

func (w *WatchDog) PatchNode(patch *Patch) error

PatchNode applies passed patch to the node WatchDog is configured to work with. PatchNode cleans up any patch applied before.