diff options
| author |  kim <89579420+NyaaaWhatsUpDoc@users.noreply.github.com> | 2022-11-06 12:30:08 +0000 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2022-11-06 13:30:08 +0100 |
| commit | 05a8baa53ae7983b8fa2d79589ff0cab7ab1b22b (patch) | |
| tree | 041f88f0f035df2c3793565d44700e0e5fe09c2d /internal/storage/local.go | |
| parent | [docs] add note about Alpha status right at the top (#971) (diff) | |
| download | gotosocial-05a8baa53ae7983b8fa2d79589ff0cab7ab1b22b.tar.xz | |
[bugfix] KVStore doesn't like lost+found directory (#972)
* bump go-store version to v2.0.5, init kv.KVStore without initial clean (as we are using for storage, not as a key-value store)
Signed-off-by: kim <grufwub@gmail.com>
* remove newline
Signed-off-by: kim <grufwub@gmail.com>
Signed-off-by: kim <grufwub@gmail.com>
Diffstat (limited to 'internal/storage/local.go')
| -rw-r--r-- | internal/storage/local.go | 32 |
1 files changed, 1 insertions, 31 deletions
diff --git a/internal/storage/local.go b/internal/storage/local.go index 3fde7f0b9..9a5f971a2 100644 --- a/internal/storage/local.go +++ b/internal/storage/local.go @@ -20,43 +20,13 @@ package storage import ( "context" - "io" "net/url" "codeberg.org/gruf/go-store/v2/kv" - "codeberg.org/gruf/go-store/v2/storage" ) type Local struct { - KVStore *kv.KVStore -} - -func (l *Local) Get(ctx context.Context, key string) ([]byte, error) { - return l.KVStore.Get(ctx, key) -} - -func (l *Local) GetStream(ctx context.Context, key string) (io.ReadCloser, error) { - return l.KVStore.GetStream(ctx, key) -} - -func (l *Local) PutStream(ctx context.Context, key string, r io.Reader) error { - err := l.KVStore.PutStream(ctx, key, r) - if err == storage.ErrAlreadyExists { - return ErrAlreadyExists - } - return err -} - -func (l *Local) Put(ctx context.Context, key string, value []byte) error { - err := l.KVStore.Put(ctx, key, value) - if err == storage.ErrAlreadyExists { - return ErrAlreadyExists - } - return err -} - -func (l *Local) Delete(ctx context.Context, key string) error { - return l.KVStore.Delete(ctx, key) + *kv.KVStore } func (l *Local) URL(ctx context.Context, key string) *url.URL { |