Add Cloudian HyperStore Object Storage (#9748)

Author: tpodowd

client/pom.xml

@@ -642,6 +642,11 @@
             <artifactId>cloud-plugin-storage-object-ceph</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.cloudstack</groupId>
+            <artifactId>cloud-plugin-storage-object-cloudian</artifactId>
+            <version>${project.version}</version>
+        </dependency>
         <dependency>
             <groupId>org.apache.cloudstack</groupId>
             <artifactId>cloud-plugin-storage-object-simulator</artifactId>

plugins/integrations/cloudian/src/main/java/org/apache/cloudstack/cloudian/client/CloudianClient.java

@@ -0,0 +1,88 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package org.apache.cloudstack.cloudian.client;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import java.util.Date;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class CloudianCredential {
+
+    String accessKey;
+    Boolean active;
+    Date createDate;
+    Date expireDate;
+    String secretKey;
+
+    @Override
+    public String toString() {
+        return String.format("Cloudian Credential [ak=%s, sk=***, createDate=%s, expireDate=%s, active=%s]", accessKey, createDate, expireDate, active);
+    }
+
+    public String getAccessKey() {
+        return accessKey;
+    }
+
+    public void setAccessKey(String accessKey) {
+        this.accessKey = accessKey;
+    }
+
+    public String getSecretKey() {
+        return secretKey;
+    }
+
+    public void setSecretKey(String secretKey) {
+        this.secretKey = secretKey;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getExpireDate() {
+        return expireDate;
+    }
+
+    public void setExpireDate(Date expireDate) {
+        this.expireDate = expireDate;
+    }
+
+    public Boolean getActive() {
+        return active;
+    }
+
+    public void setActive(Boolean active) {
+        this.active = active;
+    }
+
+    /**
+     * Return true if this credential is newer than the other credential.
+     * @param other the credential to compare against
+     * @return true only if it is known to be newer, false if anything is null.
+     */
+    public boolean isNewerThan(CloudianCredential other) {
+        if (this.createDate == null || other == null || other.createDate == null) {
+            return false;
+        }
+        return this.createDate.after(other.createDate);
+    }
+}

plugins/integrations/cloudian/src/main/java/org/apache/cloudstack/cloudian/client/CloudianCredential.java

@@ -0,0 +1,106 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package org.apache.cloudstack.cloudian.client;
+
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class CloudianUserBucketUsage {
+
+    @JsonIgnoreProperties(ignoreUnknown = true)
+    public static class CloudianBucketUsage {
+        private String bucketName;
+        private Long   byteCount;
+        private Long   objectCount;
+        private String policyName;
+
+        /**
+         * Get the name of the bucket the usage stats belong to
+         * @return the bucket name
+         */
+        public String getBucketName() {
+            return bucketName;
+        }
+        public void setBucketName(String bucketName) {
+            this.bucketName = bucketName;
+        }
+
+        /**
+         * Get the number of bytes used by this bucket.
+         *
+         * Note: This size includes bucket and object metadata.
+         *
+         * @return bytes used by the bucket
+         */
+        public Long getByteCount() {
+            return byteCount;
+        }
+        public void setByteCount(Long byteCount) {
+            this.byteCount = byteCount;
+        }
+
+        /**
+         * Get the number of objects stored in the bucket.
+         *
+         * @return object count in the bucket
+         */
+        public Long getObjectCount() {
+            return objectCount;
+        }
+        public void setObjectCount(Long objectCount) {
+            this.objectCount = objectCount;
+        }
+
+        /**
+         * Get the storage policy this bucket belongs to.
+         * @return the name of the HyperStore storage policy.
+         */
+        public String getPolicyName() {
+            return policyName;
+        }
+        public void setPolicyName(String policyName) {
+            this.policyName = policyName;
+        }
+    }
+
+    private String userId;
+    private List<CloudianBucketUsage> buckets;
+
+    /**
+     * Get the HyperStore userId this usage info belongs to
+     * @return the HyperStore userId
+     */
+    public String getUserId() {
+        return userId;
+    }
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    /**
+     * Get the list of bucket usage objects belonging to this HyperStore userId.
+     * @return list of bucket usage objects.
+     */
+    public List<CloudianBucketUsage> getBuckets() {
+        return buckets;
+    }
+    public void setBuckets(List<CloudianBucketUsage> buckets) {
+        this.buckets = buckets;
+    }
+}