Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

controller

package

Go to main page

Versions in this module

v0

v0.0.3

Mar 11, 2026

Changes in this version

+ const LoadReplicaStateTimeout

+ type ReplicaUpdateInput struct

+ BreakingSTSVersion semver.Version

+ ConfigurationRevision string

+ DataVolumeClaimSpec *corev1.PersistentVolumeClaimSpec

+ DesiredConfigMap *corev1.ConfigMap

+ DesiredSTS *appsv1.StatefulSet

+ ExistingSTS *appsv1.StatefulSet

+ HasError bool

+ StatefulSetRevision string

type ResourceReconcilerBase

+ func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) ReconcileReplicaResources(ctx context.Context, log util.Logger, replicaID ReplicaID, ...) (*ctrlruntime.Result, error)

+ func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) UpdateUpgradeCondition(ctx context.Context, log controllerutil.Logger, probe VersionProbeResult, ...) error

+ func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) UpdateVersionSyncCondition(ctx context.Context, log controllerutil.Logger, probe VersionProbeResult, ...) error

+ func (r *ResourceReconcilerBase[Status, T, ReplicaID, S]) VersionProbe(ctx context.Context, log controllerutil.Logger, cfg VersionProbeConfig) (VersionProbeResult, error)

+ type VersionProbeConfig struct

+ Annotations map[string]string

+ Binary string

+ ContainerTemplate v1.ContainerTemplateSpec

+ Labels map[string]string

+ PodTemplate v1.PodTemplateSpec

+ type VersionProbeResult struct

+ Err error

+ Pending bool

+ Version string

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