ownwrites

Documentation

Overview

Package ownwrites defines a blob.Storage wrapper that ensures that recently-written blobs show up in ListBlob() results, if the underlying provider is eventually consistent when it comes to list results.

Index

• func NewWrapper(st, cacheStorage blob.Storage, prefixes []blob.ID, cacheDuration time.Duration) blob.Storage
• type CacheStorage
  • func (s *CacheStorage) DeleteBlob(ctx context.Context, blobID blob.ID) error
  • func (s *CacheStorage) ListBlobs(ctx context.Context, prefix blob.ID, cb func(blob.Metadata) error) error
  • func (s *CacheStorage) PutBlob(ctx context.Context, blobID blob.ID, data blob.Bytes, opts blob.PutOptions) error

Functions

func NewWrapper

func NewWrapper(st, cacheStorage blob.Storage, prefixes []blob.ID, cacheDuration time.Duration) blob.Storage

NewWrapper returns new wrapper that ensures list consistency with local writes for the given set of blob prefixes. It leverages the provided local cache storage to maintain markers keeping track of recently created and deleted blobs.

Types

type CacheStorage

type CacheStorage struct {
	blob.Storage
	// contains filtered or unexported fields
}

CacheStorage implements a wrapper around blob.Storage that ensures recent local mutations are reflected in ListBlobs() results.

func (*CacheStorage) DeleteBlob

func (s *CacheStorage) DeleteBlob(ctx context.Context, blobID blob.ID) error

DeleteBlob implements blob.Storage and writes markers into local cache for all successful deletes.

func (*CacheStorage) ListBlobs

func (s *CacheStorage) ListBlobs(ctx context.Context, prefix blob.ID, cb func(blob.Metadata) error) error

ListBlobs implements blob.Storage and merges provider-returned results with cached ones.

func (*CacheStorage) PutBlob

func (s *CacheStorage) PutBlob(ctx context.Context, blobID blob.ID, data blob.Bytes, opts blob.PutOptions) error

PutBlob implements blob.Storage and writes markers into local cache for all successful writes.