Documentation
¶
Index ¶
- Constants
- func LoadKubeConfig(path string) (*restclient.Config, error)
- func SuspendedClassSelector(class string) labels.Selector
- func SuspendedSelector() labels.Selector
- type CephCluster
- type CephClusterCephStatus
- type CephClusterStatus
- type Controller
- 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
Constants ¶
View Source
const ( SuspendedKey = "k8s.ianunruh.com/suspended" SuspendedClassKey = "k8s.ianunruh.com/suspended-class" CephConsumerClass = "ceph-consumer" CephDaemonClass = "ceph-daemon" OperatorClass = "operator" CronJobClass = "cronjob" )
Variables ¶
This section is empty.
Functions ¶
func LoadKubeConfig ¶
func LoadKubeConfig(path string) (*restclient.Config, error)
func SuspendedClassSelector ¶
func SuspendedSelector ¶
Types ¶
type CephCluster ¶
type CephCluster struct {
Status CephClusterStatus
}
type CephClusterCephStatus ¶
type CephClusterCephStatus struct {
Health string
}
func (CephClusterCephStatus) HealthOK ¶
func (s CephClusterCephStatus) HealthOK() bool
type CephClusterStatus ¶
type CephClusterStatus struct {
Ceph CephClusterCephStatus
}
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(dryRun bool, restConfig *restclient.Config, log *zap.Logger) (*Controller, error)
func (*Controller) Close ¶
func (c *Controller) Close()
func (*Controller) IsCephHealthOK ¶
func (c *Controller) IsCephHealthOK() (bool, error)
func (*Controller) ResumeCephConsumers ¶
func (c *Controller) ResumeCephConsumers() error
func (*Controller) ResumeCephDaemons ¶
func (c *Controller) ResumeCephDaemons() error
func (*Controller) ResumeCluster ¶
func (c *Controller) ResumeCluster() error
func (*Controller) ResumeCronJobs ¶
func (c *Controller) ResumeCronJobs() error
func (*Controller) ResumeDeploys ¶
func (c *Controller) ResumeDeploys(selector labels.Selector) error
func (*Controller) ResumeOperators ¶
func (c *Controller) ResumeOperators() error
func (*Controller) ResumeStatefulSets ¶
func (c *Controller) ResumeStatefulSets(selector labels.Selector) error
func (*Controller) SuspendCephConsumers ¶
func (c *Controller) SuspendCephConsumers() error
func (*Controller) SuspendCephDaemons ¶
func (c *Controller) SuspendCephDaemons() error
func (*Controller) SuspendCluster ¶
func (c *Controller) SuspendCluster() error
func (*Controller) SuspendCronJobs ¶
func (c *Controller) SuspendCronJobs() error
func (*Controller) SuspendOperators ¶
func (c *Controller) SuspendOperators() error
func (*Controller) UpdateCephFlags ¶
func (c *Controller) UpdateCephFlags(ensure bool) error
func (*Controller) WaitForCacheSync ¶
func (c *Controller) WaitForCacheSync()
func (*Controller) WaitForCephHealthOK ¶
func (c *Controller) WaitForCephHealthOK() error
Source Files
Click to show internal directories.
Click to hide internal directories.