utils

Documentation

Index

• Variables
• func DefaultConfigMapEqual(cm1, cm2 *corev1.ConfigMap) bool
• type ConfigMapReconciler
  • func (r *ConfigMapReconciler) ReconcileConfigMap(ctx context.Context, obj runtime.Object, cm *corev1.ConfigMap, ...) (*corev1.ConfigMap, error)
• type DeploymentReconciler
  • func (r *DeploymentReconciler) ReconcileDeployment(ctx context.Context, obj runtime.Object, d *appsv1.Deployment) (*appsv1.Deployment, error)
• type ServiceReconciler
  • func (r *ServiceReconciler) ReconcileService(ctx context.Context, obj runtime.Object, svc *corev1.Service) (*corev1.Endpoints, error)

Variables

var BrokerClassFilter = reconciler.AnnotationFilterFunc(eventingv1.BrokerClassAnnotationKey, brokerv1.BrokerClass, false)

BrokerClassFilter is the function to filter brokers with proper brokerclass.

Functions

func DefaultConfigMapEqual

func DefaultConfigMapEqual(cm1, cm2 *corev1.ConfigMap) bool

DefaultConfigMapEqual is a basic equality testing function for K8s ConfigMaps based on string Data.

Types

type ConfigMapReconciler

type ConfigMapReconciler struct {
	KubeClient kubernetes.Interface
	Lister     corev1listers.ConfigMapLister
	Recorder   record.EventRecorder
}

func (*ConfigMapReconciler) ReconcileConfigMap

func (r *ConfigMapReconciler) ReconcileConfigMap(ctx context.Context, obj runtime.Object, cm *corev1.ConfigMap, eqFunc func(*corev1.ConfigMap, *corev1.ConfigMap) bool, handlers ...cache.ResourceEventHandlerFuncs) (*corev1.ConfigMap, error)

ReconcileConfigMap reconciles the K8s ConfigMap 'cm'.

type DeploymentReconciler

type DeploymentReconciler struct {
	KubeClient kubernetes.Interface
	Lister     appsv1listers.DeploymentLister
	Recorder   record.EventRecorder
}

func (*DeploymentReconciler) ReconcileDeployment

func (r *DeploymentReconciler) ReconcileDeployment(ctx context.Context, obj runtime.Object, d *appsv1.Deployment) (*appsv1.Deployment, error)

ReconcileDeployment reconciles the K8s Deployment 'd'.

type ServiceReconciler

type ServiceReconciler struct {
	KubeClient      kubernetes.Interface
	ServiceLister   corev1listers.ServiceLister
	EndpointsLister corev1listers.EndpointsLister
	Recorder        record.EventRecorder
}

func (*ServiceReconciler) ReconcileService

func (r *ServiceReconciler) ReconcileService(ctx context.Context, obj runtime.Object, svc *corev1.Service) (*corev1.Endpoints, error)

ReconcileService reconciles the K8s Service 'svc'.