stateless

Documentation

Index

• Constants
• func NewStatelessComponent(cli client.Client, recorder record.EventRecorder, ...) *statelessComponent
• type Stateless
  • func (stateless *Stateless) GetPhaseWhenPodsNotReady(ctx context.Context, componentName string, originPhaseIsUpRunning bool) (appsv1alpha1.ClusterComponentPhase, appsv1alpha1.ComponentMessageMap, error)
  • func (stateless *Stateless) GetPhaseWhenPodsReadyAndProbeTimeout(pods []*corev1.Pod) (appsv1alpha1.ClusterComponentPhase, appsv1alpha1.ComponentMessageMap)
  • func (stateless *Stateless) HandleHA(ctx context.Context, obj client.Object) ([]graph.Vertex, error)
  • func (stateless *Stateless) HandleRestart(context.Context, client.Object) ([]graph.Vertex, error)
  • func (stateless *Stateless) HandleRoleChange(context.Context, client.Object) ([]graph.Vertex, error)
  • func (stateless *Stateless) IsRunning(ctx context.Context, obj client.Object) (bool, error)
  • func (stateless *Stateless) PodIsAvailable(pod *corev1.Pod, minReadySeconds int32) bool
  • func (stateless *Stateless) PodsReady(ctx context.Context, obj client.Object) (bool, error)
  • func (stateless *Stateless) SetComponent(comp types.Component)

Constants

const NewRSAvailableReason = "NewReplicaSetAvailable"

NewRSAvailableReason is added in a deployment when its newest replica set is made available ie. the number of new pods that have passed readiness checks and run for at least minReadySeconds is at least the minimum available pods that need to run for the deployment.

Functions

func NewStatelessComponent

func NewStatelessComponent(cli client.Client,
	recorder record.EventRecorder,
	cluster *appsv1alpha1.Cluster,
	clusterVersion *appsv1alpha1.ClusterVersion,
	synthesizedComponent *component.SynthesizedComponent,
	dag *graph.DAG) *statelessComponent

Types

type Stateless

type Stateless struct {
	types.ComponentSetBase
}

func (*Stateless) GetPhaseWhenPodsNotReady

func (stateless *Stateless) GetPhaseWhenPodsNotReady(ctx context.Context,
	componentName string,
	originPhaseIsUpRunning bool) (appsv1alpha1.ClusterComponentPhase, appsv1alpha1.ComponentMessageMap, error)

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

func (*Stateless) GetPhaseWhenPodsReadyAndProbeTimeout

func (stateless *Stateless) GetPhaseWhenPodsReadyAndProbeTimeout(pods []*corev1.Pod) (appsv1alpha1.ClusterComponentPhase, appsv1alpha1.ComponentMessageMap)

func (*Stateless) HandleHA

func (stateless *Stateless) HandleHA(ctx context.Context, obj client.Object) ([]graph.Vertex, error)

func (*Stateless) HandleRestart

func (stateless *Stateless) HandleRestart(context.Context, client.Object) ([]graph.Vertex, error)

func (*Stateless) HandleRoleChange

func (stateless *Stateless) HandleRoleChange(context.Context, client.Object) ([]graph.Vertex, error)

func (*Stateless) IsRunning

func (stateless *Stateless) IsRunning(ctx context.Context, obj client.Object) (bool, error)

func (*Stateless) PodIsAvailable

func (stateless *Stateless) PodIsAvailable(pod *corev1.Pod, minReadySeconds int32) bool

func (*Stateless) PodsReady

func (stateless *Stateless) PodsReady(ctx context.Context, obj client.Object) (bool, error)

func (*Stateless) SetComponent

func (stateless *Stateless) SetComponent(comp types.Component)