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

common

package

Go to main page

Versions in this module

v2

v2.1.0-beta.4

Apr 28, 2026

v2.1.0-beta.3

Apr 24, 2026

v2.1.0-beta.2

Apr 22, 2026

v2.1.0-beta.1

Apr 21, 2026

v2.1.0-beta.0

Apr 13, 2026

v2.1.0-alpha.17

Apr 13, 2026

v2.1.0-alpha.16

Apr 3, 2026

v2.1.0-alpha.15

Jan 19, 2026

v2.1.0-alpha.14

Jan 14, 2026

v2.1.0-alpha.13

Dec 26, 2025

v2.1.0-alpha.12

Dec 5, 2025

v2.1.0-alpha.11

Nov 30, 2025

v2.0.1

Mar 25, 2026

Changes in this version

+ func TaskSetOffline[S scope.Instance[F, T], F client.Object, T runtime.Instance](state ObjectState[F], c client.Client) task.Task

v2.0.0

Dec 5, 2025

Changes in this version

+ var JobLifecycleManager = &jobLifecycleManager

+ func CondClusterIsDeleting(ctx ClusterState) task.Condition

+ func CondClusterIsPaused(ctx ClusterState) task.Condition

+ func CondClusterIsSuspending(ctx ClusterState) task.Condition

+ func CondClusterPDAddrIsNotRegistered(ctx ClusterState) task.Condition

+ func CondFeatureGatesIsNotSynced[S scope.Group[F, T], F client.Object, T runtime.Group](state ContextFeatureGates[F]) task.Condition

+ func CondObjectHasBeenDeleted[S scope.Object[F, T], F Object[O], T runtime.Object, O any](state ObjectState[F]) task.Condition

+ func CondObjectIsDeleting[S scope.Object[F, T], F Object[O], T runtime.Object, O any](state ObjectState[F]) task.Condition

+ func CondObjectIsNotDeletingButOfflined[S scope.Instance[F, T], F client.Object, T runtime.Instance](state ObjectState[F]) task.Condition

+ func IgnoreErrorf(format string, a ...any) error

+ func IsIgnoreError(err error) bool

+ func IsRequeueError(err error) bool

+ func RequeueErrorf(duration time.Duration, format string, a ...any) error

+ func TaskContextCluster[S scope.Object[F, T], F client.Object, T runtime.Object](state ContextClusterNewer[F], c client.Client) task.Task

+ func TaskContextObject[S scope.Object[F, T], F Object[O], T runtime.Object, O any](state ContextObjectNewer[F], c client.Client) task.Task

+ func TaskContextPeerSlice[S scope.InstanceList[F, T, L], F client.Object, T runtime.Instance, ...](state ContextSliceNewer[F, F], c client.Client) task.Task

+ func TaskContextPod[S scope.Instance[F, T], F client.Object, T runtime.Instance](state ContextPodNewer[F], c client.Client) task.Task

+ func TaskContextSlice[S scope.GroupInstance[GF, GT, IS], IS scope.List[IL, I], GF client.Object, ...](state ContextSliceNewer[GF, I], c client.Client) task.Task

+ func TaskDeleteOfflinedStore[S scope.Instance[F, T], F client.Object, T runtime.Instance](state ObjectState[F], c client.Client) task.Task

+ func TaskFinalizerAdd[S scope.Object[F, T], F Object[O], T runtime.Object, O any](state ObjectState[F], c client.Client) task.Task

+ func TaskGroupConditionReady[S scope.GroupInstance[F, T, IS], IS scope.Instance[IF, IT], F client.Object, ...](state GroupCondReadyUpdater[F, IF]) task.Task

+ func TaskGroupConditionSuspended[S scope.GroupInstance[F, T, IS], IS scope.Instance[IF, IT], F client.Object, ...](state GroupCondSuspendedUpdater[F, IF]) task.Task

+ func TaskGroupConditionSynced[S scope.GroupInstance[F, T, IS], IS scope.Instance[IF, IT], F client.Object, ...](state GroupCondSyncedUpdater[F, IF]) task.Task

+ func TaskGroupFinalizerAdd[GT runtime.GroupTuple[OG, RG], OG client.Object, RG runtime.Group](state GroupState[RG], c client.Client) task.Task

