Documentation
¶
Index ¶
- Constants
- type OriginPodHandler
- func (p *OriginPodHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
- func (p *OriginPodHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
- func (p *OriginPodHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
- func (p *OriginPodHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
- type PodReplaceHandler
- func (p *PodReplaceHandler) GetOpsProgress(ctx context.Context, candidate *OpsCandidate, ...) (progress ActionProgress, err error)
- func (p *PodReplaceHandler) OperateTargets(ctx context.Context, candidates []*OpsCandidate, ...) map[string]error
- func (p *PodReplaceHandler) ReleaseTargets(ctx context.Context, candidates []*OpsCandidate, ...) map[string]error
- func (p *PodReplaceHandler) Setup(controller controller.Controller, reconcileMixin *mixin.ReconcilerMixin) error
Constants ¶
View Source
const (
ExtraInfoNotAllowedToReplaceNewPod = "NotAllowedToReplaceNewPod"
)
View Source
const (
OperationJobReplacePodFinalizer = "finalizer.operationjob.kusionstack.io/replace-protected"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OriginPodHandler ¶
func (*OriginPodHandler) Create ¶
func (p *OriginPodHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
func (*OriginPodHandler) Delete ¶
func (p *OriginPodHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
func (*OriginPodHandler) Generic ¶
func (p *OriginPodHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
func (*OriginPodHandler) Update ¶
func (p *OriginPodHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
type PodReplaceHandler ¶
type PodReplaceHandler struct {
// contains filtered or unexported fields
}
func (*PodReplaceHandler) GetOpsProgress ¶
func (p *PodReplaceHandler) GetOpsProgress(ctx context.Context, candidate *OpsCandidate, operationJob *appsv1alpha1.OperationJob) (progress ActionProgress, err error)
func (*PodReplaceHandler) OperateTargets ¶ added in v0.6.1
func (p *PodReplaceHandler) OperateTargets(ctx context.Context, candidates []*OpsCandidate, operationJob *appsv1alpha1.OperationJob) map[string]error
func (*PodReplaceHandler) ReleaseTargets ¶ added in v0.6.1
func (p *PodReplaceHandler) ReleaseTargets(ctx context.Context, candidates []*OpsCandidate, operationJob *appsv1alpha1.OperationJob) map[string]error
func (*PodReplaceHandler) Setup ¶ added in v0.6.0
func (p *PodReplaceHandler) Setup(controller controller.Controller, reconcileMixin *mixin.ReconcilerMixin) error
Source Files
Click to show internal directories.
Click to hide internal directories.