ceph

Sep 16, 2020

Changes in this version

+ const AIO_CONCURRENT

+ const APPEND_STRIPE_COUNT

+ const APPEND_STRIPE_UNIT

+ const BUFFER_SIZE

+ const DEFAULT_CEPHCONFIG_PATTERN

+ const DEFAULT_CLIENT_PRIORITY

+ const MAX_CHUNK_SIZE

+ const MIN_CHUNK_SIZE

+ const MON_TIMEOUT

+ const OBJECT_SIZE

+ const OSD_TIMEOUT

+ const STRIPE_COUNT

+ const STRIPE_UNIT

+ func Initialize(config helper.Config) map[string]backend.Cluster

+ func PureInitialize(cephConfigPattern string, priority int) (map[string]backend.Cluster, error)

+ type AioCompletion interface

+ GetReturnValue func() int

+ IsComplete func() int

+ Release func()

+ WaitForComplete func()

+ type CephCluster struct

+ Conn RadosConn

+ InstanceId uint64

+ Name string

+ func NewCephStorage(configFile string) *CephCluster

+ func PureNewCephStorage(configFile string, priority int) (*CephCluster, error)

+ func (cluster *CephCluster) Append(poolname string, existName string, data io.Reader, offset int64, length int64) (oid string, size uint64, err error)

+ func (cluster *CephCluster) Close()

+ func (cluster *CephCluster) GetReader(poolName string, oid string, startOffset int64, length uint64) (reader io.ReadCloser, err error)

+ func (cluster *CephCluster) GetUsage() (usage backend.Usage, err error)

+ func (cluster *CephCluster) ID() string

+ func (cluster *CephCluster) Put(poolname string, data io.Reader) (oid string, size uint64, err error)

+ func (cluster *CephCluster) Remove(poolname string, oid string) error

+ func (cluster *CephCluster) Shutdown()

+ type Pool interface

+ CreateStriper func() (StriperPool, error)

+ Delete func(oid string) error

+ Destroy func()

+ Read func(oid string, data []byte, offset uint64) (int, error)

+ Truncate func(oid string, size uint64) error

+ Write func(oid string, data []byte, offset uint64) error

+ WriteSmallObject func(oid string, data []byte) error

+ type RadosConn interface

+ GetClusterStats func() (rados.ClusterStat, error)

+ OpenPool func(name string) (Pool, error)

+ Shutdown func()

+ type RadosDownloader struct

+ func (rd *RadosDownloader) Close() error

+ func (rd *RadosDownloader) Read(p []byte) (n int, err error)

+ func (rd *RadosDownloader) Seek(offset int64, whence int) (int64, error)

+ type RadosSmallDownloader struct

+ func (rd *RadosSmallDownloader) Close() error

+ func (rd *RadosSmallDownloader) Read(p []byte) (n int, err error)

+ func (rd *RadosSmallDownloader) Seek(offset int64, whence int) (int64, error)

+ type StriperPool interface

+ Delete func(oid string) error

+ Destroy func()

+ Read func(oid string, data []byte, offset uint64) (int, error)

+ SetLayoutObjectSize func(size uint) int

+ SetLayoutStripeCount func(count uint) int

+ SetLayoutStripeUnit func(unit uint) int

+ Write func(oid string, data []byte, offset uint64) (int, error)

+ WriteAIO func(oid string, data []byte, offset uint64) (AioCompletion, error)