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"

	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
	AutoApproveKubeletCertSigningRequests bool
}