nodewatch

Documentation

Overview

Package nodewatch implements Kubernetes node watcher.

Index

• type NodeWatcher
  • func NewNodeWatcher(client *kubernetes.Client, nodename string) *NodeWatcher
  • func (r *NodeWatcher) Get() (*corev1.Node, error)
  • func (r *NodeWatcher) Nodename() string
  • func (r *NodeWatcher) Watch(ctx context.Context) (<-chan struct{}, <-chan error, func(), error)

Types

type NodeWatcher

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

NodeWatcher defines a NodeWatcher-based node watcher.

func NewNodeWatcher

func NewNodeWatcher(client *kubernetes.Client, nodename string) *NodeWatcher

NewNodeWatcher creates new Kubernetes node watcher.

func (*NodeWatcher) Get

func (r *NodeWatcher) Get() (*corev1.Node, error)

Get returns the Node resource.

func (*NodeWatcher) Nodename

func (r *NodeWatcher) Nodename() string

Nodename returns the watched nodename.

func (*NodeWatcher) Watch

func (r *NodeWatcher) Watch(ctx context.Context) (<-chan struct{}, <-chan error, func(), error)

Watch starts watching Node state and notifies on updates via notify channel.