node

Documentation

Index

• Constants
• type Client
  • func New(kube kubernetes.Interface) Client
• type Node
• type Taint

Constants

const (
	TaintEffectNoSchedule = v1.TaintEffectNoSchedule
	TaintEffectNoExecute  = v1.TaintEffectNoExecute
)

Types

type Client

type Client interface {
	// Run executes the EC2 API poller. It will update the instance cache
	// periodically.
	Run(context.Context) error

	// List returns all EC2 Instances that are currently in the cache. Those
	// instance cache will be updated in the background.
	List() []Node

	// SignalEmitter gets triggered every time the cache changes. See syncutil
	// package for more information.
	SignalEmitter() *syncutil.SignalEmitter

	// Healthy indicates whether the background job is running correctly.
	Healthy() bool

	Taint(context.Context, Node, string, v1.TaintEffect) error
}

func New

func New(kube kubernetes.Interface) Client

type Node

type Node struct {
	InstanceID    string  `logfield:"instance-id,omitempty"`
	NodeName      string  `logfield:"node-name,omitempty"`
	Unschedulable bool    `logfield:"node-unschedulable"`
	Taints        []Taint `logfield:"node-taints"`
}

type Taint

type Taint = v1.Taint