+ func TaskGroupFinalizerDel[S scope.Group[GF, GT], GF client.Object, GT runtime.Group, I client.Object](state GroupFinalizerDelState[GF, I], c client.Client) task.Task

+ func TaskGroupStatusSelector[S scope.Group[F, T], F client.Object, T runtime.Group](state GroupStatusSelectorUpdater[F]) task.Task

+ func TaskInstanceConditionOffline[S scope.Instance[F, T], F client.Object, T runtime.Instance](s InstanceCondOfflineUpdater[F]) task.Task

+ func TaskInstanceConditionReady[S scope.Instance[F, T], F client.Object, T runtime.Instance](state InstanceCondReadyUpdater[F]) task.Task

+ func TaskInstanceConditionRunning[S scope.Instance[F, T], F client.Object, T runtime.Instance](state InstanceCondRunningUpdater[F]) task.Task

+ func TaskInstanceConditionSuspended[S scope.Instance[F, T], F client.Object, T runtime.Instance](state InstanceCondSuspendedUpdater[F]) task.Task

+ func TaskInstanceConditionSynced[S scope.Instance[F, T], F client.Object, T runtime.Instance](state InstanceCondSyncedUpdater[F]) task.Task

+ func TaskInstanceFinalizerAdd[IT runtime.InstanceTuple[OI, RI], OI client.Object, RI runtime.Instance](state InstanceState[RI], c client.Client) task.Task

+ func TaskJobFinalizerAdd[J runtime.Job](state JobState[J], c client.Client) task.Task

+ func TaskJobFinalizerDel[J runtime.Job](state JobState[J], c client.Client) task.Task

+ func TaskOfflineStore[S scope.Instance[F, T], F client.Object, T runtime.Instance](ctx context.Context, c pdapi.PDClient, obj F, storeID string, ...) error

+ func TaskPVC[S scope.Instance[F, T], F client.Object, T runtime.Instance](state TaskPVCState[F], c client.Client, vm volumes.ModifierFactory, ...) task.Task

+ func TaskRevision[GT runtime.GroupTuple[OG, RG], OG client.Object, RG runtime.Group](state RevisionStateInitializer[RG], c client.Client) task.Task

+ func TaskServerLabels[S scope.Instance[F, T], F client.Object, T runtime.Instance](state ServerLabelsUpdater[F], c client.Client, ...) task.Task

+ func TaskStatusPersister[S scope.Object[F, T], F client.Object, T runtime.Object](state StatusPersister[F], c client.Client) task.Task

+ func TaskStatusRevisionAndReplicas[S scope.GroupInstance[F, T, IS], IS scope.Instance[IF, IT], F client.Object, ...](state StatusRevisionAndReplicasUpdater[F, IF]) task.Task

+ func TaskSuspendPod(state PodState, c client.Client) task.Task

+ func TaskTrack[S scope.Instance[F, T], F Object[P], T runtime.Instance, P any](state TrackState[F], t tracker.Tracker) task.Task

+ type ClusterAndGroupAndInstanceSliceState interface

+ type ClusterState interface

+ Cluster func() *v1alpha1.Cluster

+ type CollisionCountOption interface

+ CollisionCount func() *int32

+ type ContextClusterNewer interface

+ SetCluster func(c *v1alpha1.Cluster)

+ type ContextFeatureGates interface

+ type ContextObjectNewer interface

+ Key func() types.NamespacedName

+ SetObject func(f F)

+ type ContextPodNewer interface

+ SetPod func(pod *corev1.Pod)

+ type ContextSliceNewer interface

+ SetInstanceSlice func(f []IF)

+ type CurrentRevisionOption interface

+ CurrentRevision func() string

+ type GetOptions interface

+ type GroupAndInstanceSliceAndRevisionState interface

+ type GroupAndInstanceSliceState interface

+ type GroupCondReadyUpdater interface

+ Object func() G

+ type GroupCondSuspendedUpdater interface

+ Object func() G

+ type GroupCondSyncedUpdater interface

+ Object func() G

+ type GroupFinalizerDelState interface

+ type GroupState interface

+ Group func() G

+ type GroupStatusSelectorUpdater interface

+ Object func() G

+ type HealthyState interface

+ IsHealthy func() bool

+ type HealthyStateUpdater interface

+ SetHealthy func()

