storage

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

type BlobFileInfo struct {
	DataFile      string
	IndexFile     string
	Objects       []*ObjectInfo
	NeedVerify    bool
	ErrMesg       string
	AvailChunkCnt int
	Used          int64
	FileBytes     uint64
	DeleteBytes   uint64
	DeletePercent float64
}

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

type Extent interface {
	// ID returns the identity value (extentId) of this extent entity.
	ID() uint64

	// Ino returns this inode ID of this extent block belong to.
	Ino() uint64

	// Close this extent and release FD.
	Close() error

	// InitToFS init extent data info filesystem. If entry file exist and overwrite is true,
	// this operation will clear all data of exist entry file and initialize extent header data.
	InitToFS(ino uint64, overwrite bool) error

	// RestoreFromFS restore entity data and status from entry file stored in filesystem.
	RestoreFromFS() error

	// Write data to extent.
	Write(data []byte, offset, size int64, crc uint32) (err error)

	// Read data from extent.
	Read(data []byte, offset, size int64) (crc uint32, err error)

	// Flush synchronize data to disk immediately.
	Flush() error

	// MarkDelete mark this extent as deleted.
	MarkDelete() error

	// IsMarkDelete test this extent if has been marked as delete.
	IsMarkDelete() bool

	// Size returns length of extent data exclude header.
	Size() (size int64)

	// ModTime returns the time when this extent was last modified.
	ModTime() time.Time

	// HeaderChecksum returns crc checksum value of extent header data
	// include inode data and block crc.
	HeaderChecksum() (crc uint32)
}

type ExtentCache interface {
	// Put extent object into cache.
	Put(extent Extent)

	// Get extent from cache with specified extent identity (extentId).
	Get(extentId uint64) (extent Extent, ok bool)

	// Del extent stored in cache this specified extent identity (extentId).
	Del(extentId uint64)

	// Size returns number of extents stored in this cache.
	Size() int

	// Flush synchronize extent stored in this cache to disk immediately.
	Flush()

	// Clear close and synchronize all extent stored in this cache and remove them from cache.
	Clear()
}

type ExtentFilter func(info *FileInfo) bool

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

type FileInfo struct {
	FileId      int       `json:"fileId"`
	Inode       uint64    `json:"ino"`
	Size        uint64    `json:"size"`
	Crc         uint32    `json:"crc"`
	Deleted     bool      `json:"deleted"`
	ModTime     time.Time `json:"modTime"`
	Source      string    `json:"src"`
	MemberIndex int
}

type Object struct {
	Oid    uint64
	Offset uint64
	Size   uint32
	Crc    uint32
}

type ObjectInfo struct {
	Object        *Object
	SuccessVerify bool
	ErrorMesg     string
}

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