horizonsource

Documentation

Index

• func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl
• type DeploymentReconciler
  • func (r *DeploymentReconciler) FindOwned(ctx context.Context, owner kmeta.OwnerRefable, selector labels.Selector) (*appsv1.Deployment, error)
  • func (r *DeploymentReconciler) ReconcileDeployment(ctx context.Context, owner kmeta.OwnerRefable, expected *appsv1.Deployment) (*appsv1.Deployment, pkgreconciler.Event)
• type Reconciler
  • func (r *Reconciler) ReconcileKind(ctx context.Context, src *v1alpha1.HorizonSource) pkgreconciler.Event
  • func (r *Reconciler) UpdateFromLoggingConfigMap(cfg *corev1.ConfigMap)
  • func (r *Reconciler) UpdateFromMetricsConfigMap(cfg *corev1.ConfigMap)
• type ServiceAccountReconciler
  • func (s *ServiceAccountReconciler) ReconcileServiceAccount(ctx context.Context, src *v1alpha1.HorizonSource, labels map[string]string) (*corev1.ServiceAccount, pkgreconciler.Event)

Functions

func NewController

func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl

NewController initializes the controller and is called by the generated code Registers event handlers to enqueue events

Types

type DeploymentReconciler

type DeploymentReconciler struct {
	KubeClientSet kubernetes.Interface
}

func (*DeploymentReconciler) FindOwned

func (r *DeploymentReconciler) FindOwned(ctx context.Context, owner kmeta.OwnerRefable, selector labels.Selector) (*appsv1.Deployment, error)

func (*DeploymentReconciler) ReconcileDeployment

func (r *DeploymentReconciler) ReconcileDeployment(ctx context.Context, owner kmeta.OwnerRefable, expected *appsv1.Deployment) (*appsv1.Deployment, pkgreconciler.Event)

ReconcileDeployment reconciles deployment resource (adapter) for HorizonSource

type Reconciler

type Reconciler struct {
	ReceiveAdapterImage string `envconfig:"HORIZON_SOURCE_RA_IMAGE" required:"true"`
	// contains filtered or unexported fields
}

Reconciler reconciles a HorizonSource object

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, src *v1alpha1.HorizonSource) pkgreconciler.Event

ReconcileKind implements Interface.ReconcileKind.

func (*Reconciler) UpdateFromLoggingConfigMap

func (r *Reconciler) UpdateFromLoggingConfigMap(cfg *corev1.ConfigMap)

func (*Reconciler) UpdateFromMetricsConfigMap

func (r *Reconciler) UpdateFromMetricsConfigMap(cfg *corev1.ConfigMap)

type ServiceAccountReconciler

type ServiceAccountReconciler struct {
	KubeClientSet kubernetes.Interface
}

func (*ServiceAccountReconciler) ReconcileServiceAccount

func (s *ServiceAccountReconciler) ReconcileServiceAccount(ctx context.Context, src *v1alpha1.HorizonSource, labels map[string]string) (*corev1.ServiceAccount, pkgreconciler.Event)

ReconcileServiceAccount reconciles service account resource for HorizonSource