+ type IgnoreError struct

+ func (re *IgnoreError) Error() string

+ type InstanceAndPodState interface

+ type InstanceCondOfflineUpdater interface

+ Object func() T

+ type InstanceCondReadyUpdater interface

+ Object func() T

+ type InstanceCondRunningUpdater interface

+ Object func() T

+ type InstanceCondSuspendedUpdater interface

+ Object func() T

+ type InstanceCondSyncedUpdater interface

+ Object func() T

+ type InstanceSliceState interface

+ Slice func() []I

+ type InstanceState interface

+ Instance func() I

+ type JobState interface

+ Job func() J

+ type Labels map[string]string

+ func (l Labels) Labels() map[string]string

+ type LabelsFunc func() map[string]string

+ func (f LabelsFunc) Labels() map[string]string

+ type LabelsOption interface

+ Labels func() map[string]string

+ type Lazy func() T

+ func (f Lazy[T]) CollisionCount() T

+ func (f Lazy[T]) CurrentRevision() T

+ func (f Lazy[T]) Labels() T

+ func (f Lazy[T]) Name() T

+ func (f Lazy[T]) Namespace() T

+ func (f Lazy[T]) Parent() T

+ type ListOptions interface

+ type MockGroupCondReadyUpdater struct

+ func NewMockGroupCondReadyUpdater[G client.Object, I client.Object](ctrl *gomock.Controller) *MockGroupCondReadyUpdater[G, I]

+ func (m *MockGroupCondReadyUpdater[G, I]) EXPECT() *MockGroupCondReadyUpdaterMockRecorder[G, I]

+ func (m *MockGroupCondReadyUpdater[G, I]) InstanceSlice() []I

+ func (m *MockGroupCondReadyUpdater[G, I]) Object() G

+ func (m *MockGroupCondReadyUpdater[G, I]) SetStatusChanged()

+ type MockGroupCondReadyUpdaterMockRecorder struct

+ func (mr *MockGroupCondReadyUpdaterMockRecorder[G, I]) InstanceSlice() *gomock.Call

+ func (mr *MockGroupCondReadyUpdaterMockRecorder[G, I]) Object() *gomock.Call

+ func (mr *MockGroupCondReadyUpdaterMockRecorder[G, I]) SetStatusChanged() *gomock.Call

+ type MockGroupCondSuspendedUpdater struct

+ func NewMockGroupCondSuspendedUpdater[G client.Object, I client.Object](ctrl *gomock.Controller) *MockGroupCondSuspendedUpdater[G, I]

+ func (m *MockGroupCondSuspendedUpdater[G, I]) Cluster() *v1alpha1.Cluster

+ func (m *MockGroupCondSuspendedUpdater[G, I]) EXPECT() *MockGroupCondSuspendedUpdaterMockRecorder[G, I]

+ func (m *MockGroupCondSuspendedUpdater[G, I]) InstanceSlice() []I

+ func (m *MockGroupCondSuspendedUpdater[G, I]) Object() G

+ func (m *MockGroupCondSuspendedUpdater[G, I]) SetStatusChanged()

+ type MockGroupCondSuspendedUpdaterMockRecorder struct

+ func (mr *MockGroupCondSuspendedUpdaterMockRecorder[G, I]) Cluster() *gomock.Call

+ func (mr *MockGroupCondSuspendedUpdaterMockRecorder[G, I]) InstanceSlice() *gomock.Call

+ func (mr *MockGroupCondSuspendedUpdaterMockRecorder[G, I]) Object() *gomock.Call

+ func (mr *MockGroupCondSuspendedUpdaterMockRecorder[G, I]) SetStatusChanged() *gomock.Call

+ type MockGroupCondSyncedUpdater struct

+ func NewMockGroupCondSyncedUpdater[G client.Object, I client.Object](ctrl *gomock.Controller) *MockGroupCondSyncedUpdater[G, I]

+ func (m *MockGroupCondSyncedUpdater[G, I]) EXPECT() *MockGroupCondSyncedUpdaterMockRecorder[G, I]

+ func (m *MockGroupCondSyncedUpdater[G, I]) InstanceSlice() []I

+ func (m *MockGroupCondSyncedUpdater[G, I]) Object() G

+ func (m *MockGroupCondSyncedUpdater[G, I]) Revision() (string, string, int32)

