controllers

Documentation

Index

• Constants
• func MakeBookieConfigMap(bk *v1alpha1.BookkeeperCluster) *corev1.ConfigMap
• func MakeBookieHeadlessService(bk *v1alpha1.BookkeeperCluster) *corev1.Service
• func MakeBookiePodDisruptionBudget(bk *v1alpha1.BookkeeperCluster) *policyv1.PodDisruptionBudget
• func MakeBookiePodTemplate(bk *v1alpha1.BookkeeperCluster) corev1.PodTemplateSpec
• func MakeBookieStatefulSet(bk *v1alpha1.BookkeeperCluster) *appsv1.StatefulSet
• type BookkeeperClusterReconciler
  • func (r *BookkeeperClusterReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *BookkeeperClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	LedgerDiskName  = "ledger"
	JournalDiskName = "journal"
	IndexDiskName   = "index"
)

const ReconcileTime = 30 * time.Second

ReconcileTime is the delay between reconciliations

Functions

func MakeBookieConfigMap

func MakeBookieConfigMap(bk *v1alpha1.BookkeeperCluster) *corev1.ConfigMap

func MakeBookieHeadlessService

func MakeBookieHeadlessService(bk *v1alpha1.BookkeeperCluster) *corev1.Service

func MakeBookiePodDisruptionBudget

func MakeBookiePodDisruptionBudget(bk *v1alpha1.BookkeeperCluster) *policyv1.PodDisruptionBudget

func MakeBookiePodTemplate

func MakeBookiePodTemplate(bk *v1alpha1.BookkeeperCluster) corev1.PodTemplateSpec

func MakeBookieStatefulSet

func MakeBookieStatefulSet(bk *v1alpha1.BookkeeperCluster) *appsv1.StatefulSet

Types

type BookkeeperClusterReconciler

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

BookkeeperClusterReconciler reconciles a BookkeeperCluster object

func (*BookkeeperClusterReconciler) Reconcile

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

func (*BookkeeperClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.