Documentation ¶
Index ¶
Constants ¶
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") )
Variables ¶
This section is empty.
Functions ¶
func GetNodeInstanceID ¶
GetNodeInstanceID returns the EC2 instance ID of a node
Types ¶
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 CheckNodeForLeakedENIs(nodeName string) }
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, controllerVersion string, healthzHandler *rcHealthz.HealthzHandler) (Manager, error)
NewNodeManager returns a new node manager
type NodeUpdateStatus ¶
type NodeUpdateStatus string
NodeUpdateStatus represents the status of the Node on Update operation.
Click to show internal directories.
Click to hide internal directories.