Versions in this module Expand all Collapse all v1 v1.0.1 Aug 7, 2021 v1.0.0 Aug 7, 2021 Changes in this version + const CephConsumerClass + const CephDaemonClass + const CronJobClass + const OperatorClass + const SuspendedClassKey + const SuspendedKey + func LoadKubeConfig(path string) (*restclient.Config, error) + func SuspendedClassSelector(class string) labels.Selector + func SuspendedSelector() labels.Selector + type CephCluster struct + Status CephClusterStatus + type CephClusterCephStatus struct + Health string + func (s CephClusterCephStatus) HealthOK() bool + type CephClusterStatus struct + Ceph CephClusterCephStatus + type Controller struct + func NewController(dryRun bool, restConfig *restclient.Config, log *zap.Logger) (*Controller, error) + func (c *Controller) Close() + func (c *Controller) IsCephHealthOK() (bool, error) + func (c *Controller) ResumeCephConsumers() error + func (c *Controller) ResumeCephDaemons() error + func (c *Controller) ResumeCluster() error + func (c *Controller) ResumeCronJobs() error + func (c *Controller) ResumeDeploys(selector labels.Selector) error + func (c *Controller) ResumeOperators() error + func (c *Controller) ResumeStatefulSets(selector labels.Selector) error + func (c *Controller) SuspendCephConsumers() error + func (c *Controller) SuspendCephDaemons() error + func (c *Controller) SuspendCluster() error + func (c *Controller) SuspendCronJobs() error + func (c *Controller) SuspendOperators() error + func (c *Controller) UpdateCephFlags(ensure bool) error + func (c *Controller) WaitForCacheSync() + func (c *Controller) WaitForCephHealthOK() error