controllers

Documentation

Index

• Variables
• func CacheByObject() (map[client.Object]cache.ByObject, error)
• func MergeVolumeClaimVolumes(existing, pvcVolumes []corev1.Volume) []corev1.Volume
• type PodMutator
• type SandboxReconciler
  • func (r *SandboxReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SandboxReconciler) SetupWithManager(mgr ctrl.Manager, concurrentWorkers int) error

Variables

var Scheme = func() *runtime.Scheme {
	s := runtime.NewScheme()
	utilruntime.Must(clientgoscheme.AddToScheme(s))
	utilruntime.Must(sandboxv1alpha1.AddToScheme(s))
	utilruntime.Must(sandboxv1beta1.AddToScheme(s))
	return s
}()

Scheme registers the types sandbox controllers need on their client.

Functions

func CacheByObject

func CacheByObject() (map[client.Object]cache.ByObject, error)

CacheByObject scopes the manager cache to this controller's labeled children, so no child informer watches the whole cluster.

func MergeVolumeClaimVolumes

func MergeVolumeClaimVolumes(existing, pvcVolumes []corev1.Volume) []corev1.Volume

MergeVolumeClaimVolumes merges PVC-backed volumes into an existing volume list, replacing any volumes with matching names. This follows StatefulSet semantics where volumeClaimTemplate volumes take priority.

Types

type PodMutator

type PodMutator interface {
	MutatePod(context.Context, *sandboxv1beta1.Sandbox, *corev1.Pod) error
}

PodMutator applies runtime-specific defaults to a newly-created Sandbox Pod. Implementations must preserve every field explicitly supplied through the Sandbox API and return an error instead of silently overriding conflicts.

type SandboxReconciler

type SandboxReconciler struct {
	client.Client
	Scheme        *runtime.Scheme
	Tracer        asmetrics.Instrumenter
	ClusterDomain string
	PodMutator    PodMutator
}

SandboxReconciler reconciles a Sandbox object.

func (*SandboxReconciler) Reconcile

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

Reconcile drives a Sandbox toward its declared spec: child Service/Pod/PVCs, status conditions, and expiry.

func (*SandboxReconciler) SetupWithManager

func (r *SandboxReconciler) SetupWithManager(mgr ctrl.Manager, concurrentWorkers int) error

SetupWithManager sets up the controller with the Manager.