Documentation ¶
Overview ¶
Package pool to manage a rook pool.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var PoolResource = k8sutil.CustomResource{ Name: "cephblockpool", Plural: "cephblockpools", Group: cephv1.CustomResourceGroup, Version: cephv1.Version, Kind: reflect.TypeOf(cephv1.CephBlockPool{}).Name(), }
PoolResource represents the Pool custom resource object
Functions ¶
func ValidatePool ¶
func ValidatePool(context *clusterd.Context, p *cephv1.CephBlockPool) error
Validate the pool arguments
Types ¶
type PoolController ¶
type PoolController struct {
// contains filtered or unexported fields
}
PoolController represents a controller object for pool custom resources
func NewPoolController ¶
func NewPoolController(context *clusterd.Context, clusterSpec *cephv1.ClusterSpec) *PoolController
NewPoolController create controller for watching pool custom resources created
func (*PoolController) ParentClusterChanged ¶
func (c *PoolController) ParentClusterChanged(cluster cephv1.ClusterSpec, clusterInfo *cephconfig.ClusterInfo, isUpgrade bool)
ParentClusterChanged determines wether or not a CR update has been sent
func (*PoolController) StartWatch ¶
func (c *PoolController) StartWatch(namespace string, stopCh chan struct{})
Watch watches for instances of Pool custom resources and acts on them
Click to show internal directories.
Click to hide internal directories.