controller

Documentation

Index

• Constants
• func LoadKubeConfig(path string) (*restclient.Config, error)
• func SuspendedClassSelector(class string) labels.Selector
• func SuspendedSelector() labels.Selector
• type CephCluster
• type CephClusterCephStatus
  • func (s CephClusterCephStatus) HealthOK() bool
• type CephClusterStatus
• type Controller
  • 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

Constants

const (
	SuspendedKey      = "k8s.ianunruh.com/suspended"
	SuspendedClassKey = "k8s.ianunruh.com/suspended-class"

	CephConsumerClass = "ceph-consumer"
	CephDaemonClass   = "ceph-daemon"
	OperatorClass     = "operator"
	CronJobClass      = "cronjob"
)

Functions

func LoadKubeConfig

func LoadKubeConfig(path string) (*restclient.Config, error)

func SuspendedClassSelector

func SuspendedClassSelector(class string) labels.Selector

func SuspendedSelector

func SuspendedSelector() labels.Selector

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