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

util

package

Go to main page

Versions in this module

v0

v0.4.1

Aug 19, 2025

v0.4.0

Aug 5, 2025

v0.4.0-rc.4

Aug 2, 2025

v0.4.0-rc.3

Aug 2, 2025

v0.4.0-rc.1

Jul 31, 2025

v0.3.0

May 21, 2025

Changes in this version

+ const DesiredReplicasAnnotation

+ const FailedRSCreateReason

+ const FoundNewRSReason

+ const MaxReplicasAnnotation

+ const MinimumReplicasAvailable

+ const MinimumReplicasUnavailable

+ const NewRSAvailableReason

+ const NewReplicaSetReason

+ const PausedDeployReason

+ const ReplicaSetUpdatedReason

+ const ResumedDeployReason

+ const RevisionAnnotation

+ const RevisionHistoryAnnotation

+ const RollbackDone

+ const RollbackRevisionNotFound

+ const RollbackTemplateUnchanged

+ const SetNameLabelKey

+ const TimedOutReason

+ var NowFn = func() time.Time

+ func ComputeHash(template *orchestrationv1alpha1.RayClusterTemplateSpec, collisionCount *int32) string

+ func DeepHashObject(hasher hash.Hash, objectToWrite interface{})

+ func DeploymentComplete(deployment *orchestrationv1alpha1.RayClusterFleet, ...) bool

+ func DeploymentProgressing(deployment *orchestrationv1alpha1.RayClusterFleet, ...) bool

+ func DeploymentTimedOut(ctx context.Context, deployment *orchestrationv1alpha1.RayClusterFleet, ...) bool

+ func EqualIgnoreLabels(template1, template2 *orchestrationv1alpha1.RayClusterTemplateSpec) bool

+ func FilterActiveReplicaSets(replicaSets []*orchestrationv1alpha1.RayClusterReplicaSet) []*orchestrationv1alpha1.RayClusterReplicaSet

+ func FilterReplicaSets(RSes []*orchestrationv1alpha1.RayClusterReplicaSet, filterFn filterRS) []*orchestrationv1alpha1.RayClusterReplicaSet

+ func FindActiveOrLatest(newRS *orchestrationv1alpha1.RayClusterReplicaSet, ...) *orchestrationv1alpha1.RayClusterReplicaSet

+ func FindNewReplicaSet(fleet *orchestrationv1alpha1.RayClusterFleet, ...) *orchestrationv1alpha1.RayClusterReplicaSet

+ func FindOldReplicaSets(deployment *orchestrationv1alpha1.RayClusterFleet, ...) ([]*orchestrationv1alpha1.RayClusterReplicaSet, ...)

+ func GetActualReplicaCountForReplicaSets(replicaSets []*orchestrationv1alpha1.RayClusterReplicaSet) int32

+ func GetAvailableReplicaCountForReplicaSets(replicaSets []*orchestrationv1alpha1.RayClusterReplicaSet) int32

+ func GetDeploymentCondition(status orchestrationv1alpha1.RayClusterFleetStatus, ...) *orchestrationv1alpha1.RayClusterFleetCondition

+ func GetDeploymentsForReplicaSet(c client.Client, rs *orchestrationv1alpha1.RayClusterReplicaSet) ([]*orchestrationv1alpha1.RayClusterFleet, error)

+ func GetDesiredReplicasAnnotation(logger klog.Logger, rs *orchestrationv1alpha1.RayClusterReplicaSet) (int32, bool)

+ func GetProportion(logger klog.Logger, rs *orchestrationv1alpha1.RayClusterReplicaSet, ...) int32

+ func GetReadyReplicaCountForReplicaSets(replicaSets []*orchestrationv1alpha1.RayClusterReplicaSet) int32

+ func GetReplicaCountForReplicaSets(replicaSets []*orchestrationv1alpha1.RayClusterReplicaSet) int32

+ func HasProgressDeadline(d *orchestrationv1alpha1.RayClusterFleet) bool

+ func HasRevisionHistoryLimit(d *orchestrationv1alpha1.RayClusterFleet) bool

+ func IsRollingUpdate(deployment *orchestrationv1alpha1.RayClusterFleet) bool

+ func IsSaturated(deployment *orchestrationv1alpha1.RayClusterFleet, ...) bool

