stateful

Documentation

Index

• func NewStatefulComponent(cli client.Client, cluster *appsv1alpha1.Cluster, ...) (types.Component, error)
• type StatefulComponent
  • func (r *StatefulComponent) GetPhaseWhenPodsNotReady(ctx context.Context, componentName string) (appsv1alpha1.ClusterComponentPhase, error)
  • func (r *StatefulComponent) HandleProbeTimeoutWhenPodsReady(ctx context.Context, recorder record.EventRecorder) (bool, error)
  • func (r *StatefulComponent) HandleUpdate(ctx context.Context, obj client.Object) error
  • func (r *StatefulComponent) HandleUpdateWithProcessors(ctx context.Context, obj client.Object, ...) error
  • func (r *StatefulComponent) IsRunning(ctx context.Context, obj client.Object) (bool, error)
  • func (r *StatefulComponent) PodIsAvailable(pod *corev1.Pod, minReadySeconds int32) bool
  • func (r *StatefulComponent) PodsReady(ctx context.Context, obj client.Object) (bool, error)

Functions

func NewStatefulComponent

func NewStatefulComponent(
	cli client.Client,
	cluster *appsv1alpha1.Cluster,
	component *appsv1alpha1.ClusterComponentSpec,
	componentDef appsv1alpha1.ClusterComponentDefinition,
) (types.Component, error)

Types

type StatefulComponent

type StatefulComponent types.ComponentBase

func (*StatefulComponent) GetPhaseWhenPodsNotReady

func (r *StatefulComponent) GetPhaseWhenPodsNotReady(ctx context.Context, componentName string) (appsv1alpha1.ClusterComponentPhase, error)

GetPhaseWhenPodsNotReady gets the component phase when the pods of component are not ready.

func (*StatefulComponent) HandleProbeTimeoutWhenPodsReady

func (r *StatefulComponent) HandleProbeTimeoutWhenPodsReady(ctx context.Context, recorder record.EventRecorder) (bool, error)

HandleProbeTimeoutWhenPodsReady the Stateful component has no role detection, empty implementation here.

func (*StatefulComponent) HandleUpdate

func (r *StatefulComponent) HandleUpdate(ctx context.Context, obj client.Object) error

func (*StatefulComponent) HandleUpdateWithProcessors

func (r *StatefulComponent) HandleUpdateWithProcessors(ctx context.Context, obj client.Object,
	compStatusProcessor func(compDef *appsv1alpha1.ClusterComponentDefinition, pods []corev1.Pod, componentName string) error,
	priorityMapper func(component *appsv1alpha1.ClusterComponentDefinition) map[string]int,
	serialStrategyHandler, bestEffortParallelStrategyHandler, parallelStrategyHandler func(plan *util.Plan, pods []corev1.Pod, rolePriorityMap map[string]int)) error

HandleUpdateWithProcessors extended HandleUpdate() with custom processors REVIEW/TODO: (nashtsai)

1. too many args

func (*StatefulComponent) IsRunning

func (r *StatefulComponent) IsRunning(ctx context.Context, obj client.Object) (bool, error)

func (*StatefulComponent) PodIsAvailable

func (r *StatefulComponent) PodIsAvailable(pod *corev1.Pod, minReadySeconds int32) bool

func (*StatefulComponent) PodsReady

func (r *StatefulComponent) PodsReady(ctx context.Context, obj client.Object) (bool, error)