ceph

Documentation

Index

• Constants
• func EncodeName(id string) string
• type CephConfig
• type DfInfo
• type Driver
  • func (d *Driver) CreateSnapshot(opt *pb.CreateVolumeSnapshotOpts) (*model.VolumeSnapshotSpec, error)
  • func (d *Driver) CreateVolume(opt *pb.CreateVolumeOpts) (*model.VolumeSpec, error)
  • func (d *Driver) CreateVolumeGroup(opt *pb.CreateVolumeGroupOpts) (*model.VolumeGroupSpec, error)
  • func (d *Driver) DeleteSnapshot(opt *pb.DeleteVolumeSnapshotOpts) error
  • func (d *Driver) DeleteVolume(opt *pb.DeleteVolumeOpts) error
  • func (d *Driver) DeleteVolumeGroup(opt *pb.DeleteVolumeGroupOpts) error
  • func (d *Driver) ExtendVolume(opt *pb.ExtendVolumeOpts) (*model.VolumeSpec, error)
  • func (d *Driver) InitializeConnection(opt *pb.CreateVolumeAttachmentOpts) (*model.ConnectionInfo, error)
  • func (d *Driver) InitializeSnapshotConnection(opt *pb.CreateSnapshotAttachmentOpts) (*model.ConnectionInfo, error)
  • func (d *Driver) ListPools() ([]*model.StoragePoolSpec, error)
  • func (d *Driver) PullSnapshot(snapID string) (*model.VolumeSnapshotSpec, error)
  • func (d *Driver) PullVolume(volID string) (*model.VolumeSpec, error)
  • func (d *Driver) Setup() error
  • func (d *Driver) TerminateConnection(opt *pb.DeleteVolumeAttachmentOpts) error
  • func (d *Driver) TerminateSnapshotConnection(opt *pb.DeleteSnapshotAttachmentOpts) error
  • func (d *Driver) Unset() error
  • func (d *Driver) UpdateVolumeGroup(opt *pb.UpdateVolumeGroupOpts) (*model.VolumeGroupSpec, error)
• type PoolStats
• type SrcMgr
  • func NewSrcMgr(conf *CephConfig) *SrcMgr
  • func (s *SrcMgr) GetConn() (*rados.Conn, error)
  • func (s *SrcMgr) GetImage(poolName string, imgName string, args ...interface{}) (*rbd.Image, error)
  • func (s *SrcMgr) GetIoctx(poolName string) (*rados.IOContext, error)
• type TotalStats

Constants

const (
	KPoolName  = "CephPoolName"
	KImageName = "CephImageName"
)

Functions

func EncodeName

func EncodeName(id string) string

Types

type CephConfig

type CephConfig struct {
	ConfigFile string                    `yaml:"configFile,omitempty"`
	Pool       map[string]PoolProperties `yaml:"pool,flow"`
}

type DfInfo

type DfInfo struct {
	Stats TotalStats  `json:"stats,omitempty"`
	Pools []PoolStats `json:"pools,omitempty"`
}

type Driver

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

func (*Driver) CreateSnapshot

func (d *Driver) CreateSnapshot(opt *pb.CreateVolumeSnapshotOpts) (*model.VolumeSnapshotSpec, error)

func (*Driver) CreateVolume

func (d *Driver) CreateVolume(opt *pb.CreateVolumeOpts) (*model.VolumeSpec, error)

func (*Driver) CreateVolumeGroup

func (d *Driver) CreateVolumeGroup(opt *pb.CreateVolumeGroupOpts) (*model.VolumeGroupSpec, error)

func (*Driver) DeleteSnapshot

func (d *Driver) DeleteSnapshot(opt *pb.DeleteVolumeSnapshotOpts) error

func (*Driver) DeleteVolume

func (d *Driver) DeleteVolume(opt *pb.DeleteVolumeOpts) error

func (*Driver) DeleteVolumeGroup

func (d *Driver) DeleteVolumeGroup(opt *pb.DeleteVolumeGroupOpts) error

func (*Driver) ExtendVolume

func (d *Driver) ExtendVolume(opt *pb.ExtendVolumeOpts) (*model.VolumeSpec, error)

ExtendVolume ...

func (*Driver) InitializeConnection

func (d *Driver) InitializeConnection(opt *pb.CreateVolumeAttachmentOpts) (*model.ConnectionInfo, error)

func (*Driver) InitializeSnapshotConnection

func (d *Driver) InitializeSnapshotConnection(opt *pb.CreateSnapshotAttachmentOpts) (*model.ConnectionInfo, error)

func (*Driver) ListPools

func (d *Driver) ListPools() ([]*model.StoragePoolSpec, error)

func (*Driver) PullSnapshot

func (d *Driver) PullSnapshot(snapID string) (*model.VolumeSnapshotSpec, error)

func (*Driver) PullVolume

func (d *Driver) PullVolume(volID string) (*model.VolumeSpec, error)

func (*Driver) Setup

func (d *Driver) Setup() error

func (*Driver) TerminateConnection

func (d *Driver) TerminateConnection(opt *pb.DeleteVolumeAttachmentOpts) error

func (*Driver) TerminateSnapshotConnection

func (d *Driver) TerminateSnapshotConnection(opt *pb.DeleteSnapshotAttachmentOpts) error

func (*Driver) Unset

func (d *Driver) Unset() error

func (*Driver) UpdateVolumeGroup

func (d *Driver) UpdateVolumeGroup(opt *pb.UpdateVolumeGroupOpts) (*model.VolumeGroupSpec, error)

type PoolStats

type PoolStats struct {
	Name  string `json:"name,omitempty"`
	Id    int64  `json:"id,omitempty"`
	Stats struct {
		KbUsed      int64 `json:"kb_used,omitempty"`
		BytesUsed   int64 `json:"bytes_used,omitempty"`
		PercentUsed int64 `json:"percent_used,omitempty"`
		MaxAvail    int64 `json:"max_avail,omitempty"`
		Objects     int64 `json:"objects,omitempty"`
	} `json:"stats,omitempty"`
}

type SrcMgr

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

func NewSrcMgr

func NewSrcMgr(conf *CephConfig) *SrcMgr

func (*SrcMgr) GetConn

func (s *SrcMgr) GetConn() (*rados.Conn, error)

func (*SrcMgr) GetImage

func (s *SrcMgr) GetImage(poolName string, imgName string, args ...interface{}) (*rbd.Image, error)

func (*SrcMgr) GetIoctx

func (s *SrcMgr) GetIoctx(poolName string) (*rados.IOContext, error)

type TotalStats

type TotalStats struct {
	TotalBytes      int64 `json:"total_bytes,omitempty"`
	TotalUsedBytes  int64 `json:"total_used_bytes,omitempty"`
	TotalAvailBytes int64 `json:"total_avail_bytes,omitempty"`
}