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.

Index

• Constants
• Variables
• func AddToManager(m manager.Manager) error
• func ClusterOwnerRef(clusterName, clusterID string) metav1.OwnerReference
• type ClusterController
  • func NewClusterController(context *clusterd.Context, rookImage string, ...) *ClusterController
  • func (c *ClusterController) GetClusterCount() int
  • func (c *ClusterController) StartWatch(namespace string, stopCh chan struct{})
  • func (c *ClusterController) StopWatch()

Constants

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

Variables

var AddToManagerFuncs = []func(manager.Manager) error{
	crash.Add,
}

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

var ClusterResource = k8sutil.CustomResource{
	Name:    "cephcluster",
	Plural:  "cephclusters",
	Group:   cephv1.CustomResourceGroup,
	Version: cephv1.Version,
	Kind:    reflect.TypeOf(cephv1.CephCluster{}).Name(),
}

ClusterResource operator-kit Custom Resource Definition

Functions

func AddToManager

func AddToManager(m manager.Manager) 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 ClusterOwnerRef

func ClusterOwnerRef(clusterName, clusterID string) metav1.OwnerReference

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, addClusterCallbacks []func(*cephv1.ClusterSpec) error, removeClusterCallbacks []func() error) *ClusterController

NewClusterController create controller for watching cluster custom resources created

func (*ClusterController) GetClusterCount

func (c *ClusterController) GetClusterCount() int

func (*ClusterController) StartWatch

func (c *ClusterController) StartWatch(namespace string, stopCh chan struct{})

StartWatch watches instances of cluster resources

func (*ClusterController) StopWatch

func (c *ClusterController) StopWatch()