diff options
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 { |