controller

Documentation

Overview

Definitions for the Kubernetes Controllers

Definitions for the multicluster Kubernetes Controllers

Definitions for the Kubernetes Controllers

Index

• type MulticlusterTelemetryDeletionReconciler
• type MulticlusterTelemetryReconcileLoop
  • func NewMulticlusterTelemetryReconcileLoop(name string, cw multicluster.ClusterWatcher, options reconcile.Options) MulticlusterTelemetryReconcileLoop
• type MulticlusterTelemetryReconciler
• type MulticlusterTelemetryReconcilerFuncs
  • func (f *MulticlusterTelemetryReconcilerFuncs) ReconcileTelemetry(clusterName string, obj *telemetry_istio_io_v1alpha1.Telemetry) (reconcile.Result, error)
  • func (f *MulticlusterTelemetryReconcilerFuncs) ReconcileTelemetryDeletion(clusterName string, req reconcile.Request) error
• type TelemetryDeletionReconciler
• type TelemetryEventHandler
• type TelemetryEventHandlerFuncs
  • func (f *TelemetryEventHandlerFuncs) CreateTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error
  • func (f *TelemetryEventHandlerFuncs) DeleteTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error
  • func (f *TelemetryEventHandlerFuncs) GenericTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error
  • func (f *TelemetryEventHandlerFuncs) UpdateTelemetry(objOld, objNew *telemetry_istio_io_v1alpha1.Telemetry) error
• type TelemetryEventWatcher
  • func NewTelemetryEventWatcher(name string, mgr manager.Manager) TelemetryEventWatcher
• type TelemetryFinalizer
• type TelemetryReconcileLoop
  • func NewTelemetryReconcileLoop(name string, mgr manager.Manager, options reconcile.Options) TelemetryReconcileLoop
• type TelemetryReconciler
• type TelemetryReconcilerFuncs
  • func (f *TelemetryReconcilerFuncs) ReconcileTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) (reconcile.Result, error)
  • func (f *TelemetryReconcilerFuncs) ReconcileTelemetryDeletion(req reconcile.Request) error

Types

type MulticlusterTelemetryDeletionReconciler

type MulticlusterTelemetryDeletionReconciler interface {
	ReconcileTelemetryDeletion(clusterName string, req reconcile.Request) error
}

Reconcile deletion events for the Telemetry Resource across clusters. Deletion receives a reconcile.Request as we cannot guarantee the last state of the object before being deleted. implemented by the user

type MulticlusterTelemetryReconcileLoop

type MulticlusterTelemetryReconcileLoop interface {
	// AddMulticlusterTelemetryReconciler adds a MulticlusterTelemetryReconciler to the MulticlusterTelemetryReconcileLoop.
	AddMulticlusterTelemetryReconciler(ctx context.Context, rec MulticlusterTelemetryReconciler, predicates ...predicate.Predicate)
}

func NewMulticlusterTelemetryReconcileLoop

func NewMulticlusterTelemetryReconcileLoop(name string, cw multicluster.ClusterWatcher, options reconcile.Options) MulticlusterTelemetryReconcileLoop

type MulticlusterTelemetryReconciler

type MulticlusterTelemetryReconciler interface {
	ReconcileTelemetry(clusterName string, obj *telemetry_istio_io_v1alpha1.Telemetry) (reconcile.Result, error)
}

Reconcile Upsert events for the Telemetry Resource across clusters. implemented by the user

type MulticlusterTelemetryReconcilerFuncs

type MulticlusterTelemetryReconcilerFuncs struct {
	OnReconcileTelemetry         func(clusterName string, obj *telemetry_istio_io_v1alpha1.Telemetry) (reconcile.Result, error)
	OnReconcileTelemetryDeletion func(clusterName string, req reconcile.Request) error
}

func (*MulticlusterTelemetryReconcilerFuncs) ReconcileTelemetry

func (f *MulticlusterTelemetryReconcilerFuncs) ReconcileTelemetry(clusterName string, obj *telemetry_istio_io_v1alpha1.Telemetry) (reconcile.Result, error)

