reconcilers

package

v1.4.0 Latest Latest Go to latest Published: Nov 25, 2025 License: AGPL-3.0 Imports: 40 Imported by: 0

Documentation ¶

Index ¶

type ContainerOptions
type ManagementResourceReconciler
type PodDisruptionBudgetMode
type PodDisruptionBudgetType
type PodOptions
type WorkloadResourceReconciler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ContainerOptions ¶

type ContainerOptions struct {
	Root                    bool
	ReadWriteRootFilesystem bool
	Capabilities            []corev1.Capability
}

type ManagementResourceReconciler ¶

type ManagementResourceReconciler struct {
	Tracer                  string
	ManagementClusterClient *alias.ManagementClusterClient
	CiliumClient            ciliumclient.Interface
	WorldComponent          string
	ControllerNamespace     string
	ControllerComponent     string
}

func (*ManagementResourceReconciler) ReconcileConfigmap ¶

func (mr *ManagementResourceReconciler) ReconcileConfigmap(
	ctx context.Context,
	hostedControlPlane *v1alpha1.HostedControlPlane,
	cluster *capiv2.Cluster,
	component string,
	namespace string,
	name string,
	data map[string]string,
) error

func (*ManagementResourceReconciler) ReconcileDeployment ¶

func (mr *ManagementResourceReconciler) ReconcileDeployment(
	ctx context.Context,
	hostedControlPlane *v1alpha1.HostedControlPlane,
	cluster *capiv2.Cluster,
	replicas int32,
	priorityClassName string,
	component string,
	ingressPolicyTargets map[int32][]networkpolicy.IngressNetworkPolicyTarget,
	egressPolicyTargets map[int32][]networkpolicy.EgressNetworkPolicyTarget,
	targetComponent string,
	initContainers []slices.Tuple2[*corev1ac.ContainerApplyConfiguration, ContainerOptions],
	containers []slices.Tuple2[*corev1ac.ContainerApplyConfiguration, ContainerOptions],
	volumes []*corev1ac.VolumeApplyConfiguration,
) (*appsv1.Deployment, bool, error)

func (*ManagementResourceReconciler) ReconcileSecret ¶

func (mr *ManagementResourceReconciler) ReconcileSecret(
	ctx context.Context,
	hostedControlPlane *v1alpha1.HostedControlPlane,
	cluster *capiv2.Cluster,
	component string,
	namespace string,
	name string,
	deleteResource bool,
	data map[string][]byte,
) error

func (*ManagementResourceReconciler) ReconcileService ¶

func (mr *ManagementResourceReconciler) ReconcileService(
	ctx context.Context,
	hostedControlPlane *v1alpha1.HostedControlPlane,
	cluster *capiv2.Cluster,
	namespace string,
	name string,
	serviceType corev1.ServiceType,
	headless bool,
	component string,
	ports []*corev1ac.ServicePortApplyConfiguration,
) (*corev1.Service, bool, error)

func (*ManagementResourceReconciler) ReconcileStatefulset ¶

func (mr *ManagementResourceReconciler) ReconcileStatefulset(
	ctx context.Context,
	hostedControlPlane *v1alpha1.HostedControlPlane,
	cluster *capiv2.Cluster,
	name string,
	namespace string,
	podOptions PodOptions,
	serviceName string,
	podManagementPolicy appsv1.PodManagementPolicyType,
	updateStrategy *appsv1ac.StatefulSetUpdateStrategyApplyConfiguration,
	component string,
	ingressPolicyTargets map[int32][]networkpolicy.IngressNetworkPolicyTarget,
	egressPolicyTargets map[int32][]networkpolicy.EgressNetworkPolicyTarget,
	replicas int32,
	containers []slices.Tuple2[*corev1ac.ContainerApplyConfiguration, ContainerOptions],
	volumes []*corev1ac.VolumeApplyConfiguration,
	volumeClaimTemplates []*corev1ac.PersistentVolumeClaimApplyConfiguration,
	volumeClaimRetentionPolicy *appsv1ac.StatefulSetPersistentVolumeClaimRetentionPolicyApplyConfiguration,
) (*appsv1.StatefulSet, bool, error)

type PodDisruptionBudgetMode ¶ added in v1.1.0

type PodDisruptionBudgetMode struct {
	Type  PodDisruptionBudgetType
	Value int32
}

type PodDisruptionBudgetType ¶ added in v1.1.0

type PodDisruptionBudgetType = string

var (
	PodDisruptionBudgetTypeMinAvailable   PodDisruptionBudgetType = "MinAvailable"
	PodDisruptionBudgetTypeMaxUnavailable PodDisruptionBudgetType = "MaxUnavailable"
)

type PodOptions ¶

type PodOptions struct {
	ServiceAccountName string
	DNSPolicy          corev1.DNSPolicy
	HostNetwork        bool
	Annotations        map[string]string
	PriorityClassName  string
	Affinity           *corev1ac.AffinityApplyConfiguration
	Tolerations        []*corev1ac.TolerationApplyConfiguration
}

type WorkloadResourceReconciler ¶

type WorkloadResourceReconciler struct {
	Tracer                string
	WorkloadClusterClient *alias.WorkloadClusterClient
	CiliumClient          ciliumclient.Interface
}

func (*WorkloadResourceReconciler) ReconcileConfigmap ¶

func (wr *WorkloadResourceReconciler) ReconcileConfigmap(
	ctx context.Context,
	namespace string,
	name string,
	deleteResource bool,
	labels map[string]string,
	data map[string]string,
) error

func (*WorkloadResourceReconciler) ReconcileDaemonSet ¶

func (wr *WorkloadResourceReconciler) ReconcileDaemonSet(
	ctx context.Context,
	namespace string,
	name string,
	deleteResource bool,
	podOptions PodOptions,
	labels map[string]string,
	ingressPolicyTargets map[int32][]networkpolicy.IngressNetworkPolicyTarget,
	egressPolicyTargets map[int32][]networkpolicy.EgressNetworkPolicyTarget,
	containers []slices.Tuple2[*corev1ac.ContainerApplyConfiguration, ContainerOptions],
	volumes []*corev1ac.VolumeApplyConfiguration,
) (*appsv1.DaemonSet, bool, error)

func (*WorkloadResourceReconciler) ReconcileDeployment ¶

func (wr *WorkloadResourceReconciler) ReconcileDeployment(
	ctx context.Context,
	namespace string,
	name string,
	deleteResource bool,
	replicas int32,
	podOptions PodOptions,
	labels map[string]string,
	ingressPolicyTargets map[int32][]networkpolicy.IngressNetworkPolicyTarget,
	egressPolicyTargets map[int32][]networkpolicy.EgressNetworkPolicyTarget,
	containers []slices.Tuple2[*corev1ac.ContainerApplyConfiguration, ContainerOptions],
	volumes []*corev1ac.VolumeApplyConfiguration,
) (*appsv1.Deployment, bool, error)

func (*WorkloadResourceReconciler) ReconcileService ¶

func (wr *WorkloadResourceReconciler) ReconcileService(
	ctx context.Context,
	namespace string,
	name string,
	labels map[string]string,
	serviceType corev1.ServiceType,
	serviceIP net.IP,
	headless bool,
	ports []*corev1ac.ServicePortApplyConfiguration,
) (*corev1.Service, bool, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
alias
apiserverresources
certificates
etcd_cluster
etcd_client
s3_client
infrastructure_cluster
kubeconfig
tlsroutes
workload
config
coredns
konnectivity
kubeproxy
rbac

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL