implement vfs with openstack swift

util/pkg/vfs/context.go

@@ -112,6 +112,10 @@ func (c *VFSContext) BuildVfsPath(p string) (Path, error) {
 		return c.buildKubernetesPath(p)
 	}
 
+	if strings.HasPrefix(p, "swift://") {
+		return c.buildOpenstackSwiftPath(p)
+	}
+
 	return nil, fmt.Errorf("unknown / unhandled path type: %q", p)
 }
 
@@ -309,3 +313,21 @@ func (c *VFSContext) getGCSClient() (*storage.Service, error) {
 	c.gcsClient = gcsClient
 	return gcsClient, nil
 }
+
+func (c *VFSContext) buildOpenstackSwiftPath(p string) (*SwiftPath, error) {
+	u, err := url.Parse(p)
+	if err != nil {
+		return nil, fmt.Errorf("invalid openstack cloud storage path: %q", p)
+	}
+
+	if u.Scheme != "swift" {
+		return nil, fmt.Errorf("invalid openstack cloud storage path: %q", p)
+	}
+
+	swiftClient, err := NewSwiftClient()
+	if err != nil {
+		return nil, err
+	}
+
+	return NewSwiftPath(swiftClient, strings.TrimSuffix(u.Host, "/"), u.Path)
+}