stateless

Documentation

Index

• Constants
• func NewStatelessComponent(cli client.Client, cluster *appsv1alpha1.Cluster, ...) (types.Component, error)
• type StatelessComponent
  • func (stateless *StatelessComponent) GetPhaseWhenPodsNotReady(ctx context.Context, componentName string) (appsv1alpha1.ClusterComponentPhase, error)
  • func (stateless *StatelessComponent) HandleProbeTimeoutWhenPodsReady(ctx context.Context, recorder record.EventRecorder) (bool, error)
  • func (stateless *StatelessComponent) HandleUpdate(ctx context.Context, obj client.Object) error
  • func (stateless *StatelessComponent) IsRunning(ctx context.Context, obj client.Object) (bool, error)
  • func (stateless *StatelessComponent) PodIsAvailable(pod *corev1.Pod, minReadySeconds int32) bool
  • func (stateless *StatelessComponent) PodsReady(ctx context.Context, obj client.Object) (bool, error)

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,
	component *appsv1alpha1.ClusterComponentSpec,
	componentDef appsv1alpha1.ClusterComponentDefinition) (types.Component, error)

Types

type StatelessComponent

type StatelessComponent types.ComponentBase

func (*StatelessComponent) GetPhaseWhenPodsNotReady

func (stateless *StatelessComponent) GetPhaseWhenPodsNotReady(ctx context.Context,
	componentName string) (appsv1alpha1.ClusterComponentPhase, error)

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

func (*StatelessComponent) HandleProbeTimeoutWhenPodsReady

func (stateless *StatelessComponent) HandleProbeTimeoutWhenPodsReady(ctx context.Context,
	recorder record.EventRecorder) (bool, error)

HandleProbeTimeoutWhenPodsReady the stateless component has no role detection, empty implementation here.

func (*StatelessComponent) HandleUpdate

func (stateless *StatelessComponent) HandleUpdate(ctx context.Context, obj client.Object) error

func (*StatelessComponent) IsRunning

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

func (*StatelessComponent) PodIsAvailable

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

func (*StatelessComponent) PodsReady

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