bookkeepercluster

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• func MakeBookieConfigMap(bookkeeperCluster *v1alpha1.BookkeeperCluster) *corev1.ConfigMap
• func MakeBookieHeadlessService(bookkeeperCluster *v1alpha1.BookkeeperCluster) *corev1.Service
• func MakeBookiePodDisruptionBudget(bookkeeperCluster *v1alpha1.BookkeeperCluster) *policyv1beta1.PodDisruptionBudget
• func MakeBookiePodTemplate(p *v1alpha1.BookkeeperCluster) corev1.PodTemplateSpec
• func MakeBookieStatefulSet(bookkeeperCluster *v1alpha1.BookkeeperCluster) *appsv1.StatefulSet
• type ReconcileBookkeeperCluster
  • func (r *ReconcileBookkeeperCluster) Reconcile(request reconcile.Request) (reconcile.Result, error)

Constants

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

const ReconcileTime = 30 * time.Second

ReconcileTime is the delay between reconciliations

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new bookkeeperCluster Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func MakeBookieConfigMap

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

func MakeBookieHeadlessService

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

func MakeBookiePodDisruptionBudget

func MakeBookiePodDisruptionBudget(bookkeeperCluster *v1alpha1.BookkeeperCluster) *policyv1beta1.PodDisruptionBudget

func MakeBookiePodTemplate

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

func MakeBookieStatefulSet

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

Types

type ReconcileBookkeeperCluster

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

ReconcileBookkeeperCluster reconciles a BookkeeperCluster object

func (*ReconcileBookkeeperCluster) Reconcile

func (r *ReconcileBookkeeperCluster) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a BookkeeperCluster object and makes changes based on the state read and what is in the BookkeeperCluster.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.