virtualnodectrl

Documentation

Overview

Package virtualnodectrl contains VirtualNode Controller logic and some functions for managing NamespaceMap lifecycle. There are also some tests for VirtualNode Controller

Package virtualnodectrl contains VirtualNode Controller logic and some functions for managing NamespaceMap lifecycle. There are also some tests for VirtualNode Controller

Index

• func ForgeCondition(virtualNode *virtualkubeletv1alpha1.VirtualNode, vnConditions VnConditionMap)
• func GetCondition(virtualNode *virtualkubeletv1alpha1.VirtualNode, ...) *virtualkubeletv1alpha1.VirtualNodeCondition
• type DeletionRoutine
  • func RunDeletionRoutine(ctx context.Context, r *VirtualNodeReconciler) (*DeletionRoutine, error)
  • func (dr *DeletionRoutine) EnsureNodeAbsence(vn *virtualkubeletv1alpha1.VirtualNode) error
• type VirtualNodeReconciler
  • func NewVirtualNodeReconciler(ctx context.Context, cl client.Client, cll client.Client, clvk client.Client, ...) (*VirtualNodeReconciler, error)
  • func (r *VirtualNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VirtualNodeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VnCondition
• type VnConditionMap

Functions

func ForgeCondition

func ForgeCondition(
	virtualNode *virtualkubeletv1alpha1.VirtualNode,
	vnConditions VnConditionMap)

ForgeCondition forges a virtual node condition.

func GetCondition

func GetCondition(virtualNode *virtualkubeletv1alpha1.VirtualNode,
	condition virtualkubeletv1alpha1.VirtualNodeConditionType) *virtualkubeletv1alpha1.VirtualNodeCondition

GetCondition returns the condition of the virtual node.

Types

type DeletionRoutine

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

DeletionRoutine is responsible for deleting a virtual node.

func RunDeletionRoutine

func RunDeletionRoutine(ctx context.Context, r *VirtualNodeReconciler) (*DeletionRoutine, error)

RunDeletionRoutine starts the deletion routine.

func (*DeletionRoutine) EnsureNodeAbsence

func (dr *DeletionRoutine) EnsureNodeAbsence(vn *virtualkubeletv1alpha1.VirtualNode) error

EnsureNodeAbsence adds a virtual node to the deletion queue.

type VirtualNodeReconciler

type VirtualNodeReconciler struct {
	client.Client
	// Client used to list local pods
	ClientLocal client.Client
	// Client used to list virtual-kubelet pods
	ClientVK              client.Client
	Scheme                *runtime.Scheme
	HomeClusterIdentity   *discoveryv1alpha1.ClusterIdentity
	VirtualKubeletOptions *vkforge.VirtualKubeletOpts
	EventsRecorder        record.EventRecorder
	// contains filtered or unexported fields
}

VirtualNodeReconciler manage NamespaceMap lifecycle.

func NewVirtualNodeReconciler

func NewVirtualNodeReconciler(
	ctx context.Context,
	cl client.Client, cll client.Client, clvk client.Client,
	s *runtime.Scheme, er record.EventRecorder,
	hci *discoveryv1alpha1.ClusterIdentity, vko *vkforge.VirtualKubeletOpts,
) (*VirtualNodeReconciler, error)

NewVirtualNodeReconciler returns a new VirtualNodeReconciler.

func (*VirtualNodeReconciler) Reconcile

func (r *VirtualNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile manage NamespaceMaps associated with the virtual-node.

func (*VirtualNodeReconciler) SetupWithManager

func (r *VirtualNodeReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager register the VirtualNodeReconciler to the manager.

type VnCondition

type VnCondition struct {
	Status  virtualkubeletv1alpha1.VirtualNodeConditionStatusType
	Message string
}

VnCondition is a virtual node condition.

type VnConditionMap

type VnConditionMap map[virtualkubeletv1alpha1.VirtualNodeConditionType]VnCondition

VnConditionMap is a map of virtual node conditions.