rsm

Aug 18, 2023

Changes in this version

+ var ErrContinue error

+ var ErrStop = errors.New("stop")

+ var ErrWait = errors.New("wait")

+ func NewRSMPlanBuilder(ctx intctrlutil.RequestCtx, cli client.Client, req ctrl.Request) graph.PlanBuilder

+ type EnqueueRequestForAncestor struct

+ Client roclient.ReadonlyClient

+ InTypes []runtime.Object

+ OwnerType runtime.Object

+ UpToLevel int

+ func (e *EnqueueRequestForAncestor) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForAncestor) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForAncestor) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestForAncestor) InjectMapper(m meta.RESTMapper) error

+ func (e *EnqueueRequestForAncestor) InjectScheme(s *runtime.Scheme) error

+ func (e *EnqueueRequestForAncestor) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

+ type FixMetaTransformer struct

+ func (t *FixMetaTransformer) Transform(ctx graph.TransformContext, dag *graph.DAG) error

+ type MemberReconfigurationTransformer struct

+ func (t *MemberReconfigurationTransformer) Transform(ctx graph.TransformContext, dag *graph.DAG) error

+ type ObjectDeletionTransformer struct

+ func (t *ObjectDeletionTransformer) Transform(ctx graph.TransformContext, dag *graph.DAG) error

+ type ObjectGenerationTransformer struct

+ func (t *ObjectGenerationTransformer) Transform(ctx graph.TransformContext, dag *graph.DAG) error

+ type ObjectStatusTransformer struct

+ func (t *ObjectStatusTransformer) Transform(ctx graph.TransformContext, dag *graph.DAG) error

+ type Plan struct

+ func (p *Plan) Execute() error

+ type PlanBuilder struct

+ func (b *PlanBuilder) AddParallelTransformer(transformer ...graph.Transformer) graph.PlanBuilder

+ func (b *PlanBuilder) AddTransformer(transformer ...graph.Transformer) graph.PlanBuilder

+ func (b *PlanBuilder) Build() (graph.Plan, error)

+ func (b *PlanBuilder) Init() error

+ type PodRoleEventHandler struct

+ func (h *PodRoleEventHandler) Handle(cli client.Client, reqCtx intctrlutil.RequestCtx, ...) error

+ type UpdateStrategyTransformer struct

+ func (t *UpdateStrategyTransformer) Transform(ctx graph.TransformContext, dag *graph.DAG) error