Documentation ¶
Index ¶
- func NewStatefulComponent(cli client.Client, recorder record.EventRecorder, ...) *statefulComponent
- type Stateful
- func (r *Stateful) GetPhaseWhenPodsNotReady(ctx context.Context, componentName string) (appsv1alpha1.ClusterComponentPhase, appsv1alpha1.ComponentMessageMap, error)
- func (r *Stateful) GetPhaseWhenPodsReadyAndProbeTimeout(pods []*corev1.Pod) (appsv1alpha1.ClusterComponentPhase, appsv1alpha1.ComponentMessageMap)
- func (r *Stateful) HandleHA(ctx context.Context, obj client.Object) ([]graph.Vertex, error)
- func (r *Stateful) HandleRestart(context.Context, client.Object) ([]graph.Vertex, error)
- func (r *Stateful) HandleRoleChange(context.Context, client.Object) ([]graph.Vertex, error)
- func (r *Stateful) HandleUpdate(ctx context.Context, obj client.Object) error
- func (r *Stateful) HandleUpdateWithProcessors(ctx context.Context, obj client.Object, ...) error
- func (r *Stateful) IsRunning(ctx context.Context, obj client.Object) (bool, error)
- func (r *Stateful) PodIsAvailable(pod *corev1.Pod, minReadySeconds int32) bool
- func (r *Stateful) PodsReady(ctx context.Context, obj client.Object) (bool, error)
- func (r *Stateful) SetComponent(comp types.Component)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewStatefulComponent ¶
func NewStatefulComponent(cli client.Client, recorder record.EventRecorder, cluster *appsv1alpha1.Cluster, clusterVersion *appsv1alpha1.ClusterVersion, synthesizedComponent *component.SynthesizedComponent, dag *graph.DAG) *statefulComponent
Types ¶
type Stateful ¶
type Stateful struct {
types.ComponentSetBase
}
func (*Stateful) GetPhaseWhenPodsNotReady ¶
func (r *Stateful) GetPhaseWhenPodsNotReady(ctx context.Context, componentName string) (appsv1alpha1.ClusterComponentPhase, appsv1alpha1.ComponentMessageMap, error)
GetPhaseWhenPodsNotReady gets the component phase when the pods of component are not ready.
func (*Stateful) GetPhaseWhenPodsReadyAndProbeTimeout ¶
func (r *Stateful) GetPhaseWhenPodsReadyAndProbeTimeout(pods []*corev1.Pod) (appsv1alpha1.ClusterComponentPhase, appsv1alpha1.ComponentMessageMap)
func (*Stateful) HandleRestart ¶
func (*Stateful) HandleRoleChange ¶
func (*Stateful) HandleUpdate ¶
func (*Stateful) HandleUpdateWithProcessors ¶
func (r *Stateful) 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 extends HandleUpdate() with custom processors REVIEW/TODO: (nashtsai)
- too many args
func (*Stateful) PodIsAvailable ¶
func (*Stateful) SetComponent ¶
Click to show internal directories.
Click to hide internal directories.