stores

type AsyncStore ¶

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

AsyncStore allows blobs to be Posted in the background by a pool of workers. It is not safe for concurrent use by multiple callers.

Close must return nil for any previous Post to be considered successful. When in doubt, call Exists on the underlying store.

If you have a loop that repeatedly calls Post, and Post is high latency, AsyncStore will probably improve performance. AsyncStore is not Read-Your-Writes consistent.

func NewAsyncStore(target Store, numWorkers int) *AsyncStore

func (s *AsyncStore) Close() error

func (s *AsyncStore) Delete(ctx context.Context, id ID) error

func (s *AsyncStore) Exists(ctx context.Context, id ID) (bool, error)

func (s *AsyncStore) Get(ctx context.Context, id ID, buf []byte) (int, error)

func (s *AsyncStore) Hash(x []byte) ID

func (s *AsyncStore) List(ctx context.Context, span cadata.Span, ids []ID) (int, error)

func (s *AsyncStore) MaxSize() int

func (s *AsyncStore) Post(ctx context.Context, data []byte) (ID, error)

type ID ¶

type ID = cadata.ID

type MemSet ¶

type MemSet map[ID]struct{}

func (ms MemSet) Add(ctx context.Context, id ID) error

func (ms MemSet) Count() int

func (ms MemSet) Delete(ctx context.Context, id ID) error

func (ms MemSet) Exists(ctx context.Context, id ID) (bool, error)

func (ms MemSet) List(ctx context.Context, span cadata.Span, ids []cadata.ID) (int, error)

type Set ¶

type Set = cadata.Set

type Store ¶

type Store = cadata.Store

func AssertReadOnly(x Store) Store