cluster

Documentation

Index

• Constants
• type Controller
  • func NewController(config ControllerConfig, log *zap.SugaredLogger) *Controller
  • func (c *Controller) CephFilesystemOK(name string) (bool, error)
  • func (c *Controller) PurgeNode(ctx context.Context, name string, rook bool) error
  • func (c *Controller) SetFilesystemReplication(name string, level int) error
  • func (c *Controller) SetObjectStoreReplication(name string, level int) error
  • func (c *Controller) SetPoolReplication(name string, level int) 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"
	RookCephObjectStoreService    = "rook-ceph-rgw-replicated"
	RookCephObjectStoreUserSecret = "rook-ceph-object-user-replicated-replicated"
)

const (
	DefaultEtcKubernetesDir = "/etc/kubernetes"
)

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

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

PurgeNode cleans up a lost node.

func (*Controller) SetFilesystemReplication

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

SetSharedFilesystemReplication ignores NotFound errors.

func (*Controller) SetObjectStoreReplication

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

SetObjectStoreReplication ignores NotFound errors.

func (*Controller) SetPoolReplication

func (c *Controller) SetPoolReplication(name string, level int) error

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