cache

package

v0.0.0-...-daf2a86 Latest Latest Go to latest Published: Jun 10, 2024 License: BSD-3-Clause Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewBlockBlobCache(bs cloud.BlobStore, dir string, cacheSize int64) (*BlockBlobCache, error)

func (c *BlockBlobCache) Delete(key string) error

func (c *BlockBlobCache) Get(key string) (cloud.GetReader, error)

func (c *BlockBlobCache) List() ([]string, error)

func (c *BlockBlobCache) Put(key string) (cloud.PutWriter, error)

func (c *BlockBlobCache) Size(key string) (int64, error)

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

func NewOpenFileCache(maxEntries int) *OpenFileCache

func (c *OpenFileCache) Open(name string) (ReaderAtCloser, error)

func (c *OpenFileCache) Remove(name string)

type ReaderAtCloser interface {
	io.ReaderAt
	io.Closer
}

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

func NewStagedBlobUploader(bs cloud.BlobStore, dir string) (*StagedBlobUploader, error)

func (u *StagedBlobUploader) Delete(key string) error

func (u *StagedBlobUploader) Get(key string) (cloud.GetReader, error)

func (u *StagedBlobUploader) List() ([]string, error)

func (u *StagedBlobUploader) Put(key string) (cloud.PutWriter, error)

func (u *StagedBlobUploader) Size(key string) (int64, error)