block_cache

Aug 22, 2025

Changes in this version

type BlockCache

+ func (bc *BlockCache) StatFs() (*common.Statfs_t, bool, error)

type BlockCacheOptions

+ Consistency bool

Apr 25, 2025

Changes in this version

+ const BlockFlagDirty — darwin/amd64, js/wasm, windows/amd64

+ const BlockFlagDownloading — darwin/amd64, js/wasm, windows/amd64

+ const BlockFlagFailed — darwin/amd64, js/wasm, windows/amd64

+ const BlockFlagFresh — darwin/amd64, js/wasm, windows/amd64

+ const BlockFlagSynced — darwin/amd64, js/wasm, windows/amd64

+ const BlockFlagUploading — darwin/amd64, js/wasm, windows/amd64

+ const BlockStatusDownloadFailed — darwin/amd64, js/wasm, windows/amd64

+ const BlockStatusDownloaded — darwin/amd64, js/wasm, windows/amd64

+ const BlockStatusUploadFailed — darwin/amd64, js/wasm, windows/amd64

+ const BlockStatusUploaded — darwin/amd64, js/wasm, windows/amd64

+ const MAX_BLOCKS — darwin/amd64, js/wasm, windows/amd64

+ const MAX_FAIL_CNT — darwin/amd64, js/wasm, windows/amd64

+ const MAX_POOL_USAGE — darwin/amd64, js/wasm, windows/amd64

+ const MIN_POOL_USAGE — darwin/amd64, js/wasm, windows/amd64

+ const MIN_PREFETCH — darwin/amd64, js/wasm, windows/amd64

+ const MIN_RANDREAD — darwin/amd64, js/wasm, windows/amd64

+ const MIN_WRITE_BLOCK — darwin/amd64, js/wasm, windows/amd64

+ func NewBlockCacheComponent() internal.Component — darwin/amd64, js/wasm, windows/amd64

+ type Block struct — darwin/amd64, js/wasm, windows/amd64

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

+ func (b *Block) Delete() error

+ 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) ReUse()

+ func (b *Block) Ready(val int)

+ func (b *Block) Unblock()

+ func (b *Block) Uploading()

+ type BlockCache struct — darwin/amd64, js/wasm, windows/amd64

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

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

+ 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) GenConfig() string

+ 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) RenameDir(options internal.RenameDirOptions) error

+ func (bc *BlockCache) RenameFile(options internal.RenameFileOptions) 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) SyncFile(options internal.SyncFileOptions) error

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

+ type BlockCacheOptions struct — darwin/amd64, js/wasm, windows/amd64

+ BlockSize float64

+ DiskSize uint64

+ DiskTimeout uint32

+ MemSize uint64

+ PrefetchCount uint32

+ PrefetchOnOpen bool

+ TmpPath string

+ Workers uint32

+ type BlockPool struct — darwin/amd64, js/wasm, windows/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 Stream struct

+ BlockSize int64

+ BufferSize uint64

+ CachedObjLimit int32

+ func (st *Stream) Configure(_ bool) error

+ func (st *Stream) Name() string

+ type StreamOptions struct

+ BlockSize uint64

+ BufferSize uint64

+ CachedObjLimit uint64

+ FileCaching bool

+ MaxBlocksPerFile uint64

+ StreamCacheMb uint64

+ type ThreadPool struct — darwin/amd64, js/wasm, windows/amd64

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

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

+ func (t *ThreadPool) Start()

+ func (t *ThreadPool) Stop()

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()