+ func (m *MockGroupCondSyncedUpdater[G, I]) SetStatusChanged()

+ type MockGroupCondSyncedUpdaterMockRecorder struct

+ func (mr *MockGroupCondSyncedUpdaterMockRecorder[G, I]) InstanceSlice() *gomock.Call

+ func (mr *MockGroupCondSyncedUpdaterMockRecorder[G, I]) Object() *gomock.Call

+ func (mr *MockGroupCondSyncedUpdaterMockRecorder[G, I]) Revision() *gomock.Call

+ func (mr *MockGroupCondSyncedUpdaterMockRecorder[G, I]) SetStatusChanged() *gomock.Call

+ type MockGroupStatusSelectorUpdater struct

+ func NewMockGroupStatusSelectorUpdater[G client.Object](ctrl *gomock.Controller) *MockGroupStatusSelectorUpdater[G]

+ func (m *MockGroupStatusSelectorUpdater[G]) EXPECT() *MockGroupStatusSelectorUpdaterMockRecorder[G]

+ func (m *MockGroupStatusSelectorUpdater[G]) Object() G

+ func (m *MockGroupStatusSelectorUpdater[G]) SetStatusChanged()

+ type MockGroupStatusSelectorUpdaterMockRecorder struct

+ func (mr *MockGroupStatusSelectorUpdaterMockRecorder[G]) Object() *gomock.Call

+ func (mr *MockGroupStatusSelectorUpdaterMockRecorder[G]) SetStatusChanged() *gomock.Call

+ type MockInstanceCondOfflineUpdater struct

+ func NewMockInstanceCondOfflineUpdater[T client.Object](ctrl *gomock.Controller) *MockInstanceCondOfflineUpdater[T]

+ func (m *MockInstanceCondOfflineUpdater[T]) EXPECT() *MockInstanceCondOfflineUpdaterMockRecorder[T]

+ func (m *MockInstanceCondOfflineUpdater[T]) GetLeaderCount() int

+ func (m *MockInstanceCondOfflineUpdater[T]) GetRegionCount() int

+ func (m *MockInstanceCondOfflineUpdater[T]) GetStoreState() v1.NodeState

+ func (m *MockInstanceCondOfflineUpdater[T]) IsStoreBusy() bool

+ func (m *MockInstanceCondOfflineUpdater[T]) IsStoreUp() bool

+ func (m *MockInstanceCondOfflineUpdater[T]) Object() T

+ func (m *MockInstanceCondOfflineUpdater[T]) SetStatusChanged()

+ type MockInstanceCondOfflineUpdaterMockRecorder struct

+ func (mr *MockInstanceCondOfflineUpdaterMockRecorder[T]) GetLeaderCount() *gomock.Call

+ func (mr *MockInstanceCondOfflineUpdaterMockRecorder[T]) GetRegionCount() *gomock.Call

+ func (mr *MockInstanceCondOfflineUpdaterMockRecorder[T]) GetStoreState() *gomock.Call

+ func (mr *MockInstanceCondOfflineUpdaterMockRecorder[T]) IsStoreBusy() *gomock.Call

+ func (mr *MockInstanceCondOfflineUpdaterMockRecorder[T]) IsStoreUp() *gomock.Call

+ func (mr *MockInstanceCondOfflineUpdaterMockRecorder[T]) Object() *gomock.Call

+ func (mr *MockInstanceCondOfflineUpdaterMockRecorder[T]) SetStatusChanged() *gomock.Call

+ type MockInstanceCondReadyUpdater struct

+ func NewMockInstanceCondReadyUpdater[T client.Object](ctrl *gomock.Controller) *MockInstanceCondReadyUpdater[T]

+ func (m *MockInstanceCondReadyUpdater[T]) EXPECT() *MockInstanceCondReadyUpdaterMockRecorder[T]

+ func (m *MockInstanceCondReadyUpdater[T]) IsHealthy() bool

+ func (m *MockInstanceCondReadyUpdater[T]) IsPodTerminating() bool

+ func (m *MockInstanceCondReadyUpdater[T]) Object() T

+ func (m *MockInstanceCondReadyUpdater[T]) Pod() *v10.Pod

+ func (m *MockInstanceCondReadyUpdater[T]) SetStatusChanged()

