mds

Documentation

Overview

Package mds provides methods for setting up Ceph configuration for mds daemons. It also provides methods for creating/deleting/managing Ceph filesystems served by the mds.

Index

• Constants
• func DownFilesystem(context *clusterd.Context, clusterName, filesystemName string) error
• func FinishedWithDaemonUpgrade(context *clusterd.Context, clusterName, fsName string, activeMDSCount int32) error
• func Initialize(context *clusterd.Context, config *Config) error
• func PrepareForDaemonUpgrade(context *clusterd.Context, clusterName, fsName string, timeout time.Duration) error
• type Config
• type Filesystem
  • func NewFS(name string, metadataPool *model.Pool, dataPools []*model.Pool, ...) *Filesystem
  • func (f *Filesystem) CreateFilesystem(context *clusterd.Context, clusterName string) error

Constants

const (
	// InitCommand is the `rook ceph` subcommand which will perform mds initialization
	InitCommand = "mds-init"
)

Functions

func DownFilesystem

func DownFilesystem(context *clusterd.Context, clusterName, filesystemName string) error

DownFilesystem marks the filesystem as down and the MDS' as failed

func FinishedWithDaemonUpgrade

func FinishedWithDaemonUpgrade(
	context *clusterd.Context,
	clusterName, fsName string,
	activeMDSCount int32,
) error

FinishedWithDaemonUpgrade performs all actions necessary to bring the filesystem back to its ideal state following an upgrade of its daemon(s).

func Initialize

func Initialize(context *clusterd.Context, config *Config) error

Initialize generates configuration files for a Ceph mds

func PrepareForDaemonUpgrade

func PrepareForDaemonUpgrade(
	context *clusterd.Context,
	clusterName, fsName string,
	timeout time.Duration,
) error

PrepareForDaemonUpgrade performs all actions necessary to ensure the filesystem is prepared to have its daemon(s) updated. This helps ensure there is no aberrant behavior during upgrades. If the mds is not prepared within the timeout window, an error will be reported. Ceph docs: http://docs.ceph.com/docs/master/cephfs/upgrading/

Types

type Config

type Config struct {
	FilesystemID  string
	Name          string
	Keyring       string
	ActiveStandby bool
	ClusterInfo   *cephconfig.ClusterInfo
}

Config contains the necessary parameters Rook needs to know to set up a mds for a Ceph cluster.

type Filesystem

type Filesystem struct {
	Name string
	// contains filtered or unexported fields
}

Filesystem represents an instance of a Ceph file system (CephFS)

func NewFS

func NewFS(name string, metadataPool *model.Pool, dataPools []*model.Pool, activeMDSCount int32) *Filesystem

NewFS creates a new instance of the file (MDS) service

func (*Filesystem) CreateFilesystem

func (f *Filesystem) CreateFilesystem(context *clusterd.Context, clusterName string) error

CreateFilesystem starts the Ceph file daemons and creates the filesystem in Ceph.