bio

Documentation

Index

• func CloseAll()
• func CompactChunksData(ctx context.Context, entry *types.Metadata, chunkStore metastore.ChunkStore, ...) (resultErr error)
• func DeleteChunksData(ctx context.Context, entry *types.Metadata, chunkStore metastore.ChunkStore, ...) error
• func InitPageCache(cfg *config.FS)
• type InvalidCacheHook
• type Reader
  • func NewChunkReader(entry *types.Metadata, chunkStore metastore.ChunkStore, ...) Reader
• type Writer
  • func NewChunkWriter(reader Reader) Writer

Functions

func CloseAll

func CloseAll()

func CompactChunksData

func CompactChunksData(ctx context.Context, entry *types.Metadata, chunkStore metastore.ChunkStore, dataStore storage.Storage) (resultErr error)

func DeleteChunksData

func DeleteChunksData(ctx context.Context, entry *types.Metadata, chunkStore metastore.ChunkStore, dataStore storage.Storage) error

func InitPageCache

func InitPageCache(cfg *config.FS)

Types

type InvalidCacheHook

type InvalidCacheHook func(eid int64)

type Reader

type Reader interface {
	ReadAt(ctx context.Context, dest []byte, off int64) (int64, error)
	Close()
}

func NewChunkReader

func NewChunkReader(entry *types.Metadata, chunkStore metastore.ChunkStore, dataStore storage.Storage) Reader

type Writer

type Writer interface {
	WriteAt(ctx context.Context, data []byte, off int64) (int64, error)
	Flush(ctx context.Context) error
	Fsync(ctx context.Context) error
	Close()
}

func NewChunkWriter

func NewChunkWriter(reader Reader) Writer