+ type MockInstanceCondReadyUpdaterMockRecorder struct

+ func (mr *MockInstanceCondReadyUpdaterMockRecorder[T]) IsHealthy() *gomock.Call

+ func (mr *MockInstanceCondReadyUpdaterMockRecorder[T]) IsPodTerminating() *gomock.Call

+ func (mr *MockInstanceCondReadyUpdaterMockRecorder[T]) Object() *gomock.Call

+ func (mr *MockInstanceCondReadyUpdaterMockRecorder[T]) Pod() *gomock.Call

+ func (mr *MockInstanceCondReadyUpdaterMockRecorder[T]) SetStatusChanged() *gomock.Call

+ type MockInstanceCondSuspendedUpdater struct

+ func NewMockInstanceCondSuspendedUpdater[T client.Object](ctrl *gomock.Controller) *MockInstanceCondSuspendedUpdater[T]

+ func (m *MockInstanceCondSuspendedUpdater[T]) Cluster() *v1alpha1.Cluster

+ func (m *MockInstanceCondSuspendedUpdater[T]) EXPECT() *MockInstanceCondSuspendedUpdaterMockRecorder[T]

+ func (m *MockInstanceCondSuspendedUpdater[T]) IsPodTerminating() bool

+ func (m *MockInstanceCondSuspendedUpdater[T]) Object() T

+ func (m *MockInstanceCondSuspendedUpdater[T]) Pod() *v10.Pod

+ func (m *MockInstanceCondSuspendedUpdater[T]) SetStatusChanged()

+ type MockInstanceCondSuspendedUpdaterMockRecorder struct

+ func (mr *MockInstanceCondSuspendedUpdaterMockRecorder[T]) Cluster() *gomock.Call

+ func (mr *MockInstanceCondSuspendedUpdaterMockRecorder[T]) IsPodTerminating() *gomock.Call

+ func (mr *MockInstanceCondSuspendedUpdaterMockRecorder[T]) Object() *gomock.Call

+ func (mr *MockInstanceCondSuspendedUpdaterMockRecorder[T]) Pod() *gomock.Call

+ func (mr *MockInstanceCondSuspendedUpdaterMockRecorder[T]) SetStatusChanged() *gomock.Call

+ type MockInstanceCondSyncedUpdater struct

+ func NewMockInstanceCondSyncedUpdater[T client.Object](ctrl *gomock.Controller) *MockInstanceCondSyncedUpdater[T]

+ func (m *MockInstanceCondSyncedUpdater[T]) Cluster() *v1alpha1.Cluster

+ func (m *MockInstanceCondSyncedUpdater[T]) EXPECT() *MockInstanceCondSyncedUpdaterMockRecorder[T]

+ func (m *MockInstanceCondSyncedUpdater[T]) IsPodTerminating() bool

+ func (m *MockInstanceCondSyncedUpdater[T]) Object() T

+ func (m *MockInstanceCondSyncedUpdater[T]) Pod() *v10.Pod

+ func (m *MockInstanceCondSyncedUpdater[T]) SetStatusChanged()

+ type MockInstanceCondSyncedUpdaterMockRecorder struct

+ func (mr *MockInstanceCondSyncedUpdaterMockRecorder[T]) Cluster() *gomock.Call

+ func (mr *MockInstanceCondSyncedUpdaterMockRecorder[T]) IsPodTerminating() *gomock.Call

+ func (mr *MockInstanceCondSyncedUpdaterMockRecorder[T]) Object() *gomock.Call

+ func (mr *MockInstanceCondSyncedUpdaterMockRecorder[T]) Pod() *gomock.Call

+ func (mr *MockInstanceCondSyncedUpdaterMockRecorder[T]) SetStatusChanged() *gomock.Call

+ type MockStatusPersister struct

+ func NewMockStatusPersister[T client.Object](ctrl *gomock.Controller) *MockStatusPersister[T]

+ func (m *MockStatusPersister[T]) EXPECT() *MockStatusPersisterMockRecorder[T]

+ func (m *MockStatusPersister[T]) IsStatusChanged() bool

+ func (m *MockStatusPersister[T]) Object() T

+ type MockStatusPersisterMockRecorder struct

+ func (mr *MockStatusPersisterMockRecorder[T]) IsStatusChanged() *gomock.Call

