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, vkConditions VkConditionMap) (update bool)
• func GetCondition(virtualNode *virtualkubeletv1alpha1.VirtualNode, ...) *virtualkubeletv1alpha1.VirtualNodeCondition
• func UpdateCondition(ctx context.Context, cl client.Client, ...) error
• type DeletionRoutine
  • func RunDeletionRoutine(ctx context.Context, r *VirtualNodeReconciler) (*DeletionRoutine, error)
  • func (dr *DeletionRoutine) EnsureNodeAbsence(vn *virtualkubeletv1alpha1.VirtualNode)
• type VirtualNodeReconciler
  • func NewVirtualNodeReconciler(ctx context.Context, cl client.Client, cll client.Client, s *runtime.Scheme, ...) (*VirtualNodeReconciler, error)
  • func (r *VirtualNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VirtualNodeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VkCondition
• type VkConditionMap

Functions

func ForgeCondition

func ForgeCondition(
	virtualNode *virtualkubeletv1alpha1.VirtualNode,
	vkConditions VkConditionMap) (update bool)

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.

func UpdateCondition

func UpdateCondition(ctx context.Context, cl client.Client,
	virtualNode *virtualkubeletv1alpha1.VirtualNode,
	vkConditions VkConditionMap,
) error

UpdateCondition updates 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)

EnsureNodeAbsence adds a virtual node to the deletion queue.

type VirtualNodeReconciler

type VirtualNodeReconciler struct {
	client.Client
	ClientLocal           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,
	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 VkCondition

type VkCondition struct {
	Status  virtualkubeletv1alpha1.VirtualNodeConditionStatusType
	Message string
}

VkCondition is a virtual node condition.

type VkConditionMap

type VkConditionMap map[virtualkubeletv1alpha1.VirtualNodeConditionType]VkCondition

VkConditionMap is a map of virtual node conditions.