The highest tagged major version is v2.

chain_file_manager

package

v2.6.3+incompatible Latest Latest Go to latest Published: Nov 25, 2019 License: GPL-3.0 Imports: 13 Imported by: 8

Details

View Source

const (
	LocationSize = 12
)

This section is empty.

func NewFdByBuffer(fdSet *fdManager, cacheItem *fileCacheItem) *fileDescription

func NewFdByFile(file *os.File) *fileDescription

type DataParser interface {
	Write([]byte) error
	WriteError(err error)
	Close() error
}

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

func NewFileManager(dirName string, fileSize int64, cacheCount int) (*FileManager, error)

func (fm *FileManager) Close() error

func (fm *FileManager) DeleteTo(location *Location) error

func (fm *FileManager) Flush(startLocation *Location, targetLocation *Location, buf []byte) error

func (fm *FileManager) GetCacheStatusList() []interfaces.DBStatus

func (fm *FileManager) GetNextLocation(location *Location) (*Location, error)

func (fm *FileManager) LatestLocation() *Location

func (fm *FileManager) NextFlushStartLocation() *Location

func (fm *FileManager) Read(location *Location) ([]byte, *Location, error)

func (fm *FileManager) ReadRange(startLocation *Location, endLocation *Location, parser DataParser)

func (fm *FileManager) ReadRaw(startLocation *Location, buf []byte) (*Location, int, error)

func (fm *FileManager) SetLog(h log15.Handler)

func (fm *FileManager) SetNextFlushStartLocation(location *Location)

func (fm *FileManager) Write(buf []byte) (*Location, error)

type Location struct {
	FileId uint64
	Offset int64
}

func NewLocation(fileId uint64, offset int64) *Location

func (location *Location) Compare(a *Location) int

func (location *Location) Distance(fileSize int64, backLocation *Location) int64