cephfs

package
Version: v2.0.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2020 License: Apache-2.0 Imports: 23 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// CSIInstanceID is the instance ID that is unique to an instance of CSI, used when sharing
	// ceph clusters across CSI instances, to differentiate omap names per CSI instance
	CSIInstanceID = "default"
)
View Source
var PluginFolder = ""

PluginFolder defines the location of ceph plugin

Functions

This section is empty.

Types

type CephFilesystem

type CephFilesystem struct {
	Name           string   `json:"name"`
	MetadataPool   string   `json:"metadata_pool"`
	MetadataPoolID int      `json:"metadata_pool_id"`
	DataPools      []string `json:"data_pools"`
	DataPoolIDs    []int    `json:"data_pool_ids"`
}

CephFilesystem is a representation of the json structure returned by 'ceph fs ls'

type CephFilesystemDetails

type CephFilesystemDetails struct {
	ID     int64  `json:"id"`
	MDSMap MDSMap `json:"mdsmap"`
}

CephFilesystemDetails is a representation of the main json structure returned by 'ceph fs get'

type CephFilesystemDump

type CephFilesystemDump struct {
	Filesystems []CephFilesystemDetails `json:"filesystems"`
}

CephFilesystemDump is a representation of the main json structure returned by 'ceph fs dump'

type ControllerServer

type ControllerServer struct {
	*csicommon.DefaultControllerServer
	MetadataStore util.CachePersister
	// A map storing all volumes with ongoing operations so that additional operations
	// for that same volume (as defined by VolumeID/volume name) return an Aborted error
	VolumeLocks *util.VolumeLocks
}

ControllerServer struct of CEPH CSI driver with supported methods of CSI controller server spec.

func NewControllerServer

func NewControllerServer(d *csicommon.CSIDriver, cachePersister util.CachePersister) *ControllerServer

NewControllerServer initialize a controller server for ceph CSI driver

func (*ControllerServer) ControllerExpandVolume

ExpandVolume expand CephFS Volumes on demand based on resizer request

func (*ControllerServer) CreateVolume

CreateVolume creates a reservation and the volume in backend, if it is not already present

func (*ControllerServer) DeleteVolume

DeleteVolume deletes the volume in backend and its reservation

func (*ControllerServer) ValidateVolumeCapabilities

ValidateVolumeCapabilities checks whether the volume capabilities requested are supported.

type Driver

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

Driver contains the default identity,node and controller struct

func NewDriver

func NewDriver() *Driver

NewDriver returns new ceph driver

func (*Driver) Run

func (fs *Driver) Run(conf *util.Config, cachePersister util.CachePersister)

Run start a non-blocking grpc controller,node and identityserver for ceph CSI driver which can serve multiple parallel requests

type ErrInvalidVolID

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

ErrInvalidVolID is returned when a CSI passed VolumeID is not conformant to any known volume ID formats

func (ErrInvalidVolID) Error

func (e ErrInvalidVolID) Error() string

type ErrNonStaticVolume

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

ErrNonStaticVolume is returned when a volume is detected as not being statically provisioned

func (ErrNonStaticVolume) Error

func (e ErrNonStaticVolume) Error() string

type ErrVolumeNotFound

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

ErrVolumeNotFound is returned when a subvolume is not found in CephFS

func (ErrVolumeNotFound) Error

func (e ErrVolumeNotFound) Error() string

type IdentityServer

type IdentityServer struct {
	*csicommon.DefaultIdentityServer
}

IdentityServer struct of ceph CSI driver with supported methods of CSI identity server spec.

func NewIdentityServer

func NewIdentityServer(d *csicommon.CSIDriver) *IdentityServer

NewIdentityServer initialize a identity server for ceph CSI driver

func (*IdentityServer) GetPluginCapabilities

GetPluginCapabilities returns available capabilities of the ceph driver

type MDSMap

type MDSMap struct {
	FilesystemName string `json:"fs_name"`
}

MDSMap is a representation of the mds map sub-structure returned by 'ceph fs get'

type NodeServer

type NodeServer struct {
	*csicommon.DefaultNodeServer
	// A map storing all volumes with ongoing operations so that additional operations
	// for that same volume (as defined by VolumeID) return an Aborted error
	VolumeLocks *util.VolumeLocks
}

NodeServer struct of ceph CSI driver with supported methods of CSI node server spec.

func NewNodeServer

func NewNodeServer(d *csicommon.CSIDriver, t string) *NodeServer

NewNodeServer initialize a node server for ceph CSI driver.

func (*NodeServer) NodeGetCapabilities

NodeGetCapabilities returns the supported capabilities of the node server

func (*NodeServer) NodePublishVolume

NodePublishVolume mounts the volume mounted to the staging path to the target path

func (*NodeServer) NodeStageVolume

NodeStageVolume mounts the volume to a staging path on the node.

func (*NodeServer) NodeUnpublishVolume

NodeUnpublishVolume unmounts the volume from the target path

func (*NodeServer) NodeUnstageVolume

NodeUnstageVolume unstages the volume from the staging path

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL