remove inventory

treeverse · Sep 5, 2023 · db2f6c4 · db2f6c4
1 parent 76a4e85
commit db2f6c4
Show file tree

Hide file tree

Showing 17 changed files with 0 additions and 1,704 deletions.
diff --git a/pkg/block/adapter.go b/pkg/block/adapter.go
@@ -130,7 +130,6 @@ type Properties struct {
 }
 
 type Adapter interface {
-	InventoryGenerator
 	Put(ctx context.Context, obj ObjectPointer, sizeBytes int64, reader io.Reader, opts PutOpts) error
 	Get(ctx context.Context, obj ObjectPointer, expectedSize int64) (io.ReadCloser, error)
 	GetWalker(uri *url.URL) (Walker, error)

diff --git a/pkg/block/azure/adapter.go b/pkg/block/azure/adapter.go
@@ -143,10 +143,6 @@ func resolveBlobURLInfo(obj block.ObjectPointer) (BlobURLInfo, error) {
 	return ResolveBlobURLInfoFromURL(parsedKey)
 }
 
-func (a *Adapter) GenerateInventory(_ context.Context, _ logging.Logger, _ string, _ bool, _ []string) (block.Inventory, error) {
-	return nil, fmt.Errorf("inventory %w", ErrNotImplemented)
-}
-
 func (a *Adapter) translatePutOpts(ctx context.Context, opts block.PutOpts) azblob.UploadStreamOptions {
 	res := azblob.UploadStreamOptions{}
 	if opts.StorageClass == nil {

diff --git a/pkg/block/gs/adapter.go b/pkg/block/gs/adapter.go
@@ -529,10 +529,6 @@ func (a *Adapter) composeMultipartUploadParts(ctx context.Context, bucketName st
 	return targetAttrs, nil
 }
 
-func (a *Adapter) GenerateInventory(_ context.Context, _ logging.Logger, _ string, _ bool, _ []string) (block.Inventory, error) {
-	return nil, fmt.Errorf("inventory %w", ErrNotImplemented)
-}
-
 func (a *Adapter) Close() error {
 	return a.client.Close()
 }

diff --git a/pkg/block/inventory.go b/pkg/block/inventory.go
diff --git a/pkg/block/local/adapter.go b/pkg/block/local/adapter.go
@@ -20,7 +20,6 @@ import (
 	"github.com/google/uuid"
 	"github.com/treeverse/lakefs/pkg/block"
 	"github.com/treeverse/lakefs/pkg/block/params"
-	"github.com/treeverse/lakefs/pkg/logging"
 	"golang.org/x/exp/slices"
 )
 
@@ -520,10 +519,6 @@ func (l *Adapter) getPartFiles(uploadID string, obj block.ObjectPointer) ([]stri
 	return names, nil
 }
 
-func (l *Adapter) GenerateInventory(_ context.Context, _ logging.Logger, _ string, _ bool, _ []string) (block.Inventory, error) {
-	return nil, ErrInventoryNotSupported
-}
-
 func (l *Adapter) BlockstoreType() string {
 	return block.BlockstoreTypeLocal
 }

diff --git a/pkg/block/mem/adapter.go b/pkg/block/mem/adapter.go
@@ -17,7 +17,6 @@ import (
 
 	"github.com/google/uuid"
 	"github.com/treeverse/lakefs/pkg/block"
-	"github.com/treeverse/lakefs/pkg/logging"
 )
 
 var (
@@ -338,10 +337,6 @@ func (a *Adapter) CompleteMultiPartUpload(_ context.Context, obj block.ObjectPoi
 	}, nil
 }
 
-func (a *Adapter) GenerateInventory(_ context.Context, _ logging.Logger, _ string, _ bool, _ []string) (block.Inventory, error) {
-	return nil, ErrInventoryNotImplemented
-}
-
 func (a *Adapter) BlockstoreType() string {
 	return block.BlockstoreTypeMem
 }

diff --git a/pkg/block/s3/inventory.go b/pkg/block/s3/inventory.go