controllers

Documentation

Index

• Constants
• func GetScc() *secv1.SecurityContextConstraints
• func ImageCreate(c client.Client) (bool, ctrl.Result)
• func ImageDelete(c client.Client) (bool, ctrl.Result)
• func IsOpenShift() (bool, error)
• type ImageGenerator
• type KataConfigOpenShiftReconciler
  • func (r *KataConfigOpenShiftReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KataConfigOpenShiftReconciler) SetupWithManager(mgr ctrl.Manager) error
• type McpEventHandler
  • func (eh *McpEventHandler) Create(event event.CreateEvent, queue workqueue.RateLimitingInterface)
  • func (eh *McpEventHandler) Delete(event event.DeleteEvent, queue workqueue.RateLimitingInterface)
  • func (eh *McpEventHandler) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)
  • func (eh *McpEventHandler) Update(event event.UpdateEvent, queue workqueue.RateLimitingInterface)
• type NodeEventHandler
  • func (eh *NodeEventHandler) Create(event event.CreateEvent, queue workqueue.RateLimitingInterface)
  • func (eh *NodeEventHandler) Delete(event event.DeleteEvent, queue workqueue.RateLimitingInterface)
  • func (eh *NodeEventHandler) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)
  • func (eh *NodeEventHandler) Update(event event.UpdateEvent, queue workqueue.RateLimitingInterface)

Constants

const (
	// "Working"
	NodeWorking = mcfgconsts.MachineConfigDaemonStateWorking
	// "Done"
	NodeDone = mcfgconsts.MachineConfigDaemonStateDone
	// "Degraded"
	NodeDegraded = mcfgconsts.MachineConfigDaemonStateDegraded
)

const (
	DEFAULT_PEER_PODS = "10"
)

Functions

func GetScc

func GetScc() *secv1.SecurityContextConstraints

func ImageCreate

func ImageCreate(c client.Client) (bool, ctrl.Result)

ImageCreate creates a podvm image for a cloud provider if not present

func ImageDelete

func ImageDelete(c client.Client) (bool, ctrl.Result)

ImageDelete deletes a podvm image for a cloud provider if present

func IsOpenShift

func IsOpenShift() (bool, error)

IsOpenShift detects if we are running in OpenShift using the discovery client

Types

type ImageGenerator

type ImageGenerator struct {
	CMimageIDKey string
	// contains filtered or unexported fields
}

type KataConfigOpenShiftReconciler

type KataConfigOpenShiftReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

KataConfigOpenShiftReconciler reconciles a KataConfig object

func (*KataConfigOpenShiftReconciler) Reconcile

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

func (*KataConfigOpenShiftReconciler) SetupWithManager

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

type McpEventHandler

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

func (*McpEventHandler) Create

func (eh *McpEventHandler) Create(event event.CreateEvent, queue workqueue.RateLimitingInterface)

func (*McpEventHandler) Delete

func (eh *McpEventHandler) Delete(event event.DeleteEvent, queue workqueue.RateLimitingInterface)

func (*McpEventHandler) Generic

func (eh *McpEventHandler) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)

func (*McpEventHandler) Update

func (eh *McpEventHandler) Update(event event.UpdateEvent, queue workqueue.RateLimitingInterface)

type NodeEventHandler

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

func (*NodeEventHandler) Create

func (eh *NodeEventHandler) Create(event event.CreateEvent, queue workqueue.RateLimitingInterface)

func (*NodeEventHandler) Delete

func (eh *NodeEventHandler) Delete(event event.DeleteEvent, queue workqueue.RateLimitingInterface)

func (*NodeEventHandler) Generic

func (eh *NodeEventHandler) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)

func (*NodeEventHandler) Update

func (eh *NodeEventHandler) Update(event event.UpdateEvent, queue workqueue.RateLimitingInterface)