Version: v1.1.0 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Oct 5, 2021 License: Apache-2.0 Imports: 12 Imported by: 0




View Source
const (
	Init   = AsyncOperation("Init")
	Update = AsyncOperation("Update")
	Delete = AsyncOperation("Delete")
View Source
const (
	ManagedToUnManaged = NodeUpdateStatus("managedToUnManaged")
	UnManagedToManaged = NodeUpdateStatus("UnManagedToManaged")
	StillManaged       = NodeUpdateStatus("Managed")
	StillUnManaged     = NodeUpdateStatus("UnManaged")


This section is empty.


func GetNodeInstanceID

func GetNodeInstanceID(node *v1.Node) string

GetNodeInstanceID returns the EC2 instance ID of a node

func GetNodeOS

func GetNodeOS(node *v1.Node) string

getNodeOS returns the operating system of a node.


type AsyncOperation

type AsyncOperation string

AsyncOperation is operation on a node after the lock has been released. All AsyncOperation are done without lock as it involves API calls that will temporarily block the access to Manager in Pod Watcher. This is done to prevent Pod startup latency for already processed nodes.

type AsyncOperationJob

type AsyncOperationJob struct {
	// contains filtered or unexported fields

type Manager

type Manager interface {
	GetNode(nodeName string) (node node.Node, found bool)
	AddNode(nodeName string) error
	UpdateNode(nodeName string) error
	DeleteNode(nodeName string) error

Manager to perform operation on list of managed/un-managed node

func NewNodeManager

func NewNodeManager(logger logr.Logger, resourceManager resource.ResourceManager,
	wrapper api.Wrapper, worker asyncWorker.Worker, conditions condition.Conditions) (Manager, error)

NewNodeManager returns a new node manager

type NodeUpdateStatus

type NodeUpdateStatus string

NodeUpdateStatus represents the status of the Node on Update operation.

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL