EFS VolumesList implementation (#6097)

pkg/blockstorage/awsefs/awsefs.go

@@ -24,6 +24,10 @@ type efs struct {
 
 var _ blockstorage.Provider = (*efs)(nil)
 
+const (
+	dummyMarker = ""
+)
+
 // NewEFSProvider retuns a blockstorage provider for AWS EFS.
 func NewEFSProvider(config map[string]string) (blockstorage.Provider, error) {
 	awsConfig, region, err := awsebs.GetConfig(config)
@@ -112,13 +116,29 @@ func (e *efs) SetTags(ctx context.Context, resource interface{}, tags map[string
 }
 
 func (e *efs) VolumesList(ctx context.Context, tags map[string]string, zone string) ([]*blockstorage.Volume, error) {
-	return nil, errors.New("Not implemented")
+	result := make([]*blockstorage.Volume, 0)
+	for resp, req := emptyResponseRequestForFilesystems(); resp.NextMarker != nil; req.Marker = resp.NextMarker {
+		var err error
+		resp, err = e.DescribeFileSystemsWithContext(ctx, req)
+		if err != nil {
+			return nil, err
+		}
+		availables := filterAvailable(filterWithTags(resp.FileSystems, tags))
+		result = append(result, volumesFromEFSDescriptions(availables, zone)...)
+	}
+	return result, nil
 }
 
 func (e *efs) SnapshotsList(ctx context.Context, tags map[string]string) ([]*blockstorage.Snapshot, error) {
 	return nil, errors.New("Not implemented")
 }
 
+func emptyResponseRequestForFilesystems() (*awsefs.DescribeFileSystemsOutput, *awsefs.DescribeFileSystemsInput) {
+	resp := (&awsefs.DescribeFileSystemsOutput{}).SetNextMarker(dummyMarker)
+	req := &awsefs.DescribeFileSystemsInput{}
+	return resp, req
+}
+
 func (e *efs) getFileSystemDescriptionWithID(ctx context.Context, id string) (*awsefs.FileSystemDescription, error) {
 	req := &awsefs.DescribeFileSystemsInput{}
 	req.SetFileSystemId(id)

pkg/blockstorage/awsefs/filter.go

@@ -2,6 +2,8 @@ package awsefs
 
 import (
 	awsefs "github.com/aws/aws-sdk-go/service/efs"
+
+	kantags "github.com/kanisterio/kanister/pkg/blockstorage/tags"
 )
 
 func filterAvailable(descriptions []*awsefs.FileSystemDescription) []*awsefs.FileSystemDescription {
@@ -13,3 +15,13 @@ func filterAvailable(descriptions []*awsefs.FileSystemDescription) []*awsefs.Fil
 	}
 	return result
 }
+
+func filterWithTags(descriptions []*awsefs.FileSystemDescription, tags map[string]string) []*awsefs.FileSystemDescription {
+	result := make([]*awsefs.FileSystemDescription, 0)
+	for i, desc := range descriptions {
+		if kantags.IsSubset(convertFromEFSTags(desc.Tags), tags) {
+			result = append(result, descriptions[i])
+		}
+	}
+	return result
+}