+ func (mr *MockStatusPersisterMockRecorder[T]) Object() *gomock.Call

+ type MockStatusRevisionAndReplicasUpdater struct

+ func NewMockStatusRevisionAndReplicasUpdater[G client.Object, I client.Object](ctrl *gomock.Controller) *MockStatusRevisionAndReplicasUpdater[G, I]

+ func (m *MockStatusRevisionAndReplicasUpdater[G, I]) EXPECT() *MockStatusRevisionAndReplicasUpdaterMockRecorder[G, I]

+ func (m *MockStatusRevisionAndReplicasUpdater[G, I]) InstanceSlice() []I

+ func (m *MockStatusRevisionAndReplicasUpdater[G, I]) Object() G

+ func (m *MockStatusRevisionAndReplicasUpdater[G, I]) Revision() (string, string, int32)

+ func (m *MockStatusRevisionAndReplicasUpdater[G, I]) SetStatusChanged()

+ type MockStatusRevisionAndReplicasUpdaterMockRecorder struct

+ func (mr *MockStatusRevisionAndReplicasUpdaterMockRecorder[G, I]) InstanceSlice() *gomock.Call

+ func (mr *MockStatusRevisionAndReplicasUpdaterMockRecorder[G, I]) Object() *gomock.Call

+ func (mr *MockStatusRevisionAndReplicasUpdaterMockRecorder[G, I]) Revision() *gomock.Call

+ func (mr *MockStatusRevisionAndReplicasUpdaterMockRecorder[G, I]) SetStatusChanged() *gomock.Call

+ type Name string

+ func (n Name) Name() string

+ type NameOption interface

+ Name func() string

+ type Namespace string

+ func (n Namespace) Namespace() string

+ type NamespaceOption interface

+ Namespace func() string

+ type Object interface

+ type ObjectList interface

+ type ObjectState interface

+ Object func() F

+ type PDGroupState interface

+ PDGroup func() *v1alpha1.PDGroup

+ type PDSliceInitializer = ResourceSliceInitializer[v1alpha1.PD]

+ type PDSliceState interface

+ PDSlice func() []*v1alpha1.PD

+ type PDSliceStateInitializer interface

+ PDSliceInitializer func() PDSliceInitializer

+ type PDState interface

+ PD func() *v1alpha1.PD

+ type PVCNewer interface

+ NewPVCs func(c *v1alpha1.Cluster, obj F, fg features.Gates) []*corev1.PersistentVolumeClaim

+ type PVCNewerFunc func(c *v1alpha1.Cluster, obj F, fg features.Gates) []*corev1.PersistentVolumeClaim

+ func (f PVCNewerFunc[F]) NewPVCs(c *v1alpha1.Cluster, obj F, fg features.Gates) []*corev1.PersistentVolumeClaim

+ type ParentOption interface

+ Parent func() G

+ type PodState interface

+ IsPodTerminating func() bool

+ Pod func() *corev1.Pod

+ type PodStateUpdater interface

+ DeletePod func(pod *corev1.Pod)

+ SetPod func(pod *corev1.Pod)

+ type RequeueError struct

+ Duration time.Duration

+ func (re *RequeueError) Error() string

+ type Resource interface

+ Initializer func() ResourceInitializer[T]

+ WithName func(NameOption) Resource[T]

+ WithNamespace func(NamespaceOption) Resource[T]

+ func NewResource[T any](setter SetFunc[*T]) Resource[T]

+ type ResourceInitializer interface

+ type ResourceSlice interface

+ Initializer func() ResourceSliceInitializer[T]

+ WithLabels func(LabelsOption) ResourceSlice[T]

+ WithNamespace func(NamespaceOption) ResourceSlice[T]

+ func NewResourceSlice[T any](setter SetFunc[[]*T]) ResourceSlice[T]

+ type ResourceSliceInitializer interface

+ type Revision interface

+ Initializer func() RevisionInitializer[G]

+ WithCollisionCount func(CollisionCountOption) Revision[G]

+ WithCurrentRevision func(CurrentRevisionOption) Revision[G]

+ WithLabels func(LabelsOption) Revision[G]

+ WithParent func(ParentOption[G]) Revision[G]

+ func NewRevision[G runtime.Group](setter RevisionSetter) Revision[G]

