block_cache

Oct 22, 2024

Changes in this version

+ const BlockStatusDownloadFailed — linux/amd64

+ const BlockStatusDownloaded — linux/amd64

+ const BlockStatusUploadFailed — linux/amd64

+ const BlockStatusUploaded — linux/amd64

Feb 12, 2024

Changes in this version

+ const BlockFlagDirty — linux/amd64

+ const BlockFlagDownloading — linux/amd64

+ const BlockFlagFailed — linux/amd64

+ const BlockFlagFresh — linux/amd64

+ const BlockFlagSynced — linux/amd64

+ const BlockFlagUploading — linux/amd64

+ const MAX_BLOCKS — linux/amd64

+ const MIN_WRITE_BLOCK — linux/amd64

type Block — linux/amd64

+ func (b *Block) Dirty()

+ func (b *Block) Failed()

+ func (b *Block) IsDirty() bool

+ func (b *Block) IsFailed() bool

+ func (b *Block) NoMoreDirty()

+ func (b *Block) Ready()

+ func (b *Block) Uploading()

type BlockCache — linux/amd64

+ func (bc *BlockCache) CreateFile(options internal.CreateFileOptions) (*handlemap.Handle, error)

+ func (bc *BlockCache) DeleteDir(options internal.DeleteDirOptions) error

+ func (bc *BlockCache) DeleteFile(options internal.DeleteFileOptions) error

+ func (bc *BlockCache) FlushFile(options internal.FlushFileOptions) error

+ func (bc *BlockCache) RenameDir(options internal.RenameDirOptions) error

+ func (bc *BlockCache) RenameFile(options internal.RenameFileOptions) error

+ func (bc *BlockCache) SyncFile(options internal.SyncFileOptions) error

+ func (bc *BlockCache) WriteFile(options internal.WriteFileOptions) (int, error)

Oct 19, 2023

Changes in this version

+ const MAX_FAIL_CNT — linux/amd64

+ const MAX_POOL_USAGE — linux/amd64

+ const MIN_POOL_USAGE — linux/amd64

+ const MIN_PREFETCH — linux/amd64

+ const MIN_RANDREAD — linux/amd64

+ func NewBlockCacheComponent() internal.Component — linux/amd64

+ type Block struct — linux/amd64

+ func AllocateBlock(size uint64) (*Block, error)

+ func (b *Block) Delete() error

+ func (b *Block) ReUse()

+ func (b *Block) ReadyForReading()

+ func (b *Block) Unblock()

+ type BlockCache struct — linux/amd64

+ func (bc *BlockCache) CloseFile(options internal.CloseFileOptions) error

+ func (bc *BlockCache) Configure(_ bool) error

+ func (bc *BlockCache) Name() string

+ func (bc *BlockCache) OpenFile(options internal.OpenFileOptions) (*handlemap.Handle, error)

+ func (bc *BlockCache) ReadInBuffer(options internal.ReadInBufferOptions) (int, error)

+ func (bc *BlockCache) SetName(name string)

+ func (bc *BlockCache) SetNextComponent(nc internal.Component)

+ func (bc *BlockCache) Start(ctx context.Context) error

+ func (bc *BlockCache) Stop() error

+ func (bc *BlockCache) TempCacheCleanup() error

+ type BlockCacheOptions struct — linux/amd64

+ BlockSize uint64

+ DiskSize uint64

+ DiskTimeout uint32

+ MemSize uint64

+ PrefetchCount uint32

+ PrefetchOnOpen bool

+ TmpPath string

+ Workers uint32

+ type BlockPool struct — linux/amd64

+ func NewBlockPool(blockSize uint64, memSize uint64) *BlockPool

+ func (pool *BlockPool) MustGet() *Block

+ func (pool *BlockPool) Release(b *Block)

+ func (pool *BlockPool) Terminate()

+ func (pool *BlockPool) TryGet() *Block

+ func (pool *BlockPool) Usage() uint32

+ type ThreadPool struct — linux/amd64

+ func (t *ThreadPool) Do(priority bool)

+ func (t *ThreadPool) Schedule(urgent bool, item *workItem)

+ func (t *ThreadPool) Start()

+ func (t *ThreadPool) Stop()