ceph

type AioCompletion interface {
	WaitForComplete()
	Release()
	IsComplete() int
	GetReturnValue() int
}

type CephCluster struct {
	Name       string
	Conn       RadosConn
	InstanceId uint64
	// contains filtered or unexported fields
}

type Pool interface {
	Write(oid string, data []byte, offset uint64) error
	Read(oid string, data []byte, offset uint64) (int, error)
	Delete(oid string) error
	Truncate(oid string, size uint64) error
	Destroy()
	CreateStriper() (StriperPool, error)
	WriteSmallObject(oid string, data []byte) error
}

type RadosConn interface {
	OpenPool(name string) (Pool, error)
	GetClusterStats() (rados.ClusterStat, error)
	Shutdown()
}

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

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

type StriperPool interface {
	Read(oid string, data []byte, offset uint64) (int, error)
	Write(oid string, data []byte, offset uint64) (int, error)
	WriteAIO(oid string, data []byte, offset uint64) (AioCompletion, error)
	Delete(oid string) error
	Destroy()
	SetLayoutStripeUnit(uint uint) int
	SetLayoutStripeCount(count uint) int
	SetLayoutObjectSize(size uint) int
}