chunk

type CacheManager interface {
	// contains filtered or unexported methods
}

type ChunkStore interface {
	NewReader(id uint64, length int) Reader
	NewWriter(id uint64) Writer
	Remove(id uint64, length int) error
	FillCache(id uint64, length uint32) error
	UsedMemory() int64
	UpdateLimit(upload, download int64)
}

type Config struct {
	CacheDir          string
	CacheMode         os.FileMode
	CacheSize         int64
	CacheChecksum     string
	CacheEviction     string
	CacheScanInterval time.Duration
	FreeSpace         float32
	AutoCreate        bool
	Compress          string
	MaxUpload         int
	MaxRetries        int
	UploadLimit       int64 // bytes per second
	DownloadLimit     int64 // bytes per second
	Writeback         bool
	UploadDelay       time.Duration
	HashPrefix        bool
	BlockSize         int
	GetTimeout        time.Duration
	PutTimeout        time.Duration
	CacheFullBlock    bool
	BufferSize        int
	Readahead         int
	Prefetch          int
}

type Controller struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Page struct {
	Data []byte
	// contains filtered or unexported fields
}

type ReadCloser interface {
	// io.Reader
	io.ReaderAt
	io.Closer
}

type Reader interface {
	ReadAt(ctx context.Context, p *Page, off int) (int, error)
}

type Writer interface {
	io.WriterAt
	ID() uint64
	SetID(id uint64)
	FlushTo(offset int) error
	Finish(length int) error
	Abort()
}