Documentation
¶
Overview ¶
Package memory provides an in-memory implementation of store.Store for testing.
Index ¶
- type Store
- func (s *Store) Close() error
- func (s *Store) CreateBucket(_ context.Context, b *model.Bucket) error
- func (s *Store) CreateObject(_ context.Context, o *model.Object) error
- func (s *Store) CreateUploadSession(_ context.Context, u *model.UploadSession) error
- func (s *Store) DB() *grove.DB
- func (s *Store) DecrementCASRef(_ context.Context, hash string) error
- func (s *Store) DeleteBucket(_ context.Context, id string) error
- func (s *Store) DeleteCASEntry(_ context.Context, hash string) error
- func (s *Store) DeleteQuota(_ context.Context, tenantKey string) error
- func (s *Store) GetBucket(_ context.Context, id string) (*model.Bucket, error)
- func (s *Store) GetBucketByName(_ context.Context, name string) (*model.Bucket, error)
- func (s *Store) GetCASEntry(_ context.Context, hash string) (*model.CASEntry, error)
- func (s *Store) GetObject(_ context.Context, id string) (*model.Object, error)
- func (s *Store) GetObjectByKey(_ context.Context, bucketID, key string) (*model.Object, error)
- func (s *Store) GetQuota(_ context.Context, tenantKey string) (*model.Quota, error)
- func (s *Store) GetUploadSession(_ context.Context, id string) (*model.UploadSession, error)
- func (s *Store) IncrementCASRef(_ context.Context, hash string) error
- func (s *Store) ListAllObjects(_ context.Context, limit int) ([]*model.Object, error)
- func (s *Store) ListBuckets(_ context.Context, tenantKey string) ([]*model.Bucket, error)
- func (s *Store) ListCASEntries(_ context.Context) ([]*model.CASEntry, error)
- func (s *Store) ListExpiredUploads(_ context.Context) ([]*model.UploadSession, error)
- func (s *Store) ListObjects(_ context.Context, bucketID string, opts ...store.ListOption) ([]*model.Object, error)
- func (s *Store) ListQuotas(_ context.Context) ([]*model.Quota, error)
- func (s *Store) ListUnpinnedCAS(_ context.Context) ([]*model.CASEntry, error)
- func (s *Store) ListUploads(_ context.Context) ([]*model.UploadSession, error)
- func (s *Store) Migrate(_ context.Context, _ ...*migrate.Group) error
- func (s *Store) Ping(_ context.Context) error
- func (s *Store) PutCASEntry(_ context.Context, entry *model.CASEntry) error
- func (s *Store) SetCASPinned(_ context.Context, hash string, pinned bool) error
- func (s *Store) SetQuota(_ context.Context, q *model.Quota) error
- func (s *Store) SoftDeleteObject(_ context.Context, id string) error
- func (s *Store) UpdateBucket(_ context.Context, b *model.Bucket) error
- func (s *Store) UpdateObject(_ context.Context, o *model.Object) error
- func (s *Store) UpdateQuotaUsage(_ context.Context, tenantKey string, deltaBytes, deltaObjects int64) error
- func (s *Store) UpdateUploadSession(_ context.Context, u *model.UploadSession) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store is an in-memory implementation of store.Store.
func (*Store) CreateUploadSession ¶
func (*Store) DecrementCASRef ¶
func (*Store) GetBucketByName ¶
func (*Store) GetCASEntry ¶
func (*Store) GetObjectByKey ¶
func (*Store) GetUploadSession ¶
func (*Store) IncrementCASRef ¶
func (*Store) ListAllObjects ¶
func (*Store) ListBuckets ¶
func (*Store) ListCASEntries ¶
func (*Store) ListExpiredUploads ¶
func (*Store) ListObjects ¶
func (*Store) ListUnpinnedCAS ¶
func (*Store) ListUploads ¶
func (*Store) PutCASEntry ¶
func (*Store) SetCASPinned ¶
func (*Store) SoftDeleteObject ¶
func (*Store) UpdateQuotaUsage ¶
func (*Store) UpdateUploadSession ¶
Source Files
Click to show internal directories.
Click to hide internal directories.