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) 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) 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)