controller

Documentation

Index

• func SetupMetrics(ctx context.Context, c client.Client, logger logr.Logger) error
• type PDBReconciler
  • func (r *PDBReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PDBReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, ...) error
• type StatefulSetUpdater
  • func (u *StatefulSetUpdater) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (u *StatefulSetUpdater) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error
• type TTYWatcher
  • func NewTTYWatcher(client client.Client, logger logr.Logger, interval time.Duration, ...) *TTYWatcher
  • func (w *TTYWatcher) Start(ctx context.Context) error

Functions

func SetupMetrics

func SetupMetrics(ctx context.Context, c client.Client, logger logr.Logger) error

Types

type PDBReconciler

type PDBReconciler struct {
	Client client.Client
	Scheme *runtime.Scheme
}

func (*PDBReconciler) Reconcile

func (r *PDBReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PDBReconciler) SetupWithManager

func (r *PDBReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, ch chan event.TypedGenericEvent[*appsv1.StatefulSet]) error

SetupWithManager sets up the controller with the Manager.

type StatefulSetUpdater

type StatefulSetUpdater struct {
	Client    client.Client
	ClientSet kubernetes.Interface
	Scheme    *runtime.Scheme
}

StatefulSetUpdater reconciles a StatefulSet object

func (*StatefulSetUpdater) Reconcile

func (u *StatefulSetUpdater) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*StatefulSetUpdater) SetupWithManager

func (u *StatefulSetUpdater) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type TTYWatcher

type TTYWatcher struct {
	// contains filtered or unexported fields
}

func NewTTYWatcher

func NewTTYWatcher(client client.Client, logger logr.Logger, interval time.Duration, ch chan<- event.TypedGenericEvent[*appsv1.StatefulSet]) *TTYWatcher

func (*TTYWatcher) Start

func (w *TTYWatcher) Start(ctx context.Context) error