petset

Feb 20, 2024

Changes in this version

type StatefulPodControlObjectManager

+ GetPlacementPolicy func(name string) (*api.PlacementPolicy, error)

+ ListPods func(ns, labels string) (*v1.PodList, error)

Feb 7, 2024

Changes in this version

+ const MaxBatchSize

+ func ApplyRevision(set *api.PetSet, revision *apps.ControllerRevision) (*api.PetSet, error)

+ type PetSetControlInterface interface

+ AdoptOrphanRevisions func(set *api.PetSet, revisions []*apps.ControllerRevision) error

+ ListRevisions func(set *api.PetSet) ([]*apps.ControllerRevision, error)

+ UpdatePetSet func(ctx context.Context, set *api.PetSet, pods []*v1.Pod) (*apps.StatefulSetStatus, error)

+ func NewDefaultPetSetControl(podControl *StatefulPodControl, ...) PetSetControlInterface

+ type PetSetController struct

+ func NewPetSetController(ctx context.Context, podInformer coreinformers.PodInformer, ...) *PetSetController

+ func (ssc *PetSetController) Run(ctx context.Context, workers int)

+ type StatefulPodControl struct

+ func NewStatefulPodControl(client clientset.Interface, podLister corelisters.PodLister, ...) *StatefulPodControl

+ func NewStatefulPodControlFromManager(om StatefulPodControlObjectManager, recorder record.EventRecorder) *StatefulPodControl

+ func (spc *StatefulPodControl) ClaimsMatchRetentionPolicy(ctx context.Context, set *api.PetSet, pod *v1.Pod) (bool, error)

+ func (spc *StatefulPodControl) CreateStatefulPod(ctx context.Context, set *api.PetSet, pod *v1.Pod) error

+ func (spc *StatefulPodControl) DeleteStatefulPod(set *api.PetSet, pod *v1.Pod) error

+ func (spc *StatefulPodControl) PodClaimIsStale(set *api.PetSet, pod *v1.Pod) (bool, error)

+ func (spc *StatefulPodControl) UpdatePodClaimForRetentionPolicy(ctx context.Context, set *api.PetSet, pod *v1.Pod) error

+ func (spc *StatefulPodControl) UpdateStatefulPod(ctx context.Context, set *api.PetSet, pod *v1.Pod) error

+ type StatefulPodControlObjectManager interface

+ CreateClaim func(claim *v1.PersistentVolumeClaim) error

+ CreatePod func(ctx context.Context, pod *v1.Pod) error

+ DeletePod func(pod *v1.Pod) error

+ GetClaim func(namespace, claimName string) (*v1.PersistentVolumeClaim, error)

+ GetPod func(namespace, podName string) (*v1.Pod, error)

+ UpdateClaim func(claim *v1.PersistentVolumeClaim) error

+ UpdatePod func(pod *v1.Pod) error

+ type StatefulSetStatusUpdaterInterface interface

+ UpdateStatefulSetStatus func(ctx context.Context, set *api.PetSet, status *apps.StatefulSetStatus) error

+ func NewRealStatefulSetStatusUpdater(client versioned.Interface, setLister apilisters.PetSetLister) StatefulSetStatusUpdaterInterface