stateless

Documentation

Index

• Constants
• func NewStatelessComponent(cli client.Client, cluster *appsv1alpha1.Cluster, ...) *statelessComponent
• type Stateless
  • func (stateless *Stateless) GetPhaseWhenPodsNotReady(ctx context.Context, componentName string) (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,
	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) (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)