stateful

May 25, 2023

Changes in this version

+ func NewStatefulComponent(cli client.Client, cluster *appsv1alpha1.Cluster, ...) (types.Component, error)

+ type StatefulComponent types.ComponentBase

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