func (*MulticlusterTelemetryReconcilerFuncs) ReconcileTelemetryDeletion

func (f *MulticlusterTelemetryReconcilerFuncs) ReconcileTelemetryDeletion(clusterName string, req reconcile.Request) error

type TelemetryDeletionReconciler

type TelemetryDeletionReconciler interface {
	ReconcileTelemetryDeletion(req reconcile.Request) error
}

Reconcile deletion events for the Telemetry Resource. Deletion receives a reconcile.Request as we cannot guarantee the last state of the object before being deleted. implemented by the user

type TelemetryEventHandler

type TelemetryEventHandler interface {
	CreateTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error
	UpdateTelemetry(old, new *telemetry_istio_io_v1alpha1.Telemetry) error
	DeleteTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error
	GenericTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error
}

Handle events for the Telemetry Resource DEPRECATED: Prefer reconciler pattern.

type TelemetryEventHandlerFuncs

type TelemetryEventHandlerFuncs struct {
	OnCreate  func(obj *telemetry_istio_io_v1alpha1.Telemetry) error
	OnUpdate  func(old, new *telemetry_istio_io_v1alpha1.Telemetry) error
	OnDelete  func(obj *telemetry_istio_io_v1alpha1.Telemetry) error
	OnGeneric func(obj *telemetry_istio_io_v1alpha1.Telemetry) error
}

func (*TelemetryEventHandlerFuncs) CreateTelemetry

func (f *TelemetryEventHandlerFuncs) CreateTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error

func (*TelemetryEventHandlerFuncs) DeleteTelemetry

func (f *TelemetryEventHandlerFuncs) DeleteTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error

func (*TelemetryEventHandlerFuncs) GenericTelemetry

func (f *TelemetryEventHandlerFuncs) GenericTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error

func (*TelemetryEventHandlerFuncs) UpdateTelemetry

func (f *TelemetryEventHandlerFuncs) UpdateTelemetry(objOld, objNew *telemetry_istio_io_v1alpha1.Telemetry) error

type TelemetryEventWatcher

type TelemetryEventWatcher interface {
	AddEventHandler(ctx context.Context, h TelemetryEventHandler, predicates ...predicate.Predicate) error
}

func NewTelemetryEventWatcher

func NewTelemetryEventWatcher(name string, mgr manager.Manager) TelemetryEventWatcher

type TelemetryFinalizer

type TelemetryFinalizer interface {
	TelemetryReconciler

	// name of the finalizer used by this handler.
	// finalizer names should be unique for a single task
	TelemetryFinalizerName() string

	// finalize the object before it is deleted.
	// Watchers created with a finalizing handler will a
	FinalizeTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) error
}

Reconcile and finalize the Telemetry Resource implemented by the user

type TelemetryReconcileLoop

type TelemetryReconcileLoop interface {
	RunTelemetryReconciler(ctx context.Context, rec TelemetryReconciler, predicates ...predicate.Predicate) error
}

func NewTelemetryReconcileLoop

func NewTelemetryReconcileLoop(name string, mgr manager.Manager, options reconcile.Options) TelemetryReconcileLoop

type TelemetryReconciler

type TelemetryReconciler interface {
	ReconcileTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) (reconcile.Result, error)
}

Reconcile Upsert events for the Telemetry Resource. implemented by the user

type TelemetryReconcilerFuncs

type TelemetryReconcilerFuncs struct {
	OnReconcileTelemetry         func(obj *telemetry_istio_io_v1alpha1.Telemetry) (reconcile.Result, error)
	OnReconcileTelemetryDeletion func(req reconcile.Request) error
}

func (*TelemetryReconcilerFuncs) ReconcileTelemetry

func (f *TelemetryReconcilerFuncs) ReconcileTelemetry(obj *telemetry_istio_io_v1alpha1.Telemetry) (reconcile.Result, error)

func (*TelemetryReconcilerFuncs) ReconcileTelemetryDeletion

func (f *TelemetryReconcilerFuncs) ReconcileTelemetryDeletion(req reconcile.Request) error