+ func LastRevision(logger klog.Logger, allRSs []*orchestrationv1alpha1.RayClusterReplicaSet) int64

+ func ListPods(deployment *orchestrationv1alpha1.RayClusterFleet, ...) (*v1.PodList, error)

+ func ListReplicaSets(deployment *orchestrationv1alpha1.RayClusterFleet, getRSList RsListFunc) ([]*orchestrationv1alpha1.RayClusterReplicaSet, error)

+ func MaxRevision(logger klog.Logger, allRSs []*orchestrationv1alpha1.RayClusterReplicaSet) int64

+ func MaxSurge(deployment orchestrationv1alpha1.RayClusterFleet) int32

+ func MaxUnavailable(deployment orchestrationv1alpha1.RayClusterFleet) int32

+ func MinAvailable(deployment *orchestrationv1alpha1.RayClusterFleet) int32

+ func NewDeploymentCondition(condType orchestrationv1alpha1.RayClusterFleetConditionType, ...) *orchestrationv1alpha1.RayClusterFleetCondition

+ func NewRSNewReplicas(deployment *orchestrationv1alpha1.RayClusterFleet, ...) (int32, error)

+ func RemoveDeploymentCondition(status *orchestrationv1alpha1.RayClusterFleetStatus, ...)

+ func ReplicaSetToDeploymentCondition(cond metav1.Condition) orchestrationv1alpha1.RayClusterFleetCondition

+ func ReplicasAnnotationsNeedUpdate(rs *orchestrationv1alpha1.RayClusterReplicaSet, ...) bool

+ func ResolveFenceposts(maxSurge, maxUnavailable *intstrutil.IntOrString, desired int32) (int32, int32, error)

+ func Revision(obj runtime.Object) (int64, error)

+ func SetDeploymentAnnotationsTo(deployment *orchestrationv1alpha1.RayClusterFleet, ...)

+ func SetDeploymentCondition(status *orchestrationv1alpha1.RayClusterFleetStatus, ...)

+ func SetDeploymentRevision(fleet *orchestrationv1alpha1.RayClusterFleet, revision string) bool

+ func SetFromReplicaSetTemplate(fleet *orchestrationv1alpha1.RayClusterFleet, ...) *orchestrationv1alpha1.RayClusterFleet

+ func SetNewReplicaSetAnnotations(ctx context.Context, deployment *orchestrationv1alpha1.RayClusterFleet, ...) bool

+ func SetReplicasAnnotations(rs *orchestrationv1alpha1.RayClusterReplicaSet, ...) bool

+ func WaitForObservedDeployment(getDeploymentFunc func() (*orchestrationv1alpha1.RayClusterFleet, error), ...) error

+ type ReplicaSetsByCreationTimestamp []*orchestrationv1alpha1.RayClusterReplicaSet

+ func (o ReplicaSetsByCreationTimestamp) Len() int

+ func (o ReplicaSetsByCreationTimestamp) Less(i, j int) bool

+ func (o ReplicaSetsByCreationTimestamp) Swap(i, j int)

+ type ReplicaSetsByRevision []*orchestrationv1alpha1.RayClusterReplicaSet

+ func (o ReplicaSetsByRevision) Len() int

+ func (o ReplicaSetsByRevision) Less(i, j int) bool

+ func (o ReplicaSetsByRevision) Swap(i, j int)

+ type ReplicaSetsBySizeNewer []*orchestrationv1alpha1.RayClusterReplicaSet

+ func (o ReplicaSetsBySizeNewer) Len() int

+ func (o ReplicaSetsBySizeNewer) Less(i, j int) bool

+ func (o ReplicaSetsBySizeNewer) Swap(i, j int)

+ type ReplicaSetsBySizeOlder []*orchestrationv1alpha1.RayClusterReplicaSet

+ func (o ReplicaSetsBySizeOlder) Len() int

+ func (o ReplicaSetsBySizeOlder) Less(i, j int) bool

+ func (o ReplicaSetsBySizeOlder) Swap(i, j int)

+ type RsListFunc func(string, metav1.ListOptions) ([]*orchestrationv1alpha1.RayClusterReplicaSet, error)

+ func RsListFromClient(c client.Client) RsListFunc

v0.3.0-rc.2

May 21, 2025

v0.3.0-rc.1

May 13, 2025