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(reset bool) (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) ReconcileInternalLB(ctx context.Context, nodes []corev1.Node) error
  • func (c *Controller) ReconcileMonCount(count int) error
  • func (c *Controller) RotateAllCerts(ctx context.Context) error
  • func (c *Controller) RotateContourCerts() 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) SetKubeconfigServer(ctx context.Context, node corev1.Node, server string) error
  • func (c *Controller) SetObjectStoreReplication(name string, level int, doFullReconcile bool) error
  • func (c *Controller) UpdateInternalLB(ctx context.Context, nodes []corev1.Node) 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"

	TaskLabel                = "kurl.sh/task"
	UpdateInternalLBValue    = "update-internallb"
	SetKubeconfigServerValue = "set-kubeconfig-server"
)

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})

var SetKubeconfigServerSelector = labels.SelectorFromSet(labels.Set{TaskLabel: SetKubeconfigServerValue})

var UpdateInternalLBSelector = labels.SelectorFromSet(labels.Set{TaskLabel: UpdateInternalLBValue})

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(reset bool) (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) ReconcileInternalLB

func (c *Controller) ReconcileInternalLB(ctx context.Context, nodes []corev1.Node) error

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) RotateContourCerts

func (c *Controller) RotateContourCerts() error

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) SetKubeconfigServer

func (c *Controller) SetKubeconfigServer(ctx context.Context, node corev1.Node, server string) error

func (*Controller) SetObjectStoreReplication

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

SetObjectStoreReplication ignores NotFound errors.

func (*Controller) UpdateInternalLB

func (c *Controller) UpdateInternalLB(ctx context.Context, nodes []corev1.Node) error

Update /etc/haproxy/haproxy.cfg and /etc/kubernetes/manifests/haproxy.yaml on all nodes.

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
	AlertManagerV1              dynamic.NamespaceableResourceInterface
	PrometheusV1                dynamic.NamespaceableResourceInterface
	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
	ContourCertNamespace        string
	ContourCertSecret           string
	EnvoyCertSecret             string
	HostTaskImage               string
	HostTaskNamespace           string
	EnableInternalLoadBalancer  bool
}