Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

util

package

Go to main page

Versions in this module

v0

v0.4.13

Jun 1, 2023

Changes in this version

+ const OcsOperatorConfigName

+ const RookCephOperatorConfigName

+ const VersionValidReason

+ func RemoveExternalCephClusterNegativeConditions(conditions *[]conditionsv1.Condition)

+ func SetVersionMismatchCondition(conditions *[]conditionsv1.Condition, status corev1.ConditionStatus, ...)

v0.4.12

Dec 23, 2022

v0.4.11

Oct 14, 2022

Changes in this version

+ const OperatorNamespaceEnvVar

+ func GetOperatorNamespace() (string, error)

+ func GetPGBaseUnitSize(osdCount int) int

v0.4.10

Apr 26, 2022

Changes in this version

+ var PhaseOnboarding = "Onboarding"

v0.4.9

Nov 8, 2021

Changes in this version

+ const EventReasonUninstallPending

+ const EventReasonValidationFailed

+ const ExternalClusterConnectingReason

+ const ExternalClusterErrorReason

+ const ExternalClusterUnknownReason

+ const FileName

+ const WatchNamespaceEnvVar

+ var PhaseClusterExpanding = "Expanding Capacity"

+ var PhaseConnecting = "Connecting"

+ var PhaseDeleting = "Deleting"

+ var PhaseError = "Error"

+ var PhaseIgnored = "Ignored"

+ var PhaseNotReady = "Not Ready"

+ var PhaseProgressing = "Progressing"

+ var PhaseReady = "Ready"

+ func ComposePredicates(predicates ...predicate.Predicate) predicate.Predicate

+ func GetWatchNamespace() (string, error)

+ func MapCephClusterNegativeConditions(conditions *[]conditionsv1.Condition, found *cephv1.CephCluster)

+ func MapCephClusterNoConditions(conditions *[]conditionsv1.Condition, reason string, message string)

+ func MapExternalCephClusterNegativeConditions(conditions *[]conditionsv1.Condition, found *cephv1.CephCluster)

+ func MapNoobaaNegativeConditions(conditions *[]conditionsv1.Condition, found *nbv1.NooBaa)

+ func SetCompleteCondition(conditions *[]conditionsv1.Condition, reason string, message string)

+ func SetErrorCondition(conditions *[]conditionsv1.Condition, reason string, message string)

+ func SetProgressingCondition(conditions *[]conditionsv1.Condition, reason string, message string)

+ type EventReporter struct

+ func NewEventReporter(recorder record.EventRecorder) *EventReporter

+ func (rep *EventReporter) ReportIfNotPresent(instance runtime.Object, eventType, eventReason, msg string)

+ type MetadataChangedPredicate struct

+ func (p MetadataChangedPredicate) Update(e event.UpdateEvent) bool

+ type Ready interface

+ Set func() error

+ Unset func() error

+ func NewFileReady() Ready