+ type RevisionInitializer interface

+ CollisionCount func() *int32

+ CurrentRevision func() string

+ type RevisionSetter interface

+ Set func(update, current string, collisionCount int32)

+ type RevisionSetterFunc func(update, current string, collisionCount int32)

+ func (f RevisionSetterFunc) Set(update, current string, collisionCount int32)

+ type RevisionState interface

+ Revision func() (update, current string, collisionCount int32)

+ type RevisionStateInitializer interface

+ RevisionInitializer func() RevisionInitializer[G]

+ type ServerLabelsState interface

+ GetServerLabels func() map[string]string

+ type ServerLabelsUpdater interface

+ type SetFunc func(T)

+ func (f SetFunc[T]) Set(obj T)

+ type Setter interface

+ Set func(T)

+ type SliceState interface

+ InstanceSlice func() []F

+ type StatusPersister interface

+ IsStatusChanged func() bool

+ Object func() T

+ type StatusRevisionAndReplicasUpdater interface

+ Object func() G

+ type StatusUpdater interface

+ SetStatusChanged func()

+ type StoreState interface

+ GetLeaderCount func() int

+ GetRegionCount func() int

+ GetStoreState func() pdv1.NodeState

+ IsStoreBusy func() bool

+ IsStoreUp func() bool

+ type StoreStateUpdater interface

+ SetLeaderCount func(int)

+ SetRegionCount func(int)

+ SetStoreBusy func(bool)

+ SetStoreState func(pdv1.NodeState)

+ type TaskPVCState interface

+ type TiCDCGroupState interface

+ TiCDCGroup func() *v1alpha1.TiCDCGroup

+ type TiCDCSliceInitializer = ResourceSliceInitializer[v1alpha1.TiCDC]

+ type TiCDCSliceState interface

+ TiCDCSlice func() []*v1alpha1.TiCDC

+ type TiCDCSliceStateInitializer interface

+ TiCDCSliceInitializer func() TiCDCSliceInitializer

+ type TiCDCState interface

+ TiCDC func() *v1alpha1.TiCDC

+ type TiDBGroupState interface

+ TiDBGroup func() *v1alpha1.TiDBGroup

+ type TiDBSliceInitializer = ResourceSliceInitializer[v1alpha1.TiDB]

+ type TiDBSliceState interface

+ TiDBSlice func() []*v1alpha1.TiDB

+ type TiDBSliceStateInitializer interface

+ TiDBSliceInitializer func() TiDBSliceInitializer

+ type TiDBState interface

+ TiDB func() *v1alpha1.TiDB

+ type TiFlashGroupState interface

+ TiFlashGroup func() *v1alpha1.TiFlashGroup

+ type TiFlashSliceInitializer = ResourceSliceInitializer[v1alpha1.TiFlash]

+ type TiFlashSliceState interface

+ TiFlashSlice func() []*v1alpha1.TiFlash

+ type TiFlashSliceStateInitializer interface

+ TiFlashSliceInitializer func() TiFlashSliceInitializer

+ type TiFlashState interface

+ TiFlash func() *v1alpha1.TiFlash

+ type TiKVGroupState interface

+ TiKVGroup func() *v1alpha1.TiKVGroup

+ type TiKVSliceInitializer = ResourceSliceInitializer[v1alpha1.TiKV]

+ type TiKVSliceState interface

+ TiKVSlice func() []*v1alpha1.TiKV

+ type TiKVSliceStateInitializer interface

+ TiKVSliceInitializer func() TiKVSliceInitializer

+ type TiKVState interface

+ TiKV func() *v1alpha1.TiKV

+ type TiProxyGroupState interface

+ TiProxyGroup func() *v1alpha1.TiProxyGroup

+ type TiProxySliceInitializer = ResourceSliceInitializer[v1alpha1.TiProxy]

+ type TiProxySliceState interface

+ TiProxySlice func() []*v1alpha1.TiProxy

+ type TiProxySliceStateInitializer interface

+ TiProxySliceInitializer func() TiProxySliceInitializer

+ type TiProxyState interface

+ TiProxy func() *v1alpha1.TiProxy

+ type TrackState interface

+ Key func() types.NamespacedName

v2.0.0-beta.10

Dec 5, 2025