reconciling

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 29, 2023 License: Apache-2.0 Imports: 24 Imported by: 171

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultContainer 

func DefaultContainer(c *corev1.Container, procMountType *corev1.ProcMountType)

DefaultContainer defaults all Container attributes to the same values as they would get from the Kubernetes API.

func DefaultPodSpec 

func DefaultPodSpec(oldPodSpec, newPodSpec corev1.PodSpec) (corev1.PodSpec, error)

DefaultPodSpec defaults all Container attributes to the same values as they would get from the Kubernetes API. In addition, it sets default PodSpec values that KKP requires in all workloads, for example appropriate security settings. The following KKP-specific defaults are applied: - SecurityContext.SeccompProfile is set to be of type `RuntimeDefault` to enable seccomp isolation if not set.

func EnsureNamedObject 

func EnsureNamedObject(ctx context.Context, namespacedName types.NamespacedName, rawReconciler ObjectReconciler, client ctrlruntimeclient.Client, emptyObject ctrlruntimeclient.Object, requiresRecreate bool) error

EnsureNamedObject will generate the Object with the passed create function & create or update it in Kubernetes if necessary.

func ReconcileClusterRoleBindings 

func ReconcileClusterRoleBindings(ctx context.Context, namedFactories []NamedClusterRoleBindingReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileClusterRoleBindings will create and update the ClusterRoleBindings coming from the passed ClusterRoleBindingReconciler slice.

func ReconcileClusterRoles 

func ReconcileClusterRoles(ctx context.Context, namedFactories []NamedClusterRoleReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileClusterRoles will create and update the ClusterRoles coming from the passed ClusterRoleReconciler slice.

func ReconcileConfigMaps 

func ReconcileConfigMaps(ctx context.Context, namedFactories []NamedConfigMapReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileConfigMaps will create and update the ConfigMaps coming from the passed ConfigMapReconciler slice.

func ReconcileCronJobs 

func ReconcileCronJobs(ctx context.Context, namedFactories []NamedCronJobReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileCronJobs will create and update the CronJobs coming from the passed CronJobReconciler slice.

func ReconcileDaemonSets 

func ReconcileDaemonSets(ctx context.Context, namedFactories []NamedDaemonSetReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileDaemonSets will create and update the DaemonSets coming from the passed DaemonSetReconciler slice.

func ReconcileDeployments 

func ReconcileDeployments(ctx context.Context, namedFactories []NamedDeploymentReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileDeployments will create and update the Deployments coming from the passed DeploymentReconciler slice.

func ReconcileEndpointSlices 

func ReconcileEndpointSlices(ctx context.Context, namedFactories []NamedEndpointSliceReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileEndpointSlices will create and update the EndpointSlices coming from the passed EndpointSliceReconciler slice.

func ReconcileEndpoints 

func ReconcileEndpoints(ctx context.Context, namedFactories []NamedEndpointsReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileEndpoints will create and update the Endpoints coming from the passed EndpointsReconciler slice.

func ReconcileIngresses 

func ReconcileIngresses(ctx context.Context, namedFactories []NamedIngressReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileIngresses will create and update the Ingresses coming from the passed IngressReconciler slice.

func ReconcileJobs 

func ReconcileJobs(ctx context.Context, namedFactories []NamedJobReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileJobs will create and update the Jobs coming from the passed JobReconciler slice.

func ReconcileMutatingWebhookConfigurations 

func ReconcileMutatingWebhookConfigurations(ctx context.Context, namedFactories []NamedMutatingWebhookConfigurationReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileMutatingWebhookConfigurations will create and update the MutatingWebhookConfigurations coming from the passed MutatingWebhookConfigurationReconciler slice.

func ReconcileNamespaces 

func ReconcileNamespaces(ctx context.Context, namedFactories []NamedNamespaceReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileNamespaces will create and update the Namespaces coming from the passed NamespaceReconciler slice.

func ReconcileNetworkPolicies added in v0.2.0 

func ReconcileNetworkPolicies(ctx context.Context, namedFactories []NamedNetworkPolicyReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileNetworkPolicies will create and update the NetworkPolicies coming from the passed NetworkPolicyReconciler slice.

func ReconcilePodDisruptionBudgets 

func ReconcilePodDisruptionBudgets(ctx context.Context, namedFactories []NamedPodDisruptionBudgetReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcilePodDisruptionBudgets will create and update the PodDisruptionBudgets coming from the passed PodDisruptionBudgetReconciler slice.

func ReconcileRoleBindings 

func ReconcileRoleBindings(ctx context.Context, namedFactories []NamedRoleBindingReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileRoleBindings will create and update the RoleBindings coming from the passed RoleBindingReconciler slice.

func ReconcileRoles 

func ReconcileRoles(ctx context.Context, namedFactories []NamedRoleReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileRoles will create and update the Roles coming from the passed RoleReconciler slice.

func ReconcileSecrets 

func ReconcileSecrets(ctx context.Context, namedFactories []NamedSecretReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileSecrets will create and update the Secrets coming from the passed SecretReconciler slice.

func ReconcileServiceAccounts 

func ReconcileServiceAccounts(ctx context.Context, namedFactories []NamedServiceAccountReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileServiceAccounts will create and update the ServiceAccounts coming from the passed ServiceAccountReconciler slice.

func ReconcileServices 

func ReconcileServices(ctx context.Context, namedFactories []NamedServiceReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileServices will create and update the Services coming from the passed ServiceReconciler slice.

func ReconcileStatefulSets 

func ReconcileStatefulSets(ctx context.Context, namedFactories []NamedStatefulSetReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileStatefulSets will create and update the StatefulSets coming from the passed StatefulSetReconciler slice.

func ReconcileUnstructureds 

func ReconcileUnstructureds(ctx context.Context, namedFactories []NamedUnstructuredReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileUnstructureds will create and update the Unstructureds coming from the passed UnstructuredReconciler slice.

func ReconcileValidatingWebhookConfigurations 

func ReconcileValidatingWebhookConfigurations(ctx context.Context, namedFactories []NamedValidatingWebhookConfigurationReconcilerFactory, namespace string, client ctrlruntimeclient.Client, objectModifiers ...ObjectModifier) error

ReconcileValidatingWebhookConfigurations will create and update the ValidatingWebhookConfigurations coming from the passed ValidatingWebhookConfigurationReconciler slice.

func SetPauseAnnotation 

func SetPauseAnnotation(ann string)

func WaitUntilObjectExistsInCacheConditionFunc 

func WaitUntilObjectExistsInCacheConditionFunc(
	client ctrlruntimeclient.Client,
	log *zap.SugaredLogger,
	namespacedName types.NamespacedName,
	obj ctrlruntimeclient.Object,
) wait.ConditionWithContextFunc

Types

type ClusterRoleBindingReconciler 

type ClusterRoleBindingReconciler = func(existing *rbacv1.ClusterRoleBinding) (*rbacv1.ClusterRoleBinding, error)

ClusterRoleBindingReconciler defines an interface to create/update ClusterRoleBindings.

type ClusterRoleReconciler 

type ClusterRoleReconciler = func(existing *rbacv1.ClusterRole) (*rbacv1.ClusterRole, error)

ClusterRoleReconciler defines an interface to create/update ClusterRoles.

type ConfigMapReconciler 

type ConfigMapReconciler = func(existing *corev1.ConfigMap) (*corev1.ConfigMap, error)

ConfigMapReconciler defines an interface to create/update ConfigMaps.

type CronJobReconciler 

type CronJobReconciler = func(existing *batchv1.CronJob) (*batchv1.CronJob, error)

CronJobReconciler defines an interface to create/update CronJobs.

func DefaultCronJob 

func DefaultCronJob(reconciler CronJobReconciler) CronJobReconciler

DefaultCronJob defaults all CronJob attributes to the same values as they would get from the Kubernetes API. In addition, the CronJob's PodSpec template gets defaulted with KKP-specific values (see DefaultPodSpec for details).

type DaemonSetReconciler 

type DaemonSetReconciler = func(existing *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

DaemonSetReconciler defines an interface to create/update DaemonSets.

func DefaultDaemonSet 

func DefaultDaemonSet(reconciler DaemonSetReconciler) DaemonSetReconciler

DefaultDaemonSet defaults all DaemonSet attributes to the same values as they would get from the Kubernetes API. In addition, the DaemonSet's PodSpec template gets defaulted with KKP-specific values (see DefaultPodSpec for details).

type DeploymentReconciler 

type DeploymentReconciler = func(existing *appsv1.Deployment) (*appsv1.Deployment, error)

DeploymentReconciler defines an interface to create/update Deployments.

func DefaultDeployment 

func DefaultDeployment(reconciler DeploymentReconciler) DeploymentReconciler

DefaultDeployment defaults all Deployment attributes to the same values as they would get from the Kubernetes API. In addition, the Deployment's PodSpec template gets defaulted with KKP-specific values (see DefaultPodSpec for details).

type EndpointSliceReconciler 

type EndpointSliceReconciler = func(existing *discoveryv1.EndpointSlice) (*discoveryv1.EndpointSlice, error)

EndpointSliceReconciler defines an interface to create/update EndpointSlices.

type EndpointsReconciler 

type EndpointsReconciler = func(existing *corev1.Endpoints) (*corev1.Endpoints, error)

EndpointsReconciler defines an interface to create/update Endpoints.

type IngressReconciler 

type IngressReconciler = func(existing *networkingv1.Ingress) (*networkingv1.Ingress, error)

IngressReconciler defines an interface to create/update Ingresses.

type JobReconciler 

type JobReconciler = func(existing *batchv1.Job) (*batchv1.Job, error)

JobReconciler defines an interface to create/update Jobs.

type MutatingWebhookConfigurationReconciler 

type MutatingWebhookConfigurationReconciler = func(existing *admissionregistrationv1.MutatingWebhookConfiguration) (*admissionregistrationv1.MutatingWebhookConfiguration, error)

MutatingWebhookConfigurationReconciler defines an interface to create/update MutatingWebhookConfigurations.

type NamedClusterRoleBindingReconcilerFactory 

type NamedClusterRoleBindingReconcilerFactory = func() (name string, reconciler ClusterRoleBindingReconciler)

NamedClusterRoleBindingReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedClusterRoleReconcilerFactory 

type NamedClusterRoleReconcilerFactory = func() (name string, reconciler ClusterRoleReconciler)

NamedClusterRoleReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedConfigMapReconcilerFactory 

type NamedConfigMapReconcilerFactory = func() (name string, reconciler ConfigMapReconciler)

NamedConfigMapReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedCronJobReconcilerFactory 

type NamedCronJobReconcilerFactory = func() (name string, reconciler CronJobReconciler)

NamedCronJobReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedDaemonSetReconcilerFactory 

type NamedDaemonSetReconcilerFactory = func() (name string, reconciler DaemonSetReconciler)

NamedDaemonSetReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedDeploymentReconcilerFactory 

type NamedDeploymentReconcilerFactory = func() (name string, reconciler DeploymentReconciler)

NamedDeploymentReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedEndpointSliceReconcilerFactory 

type NamedEndpointSliceReconcilerFactory = func() (name string, reconciler EndpointSliceReconciler)

NamedEndpointSliceReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedEndpointsReconcilerFactory 

type NamedEndpointsReconcilerFactory = func() (name string, reconciler EndpointsReconciler)

NamedEndpointsReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedIngressReconcilerFactory 

type NamedIngressReconcilerFactory = func() (name string, reconciler IngressReconciler)

NamedIngressReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedJobReconcilerFactory 

type NamedJobReconcilerFactory = func() (name string, reconciler JobReconciler)

NamedJobReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedMutatingWebhookConfigurationReconcilerFactory 

type NamedMutatingWebhookConfigurationReconcilerFactory = func() (name string, reconciler MutatingWebhookConfigurationReconciler)

NamedMutatingWebhookConfigurationReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedNamespaceReconcilerFactory 

type NamedNamespaceReconcilerFactory = func() (name string, reconciler NamespaceReconciler)

NamedNamespaceReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedNetworkPolicyReconcilerFactory added in v0.2.0 

type NamedNetworkPolicyReconcilerFactory = func() (name string, reconciler NetworkPolicyReconciler)

NamedNetworkPolicyReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedPodDisruptionBudgetReconcilerFactory 

type NamedPodDisruptionBudgetReconcilerFactory = func() (name string, reconciler PodDisruptionBudgetReconciler)

NamedPodDisruptionBudgetReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedRoleBindingReconcilerFactory 

type NamedRoleBindingReconcilerFactory = func() (name string, reconciler RoleBindingReconciler)

NamedRoleBindingReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedRoleReconcilerFactory 

type NamedRoleReconcilerFactory = func() (name string, reconciler RoleReconciler)

NamedRoleReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedSecretReconcilerFactory 

type NamedSecretReconcilerFactory = func() (name string, reconciler SecretReconciler)

NamedSecretReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedServiceAccountReconcilerFactory 

type NamedServiceAccountReconcilerFactory = func() (name string, reconciler ServiceAccountReconciler)

NamedServiceAccountReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedServiceReconcilerFactory 

type NamedServiceReconcilerFactory = func() (name string, reconciler ServiceReconciler)

NamedServiceReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedStatefulSetReconcilerFactory 

type NamedStatefulSetReconcilerFactory = func() (name string, reconciler StatefulSetReconciler)

NamedStatefulSetReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamedUnstructuredReconcilerFactory 

type NamedUnstructuredReconcilerFactory = func() (name, kind, apiVersion string, create UnstructuredReconciler)

NamedUnstructuredReconcilerFactory returns the name of the resource and the corresponding reconciler function.

type NamedValidatingWebhookConfigurationReconcilerFactory 

type NamedValidatingWebhookConfigurationReconcilerFactory = func() (name string, reconciler ValidatingWebhookConfigurationReconciler)

NamedValidatingWebhookConfigurationReconcilerFactory returns the name of the resource and the corresponding Reconciler function.

type NamespaceReconciler 

type NamespaceReconciler = func(existing *corev1.Namespace) (*corev1.Namespace, error)

NamespaceReconciler defines an interface to create/update Namespaces.

type NetworkPolicyReconciler added in v0.2.0 

type NetworkPolicyReconciler = func(existing *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error)

NetworkPolicyReconciler defines an interface to create/update NetworkPolicies.

type ObjectModifier 

type ObjectModifier func(create ObjectReconciler) ObjectReconciler

ObjectModifier is a wrapper function which modifies the object which gets returned by the passed in ObjectReconciler.

func ImagePullSecretsWrapper 

func ImagePullSecretsWrapper(secretNames ...string) ObjectModifier

ImagePullSecretsWrapper is generating a new ObjectModifier that wraps an ObjectReconciler and takes care of adding the secret names provided to the ImagePullSecrets.

TODO At the moment only Deployments are supported, but this can be extended to whatever Object carrying a PodSpec.

func OwnerRefWrapper 

func OwnerRefWrapper(ref metav1.OwnerReference) ObjectModifier

OwnerRefWrapper is responsible for wrapping a ObjectReconciler function, solely to set the OwnerReference to the cluster object.

type ObjectReconciler 

type ObjectReconciler = func(existing ctrlruntimeclient.Object) (ctrlruntimeclient.Object, error)

ObjectReconciler defines an interface to create/update a ctrlruntimeclient.Object.

func ClusterRoleBindingObjectWrapper 

func ClusterRoleBindingObjectWrapper(reconciler ClusterRoleBindingReconciler) ObjectReconciler

ClusterRoleBindingObjectWrapper adds a wrapper so the ClusterRoleBindingReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func ClusterRoleObjectWrapper 

func ClusterRoleObjectWrapper(reconciler ClusterRoleReconciler) ObjectReconciler

ClusterRoleObjectWrapper adds a wrapper so the ClusterRoleReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func ConfigMapObjectWrapper 

func ConfigMapObjectWrapper(reconciler ConfigMapReconciler) ObjectReconciler

ConfigMapObjectWrapper adds a wrapper so the ConfigMapReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func CreateWithName 

func CreateWithName(reconciler ObjectReconciler, name string) ObjectReconciler

func CreateWithNamespace 

func CreateWithNamespace(reconciler ObjectReconciler, namespace string) ObjectReconciler

func CronJobObjectWrapper 

func CronJobObjectWrapper(reconciler CronJobReconciler) ObjectReconciler

CronJobObjectWrapper adds a wrapper so the CronJobReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func DaemonSetObjectWrapper 

func DaemonSetObjectWrapper(reconciler DaemonSetReconciler) ObjectReconciler

DaemonSetObjectWrapper adds a wrapper so the DaemonSetReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func DeploymentObjectWrapper 

func DeploymentObjectWrapper(reconciler DeploymentReconciler) ObjectReconciler

DeploymentObjectWrapper adds a wrapper so the DeploymentReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func EndpointSliceObjectWrapper 

func EndpointSliceObjectWrapper(reconciler EndpointSliceReconciler) ObjectReconciler

EndpointSliceObjectWrapper adds a wrapper so the EndpointSliceReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func EndpointsObjectWrapper 

func EndpointsObjectWrapper(reconciler EndpointsReconciler) ObjectReconciler

EndpointsObjectWrapper adds a wrapper so the EndpointsReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func IngressObjectWrapper 

func IngressObjectWrapper(reconciler IngressReconciler) ObjectReconciler

IngressObjectWrapper adds a wrapper so the IngressReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func JobObjectWrapper 

func JobObjectWrapper(reconciler JobReconciler) ObjectReconciler

JobObjectWrapper adds a wrapper so the JobReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func MutatingWebhookConfigurationObjectWrapper 

func MutatingWebhookConfigurationObjectWrapper(reconciler MutatingWebhookConfigurationReconciler) ObjectReconciler

MutatingWebhookConfigurationObjectWrapper adds a wrapper so the MutatingWebhookConfigurationReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func NamespaceObjectWrapper 

func NamespaceObjectWrapper(reconciler NamespaceReconciler) ObjectReconciler

NamespaceObjectWrapper adds a wrapper so the NamespaceReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func NetworkPolicyObjectWrapper added in v0.2.0 

func NetworkPolicyObjectWrapper(reconciler NetworkPolicyReconciler) ObjectReconciler

NetworkPolicyObjectWrapper adds a wrapper so the NetworkPolicyReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func PodDisruptionBudgetObjectWrapper 

func PodDisruptionBudgetObjectWrapper(reconciler PodDisruptionBudgetReconciler) ObjectReconciler

PodDisruptionBudgetObjectWrapper adds a wrapper so the PodDisruptionBudgetReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func RoleBindingObjectWrapper 

func RoleBindingObjectWrapper(reconciler RoleBindingReconciler) ObjectReconciler

RoleBindingObjectWrapper adds a wrapper so the RoleBindingReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func RoleObjectWrapper 

func RoleObjectWrapper(reconciler RoleReconciler) ObjectReconciler

RoleObjectWrapper adds a wrapper so the RoleReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func SecretObjectWrapper 

func SecretObjectWrapper(reconciler SecretReconciler) ObjectReconciler

SecretObjectWrapper adds a wrapper so the SecretReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func ServiceAccountObjectWrapper 

func ServiceAccountObjectWrapper(reconciler ServiceAccountReconciler) ObjectReconciler

ServiceAccountObjectWrapper adds a wrapper so the ServiceAccountReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func ServiceObjectWrapper 

func ServiceObjectWrapper(reconciler ServiceReconciler) ObjectReconciler

ServiceObjectWrapper adds a wrapper so the ServiceReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func StatefulSetObjectWrapper 

func StatefulSetObjectWrapper(reconciler StatefulSetReconciler) ObjectReconciler

StatefulSetObjectWrapper adds a wrapper so the StatefulSetReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func UnstructuredObjectWrapper 

func UnstructuredObjectWrapper(reconciler UnstructuredReconciler, emptyObject *unstructured.Unstructured) ObjectReconciler

UnstructuredObjectWrapper adds a wrapper so the UnstructuredReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

func ValidatingWebhookConfigurationObjectWrapper 

func ValidatingWebhookConfigurationObjectWrapper(reconciler ValidatingWebhookConfigurationReconciler) ObjectReconciler

ValidatingWebhookConfigurationObjectWrapper adds a wrapper so the ValidatingWebhookConfigurationReconciler matches ObjectReconciler. This is needed as Go does not support function interface matching.

type PodDisruptionBudgetReconciler 

type PodDisruptionBudgetReconciler = func(existing *policyv1.PodDisruptionBudget) (*policyv1.PodDisruptionBudget, error)

PodDisruptionBudgetReconciler defines an interface to create/update PodDisruptionBudgets.

type RoleBindingReconciler 

type RoleBindingReconciler = func(existing *rbacv1.RoleBinding) (*rbacv1.RoleBinding, error)

RoleBindingReconciler defines an interface to create/update RoleBindings.

type RoleReconciler 

type RoleReconciler = func(existing *rbacv1.Role) (*rbacv1.Role, error)

RoleReconciler defines an interface to create/update Roles.

type SecretReconciler 

type SecretReconciler = func(existing *corev1.Secret) (*corev1.Secret, error)

SecretReconciler defines an interface to create/update Secrets.

type ServiceAccountReconciler 

type ServiceAccountReconciler = func(existing *corev1.ServiceAccount) (*corev1.ServiceAccount, error)

ServiceAccountReconciler defines an interface to create/update ServiceAccounts.

type ServiceReconciler 

type ServiceReconciler = func(existing *corev1.Service) (*corev1.Service, error)

ServiceReconciler defines an interface to create/update Services.

type StatefulSetReconciler 

type StatefulSetReconciler = func(existing *appsv1.StatefulSet) (*appsv1.StatefulSet, error)

StatefulSetReconciler defines an interface to create/update StatefulSets.

func DefaultStatefulSet 

func DefaultStatefulSet(reconciler StatefulSetReconciler) StatefulSetReconciler

DefaultStatefulSet defaults all StatefulSet attributes to the same values as they would get from the Kubernetes API. In addition, the StatefulSet's PodSpec template gets defaulted with KKP-specific values (see DefaultPodSpec for details).

type UnstructuredReconciler 

type UnstructuredReconciler = func(existing *unstructured.Unstructured) (*unstructured.Unstructured, error)

UnstructuredReconciler defines an interface to create/update Unstructureds.

type ValidatingWebhookConfigurationReconciler 

type ValidatingWebhookConfigurationReconciler = func(existing *admissionregistrationv1.ValidatingWebhookConfiguration) (*admissionregistrationv1.ValidatingWebhookConfiguration, error)

ValidatingWebhookConfigurationReconciler defines an interface to create/update ValidatingWebhookConfigurations.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.