mds

Documentation

Overview

Package mds to manage a rook file system.

Package mds for file systems.

Package mds to manage a rook file system.

Package mds to manage a rook file system.

Index

• Variables
• func CreateFileSystem(context *clusterd.Context, clusterName string, f *model.FilesystemRequest, ...) error
• func Kind(kind string) schema.GroupKind
• func Resource(resource string) schema.GroupResource
• type Filesystem
  • func (f *Filesystem) Create(context *clusterd.Context, version string, hostNetwork bool) error
  • func (f *Filesystem) Delete(context *clusterd.Context) error
• type FilesystemController
  • func NewFilesystemController(context *clusterd.Context, versionTag string, hostNetwork bool) *FilesystemController
  • func (c *FilesystemController) StartWatch(namespace string, stopCh chan struct{}) error
• type FilesystemList
• type FilesystemSpec
• type MetadataServerSpec

Variables

var FilesystemResource = opkit.CustomResource{
	Name:    "filesystem",
	Plural:  "filesystems",
	Group:   k8sutil.CustomResourceGroup,
	Version: k8sutil.V1Alpha1,
	Scope:   apiextensionsv1beta1.NamespaceScoped,
	Kind:    reflect.TypeOf(Filesystem{}).Name(),
}

FilesystemResource represents the file system custom resource

Functions

func CreateFileSystem

func CreateFileSystem(context *clusterd.Context, clusterName string, f *model.FilesystemRequest, version string, hostNetwork bool) error

func Kind

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns back a Group qualified GroupResource

Types

type Filesystem

type Filesystem struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              FilesystemSpec `json:"spec"`
}

Filesystem is the definition of the file system custom resource

func (*Filesystem) Create

func (f *Filesystem) Create(context *clusterd.Context, version string, hostNetwork bool) error

Create the file system

func (*Filesystem) Delete

func (f *Filesystem) Delete(context *clusterd.Context) error

Delete the file system

type FilesystemController

type FilesystemController struct {
	// contains filtered or unexported fields
}

FilesystemController represents a controller for file system custom resources

func NewFilesystemController

func NewFilesystemController(context *clusterd.Context, versionTag string, hostNetwork bool) *FilesystemController

NewFilesystemController create controller for watching file system custom resources created

func (*FilesystemController) StartWatch

func (c *FilesystemController) StartWatch(namespace string, stopCh chan struct{}) error

StartWatch watches for instances of Filesystem custom resources and acts on them

type FilesystemList

type FilesystemList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []Filesystem `json:"items"`
}

FilesystemList is the definition of a list of file systems

type FilesystemSpec

type FilesystemSpec struct {
	// The metadata pool settings
	MetadataPool pool.PoolSpec `json:"metadataPool"`

	// The data pool settings
	DataPools []pool.PoolSpec `json:"dataPools"`

	// The mds pod info
	MetadataServer MetadataServerSpec `json:"metadataServer"`
}

FilesystemSpec represent the spec of a file system

type MetadataServerSpec

type MetadataServerSpec struct {
	// The number of metadata servers that are active. The remaining servers in the cluster will be in standby mode.
	ActiveCount int32 `json:"activeCount"`

	// Whether each active MDS instance will have an active standby with a warm metadata cache for faster failover.
	// If false, standbys will still be available, but will not have a warm metadata cache.
	ActiveStandby bool `json:"activeStandby"`

	// The affinity to place the mds pods (default is to place on all available node) with a daemonset
	Placement k8sutil.Placement `json:"placement"`
}