rsm

Jan 12, 2024

Changes in this version

+ const FeatureGateRSMToPod

+ func ConvertRSMToSTS(rsm *workloads.ReplicatedStateMachine) *appsv1.StatefulSet

+ func FilterActivePods(pods []corev1.Pod) []*corev1.Pod

+ func GetPodsLabels(labels map[string]string) client.MatchingLabels

+ func IsPodActive(p *corev1.Pod) bool

Nov 24, 2023

Changes in this version

+ func IsOwnedByRsm(obj client.Object) bool

Nov 3, 2023

Changes in this version

+ const FeatureGateRSMCompatibilityMode

+ const RoleUpdateMechanismVarName

+ var ErrContinue error

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

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

+ func AddAnnotationScope(scope AnnotationScope, annotations map[string]string) map[string]string

+ func ComposeRolePriorityMap(roles []workloads.ReplicaRole) map[string]int

+ func CopyOwnership(owner, obj client.Object, scheme *runtime.Scheme, finalizer string) error

+ func IsRSMReady(rsm *workloads.ReplicatedStateMachine) bool

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

+ func ParseAnnotationsOfScope(scope AnnotationScope, scopedAnnotations map[string]string) map[string]string

+ func SortPods(pods []corev1.Pod, rolePriorityMap map[string]int, reverse bool)

+ type AnnotationScope string

+ const AlternativeServiceScope

+ const ConfigMapScope

+ const HeadlessServiceScope

+ const RootScope

+ const ServiceScope

+ 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