controllers

Documentation

Index

• func DeletePodForUpdate(ctx context.Context, r *SolrCloudReconciler, instance *solrv1beta1.SolrCloud, ...) (requeueAfterDuration time.Duration, err error)
• func EnsurePodReadinessCondition(pod *corev1.Pod, conditionType corev1.PodConditionType, ...) (conditionNeedsChange bool)
• func EnsurePodReadinessConditions(ctx context.Context, r *SolrCloudReconciler, pod *corev1.Pod, ...) (updatedPod *corev1.Pod, err error)
• func InitializeCustomPodReadinessCondition(pod *corev1.Pod, conditionType corev1.PodConditionType, ...) (conditionNeedsInitializing bool)
• func InitializePodReadinessCondition(pod *corev1.Pod, conditionType corev1.PodConditionType) (conditionNeedsInitializing bool)
• func PodConditionEquals(pod *corev1.Pod, conditionType corev1.PodConditionType, ...) bool
• func UseZkCRD(useCRD bool)
• type PodConditionChangeReason
• type SolrBackupReconciler
  • func (r *SolrBackupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SolrBackupReconciler) SetupWithManager(mgr ctrl.Manager) (err error)
• type SolrCloudReconciler
  • func (r *SolrCloudReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SolrCloudReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SolrPrometheusExporterReconciler
  • func (r *SolrPrometheusExporterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SolrPrometheusExporterReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func DeletePodForUpdate

func DeletePodForUpdate(ctx context.Context, r *SolrCloudReconciler, instance *solrv1beta1.SolrCloud, pod *corev1.Pod, podHasReplicas bool, logger logr.Logger) (requeueAfterDuration time.Duration, err error)

func EnsurePodReadinessCondition

func EnsurePodReadinessCondition(pod *corev1.Pod, conditionType corev1.PodConditionType, ensureCondition podReadinessConditionChange) (conditionNeedsChange bool)

EnsurePodReadinessCondition ensure the podCondition is set to the given values

func EnsurePodReadinessConditions

func EnsurePodReadinessConditions(ctx context.Context, r *SolrCloudReconciler, pod *corev1.Pod, ensureConditions map[corev1.PodConditionType]podReadinessConditionChange, logger logr.Logger) (updatedPod *corev1.Pod, err error)

func InitializeCustomPodReadinessCondition

func InitializeCustomPodReadinessCondition(pod *corev1.Pod, conditionType corev1.PodConditionType, reason PodConditionChangeReason, message string, status bool) (conditionNeedsInitializing bool)

InitializeCustomPodReadinessCondition set the default value for a pod's readiness condition after pod creation, given all the default values to set

func InitializePodReadinessCondition

func InitializePodReadinessCondition(pod *corev1.Pod, conditionType corev1.PodConditionType) (conditionNeedsInitializing bool)

InitializePodReadinessCondition set the default value for a pod's readiness condition after pod creation.

func PodConditionEquals

func PodConditionEquals(pod *corev1.Pod, conditionType corev1.PodConditionType, reason PodConditionChangeReason) bool

PodConditionEquals check if a podCondition equals what is expected

func UseZkCRD

func UseZkCRD(useCRD bool)

Types

type PodConditionChangeReason

type PodConditionChangeReason string

PodConditionChangeReason describes the reason why a Pod is being stopped.

const (
	PodStarted           PodConditionChangeReason = "PodStarted"
	PodUpdate            PodConditionChangeReason = "PodUpdate"
	EvictingReplicas     PodConditionChangeReason = "EvictingReplicas"
	StatefulSetScaleDown PodConditionChangeReason = "StatefulSetScaleDown"
)

type SolrBackupReconciler

type SolrBackupReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Config *rest.Config
}

SolrBackupReconciler reconciles a SolrBackup object

func (*SolrBackupReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile

func (*SolrBackupReconciler) SetupWithManager

func (r *SolrBackupReconciler) SetupWithManager(mgr ctrl.Manager) (err error)

SetupWithManager sets up the controller with the Manager.

type SolrCloudReconciler

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

SolrCloudReconciler reconciles a SolrCloud object

func (*SolrCloudReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile

func (*SolrCloudReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type SolrPrometheusExporterReconciler

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

SolrPrometheusExporterReconciler reconciles a SolrPrometheusExporter object

func (*SolrPrometheusExporterReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile

func (*SolrPrometheusExporterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.