statefulset

Documentation

Index

• Constants
• func NewStatefulSetReconciler(mgr manager.Manager, cs clients.ClientSet) reconciler.SecondaryResourceReconciler
• type ByNodeLabelUpgradeStrategy
  • func (in ByNodeLabelUpgradeStrategy) IsOperatorManaged() bool
  • func (in ByNodeLabelUpgradeStrategy) RollingUpgrade(ctx context.Context, sts *appsv1.StatefulSet, c kubernetes.Interface) (reconcile.Result, error)
• type ByNodeUpgradeStrategy
  • func (in ByNodeUpgradeStrategy) IsOperatorManaged() bool
  • func (in ByNodeUpgradeStrategy) RollingUpgrade(ctx context.Context, sts *appsv1.StatefulSet, c kubernetes.Interface) (reconcile.Result, error)
• type ByPodUpgradeStrategy
  • func (in ByPodUpgradeStrategy) IsOperatorManaged() bool
  • func (in ByPodUpgradeStrategy) RollingUpgrade(context.Context, *appsv1.StatefulSet, kubernetes.Interface) (reconcile.Result, error)
• type ManualUpgradeStrategy
  • func (in ManualUpgradeStrategy) IsOperatorManaged() bool
  • func (in ManualUpgradeStrategy) RollingUpgrade(context.Context, *appsv1.StatefulSet, kubernetes.Interface) (reconcile.Result, error)
• type PodNodeIdSupplier
• type PodNodeLabel
  • func (p *PodNodeLabel) GetNodeId(ctx context.Context, c kubernetes.Interface, pod corev1.Pod) (string, error)
• type PodNodeName
  • func (p *PodNodeName) GetNodeId(_ context.Context, _ kubernetes.Interface, pod corev1.Pod) (string, error)
• type ReconcileStatefulSet
  • func (in *ReconcileStatefulSet) GetReconciler() reconcile.Reconciler
  • func (in *ReconcileStatefulSet) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (in *ReconcileStatefulSet) ReconcileAllResourceOfKind(ctx context.Context, request reconcile.Request, ...) (reconcile.Result, error)
• type UpgradeStrategy
  • func GetUpgradeStrategy(c coh.CoherenceResource, p probe.CoherenceProbe) UpgradeStrategy

Constants

const (
	CreateMessage        string = "successfully created StatefulSet for Coherence resource '%s'"
	FailedToScaleMessage string = "failed to scale Coherence resource %s from %d to %d due to error\n%s"
	FailedToPatchMessage string = "failed to patch Coherence resource %s due to error\n%s"

	EventReasonScale string = "Scaling"
)

Functions

func NewStatefulSetReconciler

func NewStatefulSetReconciler(mgr manager.Manager, cs clients.ClientSet) reconciler.SecondaryResourceReconciler

NewStatefulSetReconciler returns a new StatefulSet reconciler.

Types

type ByNodeLabelUpgradeStrategy

type ByNodeLabelUpgradeStrategy struct {
	// contains filtered or unexported fields
}

func (ByNodeLabelUpgradeStrategy) IsOperatorManaged

func (in ByNodeLabelUpgradeStrategy) IsOperatorManaged() bool

func (ByNodeLabelUpgradeStrategy) RollingUpgrade

func (in ByNodeLabelUpgradeStrategy) RollingUpgrade(ctx context.Context, sts *appsv1.StatefulSet, c kubernetes.Interface) (reconcile.Result, error)

type ByNodeUpgradeStrategy

type ByNodeUpgradeStrategy struct {
	// contains filtered or unexported fields
}

func (ByNodeUpgradeStrategy) IsOperatorManaged

func (in ByNodeUpgradeStrategy) IsOperatorManaged() bool

func (ByNodeUpgradeStrategy) RollingUpgrade

func (in ByNodeUpgradeStrategy) RollingUpgrade(ctx context.Context, sts *appsv1.StatefulSet, c kubernetes.Interface) (reconcile.Result, error)

type ByPodUpgradeStrategy

type ByPodUpgradeStrategy struct {
}

func (ByPodUpgradeStrategy) IsOperatorManaged

func (in ByPodUpgradeStrategy) IsOperatorManaged() bool

func (ByPodUpgradeStrategy) RollingUpgrade

func (in ByPodUpgradeStrategy) RollingUpgrade(context.Context, *appsv1.StatefulSet, kubernetes.Interface) (reconcile.Result, error)

type ManualUpgradeStrategy

type ManualUpgradeStrategy struct {
}

func (ManualUpgradeStrategy) IsOperatorManaged

func (in ManualUpgradeStrategy) IsOperatorManaged() bool

func (ManualUpgradeStrategy) RollingUpgrade

func (in ManualUpgradeStrategy) RollingUpgrade(context.Context, *appsv1.StatefulSet, kubernetes.Interface) (reconcile.Result, error)

type PodNodeIdSupplier

type PodNodeIdSupplier interface {
	GetNodeId(context.Context, kubernetes.Interface, corev1.Pod) (string, error)
}

type PodNodeLabel

type PodNodeLabel struct {
	Label string
	// contains filtered or unexported fields
}

func (*PodNodeLabel) GetNodeId

func (p *PodNodeLabel) GetNodeId(ctx context.Context, c kubernetes.Interface, pod corev1.Pod) (string, error)

type PodNodeName

type PodNodeName struct {
}

func (*PodNodeName) GetNodeId

func (p *PodNodeName) GetNodeId(_ context.Context, _ kubernetes.Interface, pod corev1.Pod) (string, error)

type ReconcileStatefulSet

type ReconcileStatefulSet struct {
	reconciler.ReconcileSecondaryResource
	// contains filtered or unexported fields
}

func (*ReconcileStatefulSet) GetReconciler

func (in *ReconcileStatefulSet) GetReconciler() reconcile.Reconciler

func (*ReconcileStatefulSet) Reconcile

func (in *ReconcileStatefulSet) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the Services for a deployment and makes changes based on the state read and the desired state based on the parent Coherence resource.

func (*ReconcileStatefulSet) ReconcileAllResourceOfKind

func (in *ReconcileStatefulSet) ReconcileAllResourceOfKind(ctx context.Context, request reconcile.Request, deployment coh.CoherenceResource, storage utils.Storage) (reconcile.Result, error)

ReconcileAllResourceOfKind will process the specified reconcile request for the specified deployment. The previous state being reconciled can be obtained from the storage parameter.

type UpgradeStrategy

type UpgradeStrategy interface {
	IsOperatorManaged() bool
	RollingUpgrade(context.Context, *appsv1.StatefulSet, kubernetes.Interface) (reconcile.Result, error)
}

func GetUpgradeStrategy

func GetUpgradeStrategy(c coh.CoherenceResource, p probe.CoherenceProbe) UpgradeStrategy