cluster

Documentation

Index

• Constants
• Variables
• type Controller
  • func NewController(config ControllerConfig, log *zap.SugaredLogger) *Controller
  • func (c *Controller) CephFilesystemOK(name string) (bool, error)
  • func (c *Controller) CheckRotateCertsDue() (bool, error)
  • func (c *Controller) ClearNode(ctx context.Context, nodeName string) error
  • func (c *Controller) PrioritizeRook() error
  • func (c *Controller) PurgeNode(ctx context.Context, name string, rook bool) error
  • func (c *Controller) ReconcileMonCount(count int) error
  • func (c *Controller) RotateAllCerts(ctx context.Context) error
  • func (c *Controller) RotateKurlProxyCert() error
  • func (c *Controller) RotateRegistryCert() error
  • func (c *Controller) SetBlockPoolReplication(name string, level int, doFullReconcile bool) error
  • func (c *Controller) SetDeviceHealthMetricsReplication(level int, doFullReconcile bool) error
  • func (c *Controller) SetFilesystemReplication(name string, level int, doFullReconcile bool) error
  • func (c *Controller) SetObjectStoreReplication(name string, level int, doFullReconcile bool) error
  • func (c *Controller) UpdateKubeletClientCertSecret() error
  • func (c *Controller) UseNodesForStorage(names []string) (int, error)
  • func (c *Controller) WaitCephFilesystem(ctx context.Context, name string) error
• type ControllerConfig

Constants

const (
	RookCephNS                   = "rook-ceph"
	CephClusterName              = "rook-ceph"
	RookCephSharedFSMetadataPool = "rook-shared-fs-metadata"
	RookCephSharedFSDataPool     = "rook-shared-fs-data0"
	CephDeviceHealthMetricsPool  = "device_health_metrics"

	RookCephObjectStoreRootPool = ".rgw.root"

	PrimaryRoleLabel         = "node-role.kubernetes.io/master"
	RotateCertsLabel         = "kurl.sh/task"
	RotateCertsValue         = "rotate-certs"
	RotateCertsLastAttempted = "rotate-certs-last-attempted"
)

const (
	DefaultEtcKubernetesDir = "/etc/kubernetes"
)

Variables

var (
	RookCephObjectStoreMetadataPools = []string{

		"rgw.control",
		"rgw.meta",
		"rgw.log",
		"rgw.buckets.index",
		"rgw.buckets.non-ec",
	}
	RookCephObjectStoreDataPools = []string{
		"rgw.buckets.data",
	}
)

var Rookv14 = semver.MustParse("1.4.0")

var RotateCertsSelector = labels.SelectorFromSet(labels.Set{RotateCertsLabel: RotateCertsValue})

Types

type Controller

type Controller struct {
	Config ControllerConfig
	Log    *zap.SugaredLogger

	sync.Mutex
}

func NewController

func NewController(config ControllerConfig, log *zap.SugaredLogger) *Controller

func (*Controller) CephFilesystemOK

func (c *Controller) CephFilesystemOK(name string) (bool, error)

func (*Controller) CheckRotateCertsDue

func (c *Controller) CheckRotateCertsDue() (bool, error)

Any time this returns true it updates the last attempted timestamp

func (*Controller) ClearNode

func (c *Controller) ClearNode(ctx context.Context, nodeName string) error

ClearNode force deletes pods stuck in Terminating state on a single node.

func (*Controller) PrioritizeRook

func (c *Controller) PrioritizeRook() error

func (*Controller) PurgeNode

func (c *Controller) PurgeNode(ctx context.Context, name string, rook bool) error

PurgeNode cleans up a lost node.

func (*Controller) ReconcileMonCount

func (c *Controller) ReconcileMonCount(count int) error

func (*Controller) RotateAllCerts

func (c *Controller) RotateAllCerts(ctx context.Context) error

This launches a pod on each primary to mount /etc/kubernetes and rotate the certs. It leaves the pods up if any fail.

func (*Controller) RotateKurlProxyCert

func (c *Controller) RotateKurlProxyCert() error

func (*Controller) RotateRegistryCert

func (c *Controller) RotateRegistryCert() error

func (*Controller) SetBlockPoolReplication

func (c *Controller) SetBlockPoolReplication(name string, level int, doFullReconcile bool) error

SetBlockPoolReplicationLevel ignores NotFound errors.

func (*Controller) SetDeviceHealthMetricsReplication

func (c *Controller) SetDeviceHealthMetricsReplication(level int, doFullReconcile bool) error

func (*Controller) SetFilesystemReplication

func (c *Controller) SetFilesystemReplication(name string, level int, doFullReconcile bool) error

SetSharedFilesystemReplication ignores NotFound errors.

func (*Controller) SetObjectStoreReplication

func (c *Controller) SetObjectStoreReplication(name string, level int, doFullReconcile bool) error

SetObjectStoreReplication ignores NotFound errors.

func (*Controller) UpdateKubeletClientCertSecret

func (c *Controller) UpdateKubeletClientCertSecret() error

Copies apiserver-kubelet-client.crt into secret used by kotsadm to collect metrics

func (*Controller) UseNodesForStorage

func (c *Controller) UseNodesForStorage(names []string) (int, error)

returns the number of nodes used for storage, which may be higher than the number of names passed in if a node is currenlty not ready but has not been purged

func (*Controller) WaitCephFilesystem

func (c *Controller) WaitCephFilesystem(ctx context.Context, name string) error

type ControllerConfig

type ControllerConfig struct {
	Client                      kubernetes.Interface
	ClientConfig                *restclient.Config
	CephV1                      *cephv1.CephV1Client
	CertificatesDir             string
	RookVersion                 semver.Version
	RookPriorityClass           string
	RotateCerts                 bool
	RotateCertsImage            string
	RotateCertsNamespace        string
	RotateCertsCheckInterval    time.Duration
	RotateCertsTTL              time.Duration
	RegistryCertNamespace       string
	RegistryCertSecret          string
	KurlProxyCertNamespace      string
	KurlProxyCertSecret         string
	KotsadmKubeletCertNamespace string
	KotsadmKubeletCertSecret    string
}