cluster

Documentation

Overview

Package cluster to manage Kubernetes storage.

Package cluster to manage a Ceph cluster.

Package cluster to manage a Ceph cluster.

Package cluster to manage a Ceph cluster.

Package cluster to manage a Ceph cluster.

Package cluster to manage a Ceph cluster.

Package cluster to manage a Ceph cluster.

Package cluster to manage a Ceph cluster.

Package cluster to manage a Ceph cluster.

Package cluster to manage a Ceph cluster.

Index

• Constants
• Variables
• func Add(mgr manager.Manager, ctx *clusterd.Context, ...) error
• func AddToManager(m manager.Manager, c *controllerconfig.Context, ...) error
• func CephClusterDependents(c *clusterd.Context, namespace string) (*dependents.DependentList, error)
• type ClusterController
  • func NewClusterController(context *clusterd.Context, rookImage string, ...) *ClusterController
  • func (c *ClusterController) StartOperatorSettingsWatch(stopCh chan struct{})
  • func (c *ClusterController) StopWatch()
• type ReconcileCephCluster
  • func (r *ReconcileCephCluster) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)

Constants

const (

	// CleanupAppName is the cluster clean up job name
	CleanupAppName = "rook-ceph-cleanup"
)

const (
	// DefaultClusterName states the default name of the rook-cluster if not provided.
	DefaultClusterName = "rook-ceph"
)

Variables

var AddToManagerFuncs = []func(manager.Manager, *clusterd.Context) error{
	crash.Add,
	pool.Add,
	objectuser.Add,
	realm.Add,
	zonegroup.Add,
	zone.Add,
	object.Add,
	file.Add,
	nfs.Add,
	rbd.Add,
	client.Add,
	mirror.Add,
}

AddToManagerFuncs is a list of functions to add all Controllers to the Manager (entrypoint for controller)

var AddToManagerFuncsMaintenance = []func(manager.Manager, *controllerconfig.Context) error{
	clusterdisruption.Add,
}

AddToManagerFuncsMaintenance is a list of functions to add all Controllers to the Manager (entrypoint for controller)

var ControllerTypeMeta = metav1.TypeMeta{
	Kind:       opcontroller.ClusterResource.Kind,
	APIVersion: opcontroller.ClusterResource.APIVersion,
}

ControllerTypeMeta Sets the type meta for the controller main object

var (
	// EnableMachineDisruptionBudget checks whether machine disruption budget is enabled
	EnableMachineDisruptionBudget bool
)

var MachineDisruptionBudgetAddToManagerFuncs = []func(manager.Manager, *controllerconfig.Context) error{
	machinelabel.Add,
	machinedisruption.Add,
}

MachineDisruptionBudgetAddToManagerFuncs is a list of fencing related functions to add all Controllers to the Manager (entrypoint for controller)

Functions

func Add

func Add(mgr manager.Manager, ctx *clusterd.Context, clusterController *ClusterController) error

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

func AddToManager

func AddToManager(m manager.Manager, c *controllerconfig.Context, clusterController *ClusterController) error

AddToManager adds all the registered controllers to the passed manager. each controller package will have an Add method listed in AddToManagerFuncs which will setup all the necessary watch

func CephClusterDependents

func CephClusterDependents(c *clusterd.Context, namespace string) (*dependents.DependentList, error)

CephClusterDependents returns a DependentList of dependents of a CephCluster in the namespace.

Types

type ClusterController

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

ClusterController controls an instance of a Rook cluster

func NewClusterController

func NewClusterController(context *clusterd.Context, rookImage string, volumeAttachment attachment.Attachment, operatorConfigCallbacks []func() error, addClusterCallbacks []func() error) *ClusterController

NewClusterController create controller for watching cluster custom resources created

func (*ClusterController) StartOperatorSettingsWatch

func (c *ClusterController) StartOperatorSettingsWatch(stopCh chan struct{})

StartOperatorSettingsWatch starts the operator settings watcher

func (*ClusterController) StopWatch

func (c *ClusterController) StopWatch()

StopWatch stop watchers

type ReconcileCephCluster

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

ReconcileCephCluster reconciles a CephFilesystem object

func (*ReconcileCephCluster) Reconcile

func (r *ReconcileCephCluster) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a CephCluster object and makes changes based on the state read and what is in the cephCluster.Spec 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.