Versions in this module Expand all Collapse all v0 v0.0.2 Feb 16, 2026 Changes in this version + const RequeueOnRefreshTimeout + const TLSFileMode + var DefaultLivenessProbeSettings = corev1.Probe + var DefaultReadinessProbeSettings = corev1.Probe + func CheckPodError(ctx context.Context, log util.Logger, client client.Client, ...) (bool, error) + func ProjectVolumes(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount) ([]corev1.Volume, []corev1.VolumeMount, error) + type LoggerConfig struct + Console bool + Count int64 + ErrorLog string + Formatting struct{ ... } + Level string + Log string + Size string + func GenerateLoggerConfig(spec v1.LoggerConfig, basePath string, service string) LoggerConfig + type OpenSSLConfig struct + Client OpenSSLParams + Server OpenSSLParams + type OpenSSLParams struct + CAConfig string + CertificateFile string + DisableProtocols string + PreferServerCiphers bool + PrivateKeyFile string + VerificationMode string + type PrometheusConfig struct + AsynchronousMetrics bool + Endpoint string + Events bool + Metrics bool + Port uint16 + func DefaultPrometheusConfig(port uint16) PrometheusConfig + type ReplicaUpdateStage int + const StageError + const StageHasDiff + const StageNotExists + const StageNotReadyUpToDate + const StageUpToDate + const StageUpdating + func (s ReplicaUpdateStage) String() string + type ResourceReconcilerBase struct + Cluster Cluster + ReplicaState map[ReplicaID]ReplicaState + func NewReconcilerBase[ClusterStatus any, Cluster clusterObject[ClusterStatus], ReplicaID replicaID, ...](ctrl controller, cluster Cluster) ResourceReconcilerBase[ClusterStatus, Cluster, ReplicaID, ReplicaState] + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) Create(ctx context.Context, resource client.Object, action v1.EventAction) error + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) Delete(ctx context.Context, resource client.Object, action v1.EventAction) error + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) NewCondition(condType v1.ConditionType, status metav1.ConditionStatus, ...) metav1.Condition + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) ReconcileConfigMap(ctx context.Context, log util.Logger, configMap *corev1.ConfigMap, ...) (bool, error) + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) ReconcilePodDisruptionBudget(ctx context.Context, log util.Logger, pdb *policyv1.PodDisruptionBudget, ...) (bool, error) + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) ReconcileService(ctx context.Context, log util.Logger, service *corev1.Service, ...) (bool, error) + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) Replica(id ReplicaID) S + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) SetCondition(log util.Logger, cond metav1.Condition) bool + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) SetConditions(log util.Logger, conditions []metav1.Condition) bool + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) SetReplica(id ReplicaID, state S) bool + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) Update(ctx context.Context, resource client.Object, action v1.EventAction) error + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) UpdatePVC(ctx context.Context, log util.Logger, id ReplicaID, ...) error + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) UpsertCondition(ctx context.Context, log util.Logger, condition metav1.Condition) (bool, error) + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) UpsertConditionAndSendEvent(ctx context.Context, log util.Logger, condition metav1.Condition, ...) (bool, error) + func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) UpsertStatus(ctx context.Context, log util.Logger) error
Go to main page