controllers

Documentation

Index

• Constants
• func MakeControllerConfigMap(p *api.PravegaCluster) *corev1.ConfigMap
• func MakeControllerDeployment(p *api.PravegaCluster) *appsv1.Deployment
• func MakeControllerPodDisruptionBudget(p *api.PravegaCluster) *policyv1.PodDisruptionBudget
• func MakeControllerPodTemplate(p *api.PravegaCluster) corev1.PodTemplateSpec
• func MakeControllerService(p *api.PravegaCluster) *corev1.Service
• func MakeSegmentStoreExternalServices(p *api.PravegaCluster) []*corev1.Service
• func MakeSegmentStoreHeadlessService(p *api.PravegaCluster) *corev1.Service
• func MakeSegmentStorePodTemplate(p *api.PravegaCluster) corev1.PodTemplateSpec
• func MakeSegmentStoreStatefulSet(p *api.PravegaCluster) *appsv1.StatefulSet
• func MakeSegmentstoreConfigMap(p *api.PravegaCluster) *corev1.ConfigMap
• func MakeSegmentstorePodDisruptionBudget(p *api.PravegaCluster) *policyv1.PodDisruptionBudget
• type PravegaClusterReconciler
  • func (r *PravegaClusterReconciler) IsAbove07STSPresent(p *pravegav1beta1.PravegaCluster) bool
  • func (r *PravegaClusterReconciler) IsClusterRollbackingFrom07(p *pravegav1beta1.PravegaCluster) bool
  • func (r *PravegaClusterReconciler) IsClusterUpgradingTo07(p *pravegav1beta1.PravegaCluster) bool
  • func (r *PravegaClusterReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *PravegaClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const ReconcileTime = 30 * time.Second

ReconcileTime is the delay between reconciliations

Functions

func MakeControllerConfigMap

func MakeControllerConfigMap(p *api.PravegaCluster) *corev1.ConfigMap

func MakeControllerDeployment

func MakeControllerDeployment(p *api.PravegaCluster) *appsv1.Deployment

func MakeControllerPodDisruptionBudget

func MakeControllerPodDisruptionBudget(p *api.PravegaCluster) *policyv1.PodDisruptionBudget

func MakeControllerPodTemplate

func MakeControllerPodTemplate(p *api.PravegaCluster) corev1.PodTemplateSpec

func MakeControllerService

func MakeControllerService(p *api.PravegaCluster) *corev1.Service

func MakeSegmentStoreExternalServices

func MakeSegmentStoreExternalServices(p *api.PravegaCluster) []*corev1.Service

func MakeSegmentStoreHeadlessService

func MakeSegmentStoreHeadlessService(p *api.PravegaCluster) *corev1.Service

func MakeSegmentStorePodTemplate

func MakeSegmentStorePodTemplate(p *api.PravegaCluster) corev1.PodTemplateSpec

func MakeSegmentStoreStatefulSet

func MakeSegmentStoreStatefulSet(p *api.PravegaCluster) *appsv1.StatefulSet

func MakeSegmentstoreConfigMap

func MakeSegmentstoreConfigMap(p *api.PravegaCluster) *corev1.ConfigMap

func MakeSegmentstorePodDisruptionBudget

func MakeSegmentstorePodDisruptionBudget(p *api.PravegaCluster) *policyv1.PodDisruptionBudget

Types

type PravegaClusterReconciler

type PravegaClusterReconciler struct {
	Client client.Client
	Scheme *runtime.Scheme
}

PravegaClusterReconciler reconciles a PravegaCluster object

func (*PravegaClusterReconciler) IsAbove07STSPresent

func (r *PravegaClusterReconciler) IsAbove07STSPresent(p *pravegav1beta1.PravegaCluster) bool

This function checks if stsabove07 exsists

func (*PravegaClusterReconciler) IsClusterRollbackingFrom07

func (r *PravegaClusterReconciler) IsClusterRollbackingFrom07(p *pravegav1beta1.PravegaCluster) bool

this function is to check are we doing a rollback in case of a upgrade failure while upgrading from a version below 07 to a version above 07

func (*PravegaClusterReconciler) IsClusterUpgradingTo07

func (r *PravegaClusterReconciler) IsClusterUpgradingTo07(p *pravegav1beta1.PravegaCluster) bool

this function will return true only in case of upgrading from a version below 0.7 to pravega version 0.7 or later

func (*PravegaClusterReconciler) Reconcile

func (r *PravegaClusterReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the PravegaCluster object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.0/pkg/reconcile

func (*PravegaClusterReconciler) SetupWithManager

func (r *PravegaClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.