controllers

Documentation

Index

• Constants
• type HealthCheckReconciler
  • func NewHealthCheckReconciler(mgr manager.Manager, log logr.Logger, MaxParallel int) *HealthCheckReconciler
  • func (r *HealthCheckReconciler) ContainsEqualFoldSubstring(str, substr string) bool
  • func (r *HealthCheckReconciler) DeleteClusterRole(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, ...) error
  • func (r *HealthCheckReconciler) DeleteClusterRoleBinding(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, ...) error
  • func (r *HealthCheckReconciler) DeleteNameSpaceRole(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, ...) error
  • func (r *HealthCheckReconciler) DeleteNameSpaceRoleBinding(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, ...) error
  • func (r *HealthCheckReconciler) DeleteServiceAccount(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, ...) error
  • func (r *HealthCheckReconciler) GetTimerByName(name string) *time.Timer
  • func (r *HealthCheckReconciler) IsStorageError(err error) bool
  • func (r *HealthCheckReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *HealthCheckReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	WfInstanceIdLabelKey = "workflows.argoproj.io/controller-instanceid"
	WfInstanceId         = "activemonitor-workflows"
	PodGCOnPodCompletion = "OnPodCompletion"
	WfManagedByLabelKey  = "workflows.argoproj.io/managed-by"
	WfManagedByValue     = "active-monitor"
)

Types

type HealthCheckReconciler

type HealthCheckReconciler struct {
	client.Client
	DynClient dynamic.Interface
	Recorder  record.EventRecorder

	Log                logr.Logger
	MaxParallel        int
	RepeatTimersByName map[string]*time.Timer

	TimerLock sync.RWMutex
	// contains filtered or unexported fields
}

HealthCheckReconciler reconciles a HealthCheck object

func NewHealthCheckReconciler

func NewHealthCheckReconciler(mgr manager.Manager, log logr.Logger, MaxParallel int) *HealthCheckReconciler

NewHealthCheckReconciler returns an instance of HealthCheckReconciler

func (*HealthCheckReconciler) ContainsEqualFoldSubstring

func (r *HealthCheckReconciler) ContainsEqualFoldSubstring(str, substr string) bool

func (*HealthCheckReconciler) DeleteClusterRole

func (r *HealthCheckReconciler) DeleteClusterRole(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, hc *activemonitorv1alpha1.HealthCheck, clusterrole string) error

Delete a ClusterRole

func (*HealthCheckReconciler) DeleteClusterRoleBinding

func (r *HealthCheckReconciler) DeleteClusterRoleBinding(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, hc *activemonitorv1alpha1.HealthCheck, clusterrolebinding string, clusterrole string, serviceaccount string, namespace string) error

Delete ClusterRoleBinding

func (*HealthCheckReconciler) DeleteNameSpaceRole

func (r *HealthCheckReconciler) DeleteNameSpaceRole(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, hc *activemonitorv1alpha1.HealthCheck, nsrole string, namespace string) error

Delete NamespaceRole

func (*HealthCheckReconciler) DeleteNameSpaceRoleBinding

func (r *HealthCheckReconciler) DeleteNameSpaceRoleBinding(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, hc *activemonitorv1alpha1.HealthCheck, rolebinding string, nsrole string, serviceaccount string, namespace string) error

Delete NamespaceRoleBinding

func (*HealthCheckReconciler) DeleteServiceAccount

func (r *HealthCheckReconciler) DeleteServiceAccount(ctx context.Context, clientset kubernetes.Interface, log logr.Logger, hc *activemonitorv1alpha1.HealthCheck, name string, namespace string) error

Delete a service Account

func (*HealthCheckReconciler) GetTimerByName

func (r *HealthCheckReconciler) GetTimerByName(name string) *time.Timer

func (*HealthCheckReconciler) IsStorageError

func (r *HealthCheckReconciler) IsStorageError(err error) bool

func (*HealthCheckReconciler) Reconcile

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

Reconcile per kubebuilder v2 pattern

func (*HealthCheckReconciler) SetupWithManager

func (r *HealthCheckReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager as used in main package by kubebuilder v2.0.0.alpha4