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) ClearNode(ctx context.Context, nodeName string) error
  • func (c *Controller) PurgeNode(ctx context.Context, name string, rook bool) error
  • func (c *Controller) SetBlockPoolReplication(name string, 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) 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"

	RookCephObjectStoreRootPool = ".rgw.root"
)

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

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

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

PurgeNode cleans up a lost node.

func (*Controller) SetBlockPoolReplication

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

SetBlockPoolReplicationLevel ignores NotFound errors.

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