package rbd

import "k8s.io/kubernetes/pkg/volume/rbd"

Package rbd contains the internal representation of Rados Block Store (Ceph) volumes.

Index ¶

• Constants
• func ProbeVolumePlugins() []volume.VolumePlugin
• type RBDPlugin
• func (plugin *RBDPlugin) CanSupport(spec *volume.Spec) bool
• func (plugin *RBDPlugin) GetAccessModes() []api.PersistentVolumeAccessMode
• func (plugin *RBDPlugin) Init(host volume.VolumeHost)
• func (plugin *RBDPlugin) Name() string
• func (plugin *RBDPlugin) NewBuilder(spec *volume.Spec, pod *api.Pod, _ volume.VolumeOptions, mounter mount.Interface) (volume.Builder, error)
• func (plugin *RBDPlugin) NewCleaner(volName string, podUID types.UID, mounter mount.Interface) (volume.Cleaner, error)
• type RBDUtil
• func (util *RBDUtil) AttachDisk(rbd rbd) error
• func (util *RBDUtil) DetachDisk(rbd rbd, mntPath string) error
• func (util *RBDUtil) MakeGlobalPDName(rbd rbd) string

Constants ¶

const (
	RBDPluginName = "kubernetes.io/rbd"
)

Functions ¶

func ProbeVolumePlugins ¶

func ProbeVolumePlugins() []volume.VolumePlugin

This is the primary entrypoint for volume plugins.

Types ¶

type RBDPlugin ¶

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

func (*RBDPlugin) CanSupport ¶

func (plugin *RBDPlugin) CanSupport(spec *volume.Spec) bool

func (*RBDPlugin) GetAccessModes ¶

func (plugin *RBDPlugin) GetAccessModes() []api.PersistentVolumeAccessMode

func (*RBDPlugin) Init ¶

func (plugin *RBDPlugin) Init(host volume.VolumeHost)

func (*RBDPlugin) Name ¶

func (plugin *RBDPlugin) Name() string

func (*RBDPlugin) NewBuilder ¶

func (plugin *RBDPlugin) NewBuilder(spec *volume.Spec, pod *api.Pod, _ volume.VolumeOptions, mounter mount.Interface) (volume.Builder, error)

func (*RBDPlugin) NewCleaner ¶

func (plugin *RBDPlugin) NewCleaner(volName string, podUID types.UID, mounter mount.Interface) (volume.Cleaner, error)

type RBDUtil ¶

type RBDUtil struct{}

func (*RBDUtil) AttachDisk ¶

func (util *RBDUtil) AttachDisk(rbd rbd) error

func (*RBDUtil) DetachDisk ¶

func (util *RBDUtil) DetachDisk(rbd rbd, mntPath string) error

func (*RBDUtil) MakeGlobalPDName ¶

func (util *RBDUtil) MakeGlobalPDName(rbd rbd) string

Source Files ¶

disk_manager.go doc.go rbd.go rbd_util.go