[Feat] SWR: Add image retention policy APIs

Author: muneeb-jan

openstack/swr/v2/policy/Create.go

@@ -0,0 +1,36 @@
+package policy
+
+import (
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/build"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/extract"
+)
+
+type CreateOpts struct {
+	// Retention policy matching algorithm. The value is "or".
+	Algorithm string `json:"algorithm" required:"true"`
+	// List of retention rules.
+	Rules []Rule `json:"rules" required:"true"`
+}
+
+// This function is used to create an image retention policy.
+func Create(client *golangsdk.ServiceClient, organization string, repository string, opts CreateOpts) (string, error) {
+	b, err := build.RequestBody(opts, "")
+	if err != nil {
+		return "", err
+	}
+
+	// POST /v2/manage/namespaces/{namespace}/repos/{repository}/retentions
+	raw, err := client.Post(client.ServiceURL("manage", "namespaces", organization, "repos", repository, "retentions"), b, nil, &golangsdk.RequestOpts{
+		OkCodes: []int{201},
+	})
+	if err != nil {
+		return "", err
+	}
+
+	var res struct {
+		ID string `json:"id"`
+	}
+	err = extract.Into(raw.Body, &res)
+	return res.ID, err
+}

openstack/swr/v2/policy/Delete.go

@@ -0,0 +1,10 @@
+package policy
+
+import golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+
+// This function is used to delete an image retention policy.
+func Delete(client *golangsdk.ServiceClient, organization, repository, policy string) (err error) {
+	// DELETE /v2/manage/namespaces/{namespace}/repos/{repository}/retentions/{retention_id}
+	_, err = client.Delete(client.ServiceURL("manage", "namespaces", organization, "repos", repository, "retentions", policy), nil)
+	return err
+}

openstack/swr/v2/policy/Get.go

@@ -0,0 +1,30 @@
+package policy
+
+import (
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/extract"
+)
+
+// This function is used to query details about an image retention policy.
+func Get(client *golangsdk.ServiceClient, organization, repository, policy string) (*ImageRetentionPolicy, error) {
+	// GET /v2/manage/namespaces/{namespace}/repos/{repository}/retentions/{retention_id}
+	raw, err := client.Get(client.ServiceURL("manage", "namespaces", organization, "repos", repository, "retentions", policy), nil, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	var res ImageRetentionPolicy
+	err = extract.Into(raw.Body, &res)
+	return &res, err
+}
+
+type ImageRetentionPolicy struct {
+	// Retention policy matching rule. The value is or.
+	Algorithm string `json:"algorithm"`
+	// ID.
+	ID int `json:"id"`
+	// Image retention policy.
+	Rules []Rule `json:"rules"`
+	// Reserved field.
+	Scope string `json:"scope"`
+}

openstack/swr/v2/policy/List.go

@@ -0,0 +1,19 @@
+package policy
+
+import (
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/extract"
+)
+
+// This function is used to query image retention policies.
+func List(client *golangsdk.ServiceClient, organization, repository string) ([]ImageRetentionPolicy, error) {
+	// GET /v2/manage/namespaces/{namespace}/repos/{repository}/retentions}
+	raw, err := client.Get(client.ServiceURL("manage", "namespaces", organization, "repos", repository, "retentions"), nil, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	var res []ImageRetentionPolicy
+	err = extract.Into(raw.Body, &res)
+	return res, err
+}

openstack/swr/v2/policy/Update.go

@@ -0,0 +1,27 @@
+package policy
+
+import (
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/build"
+)
+
+type UpdateOpts struct {
+	// Retention policy matching algorithm. The value is "or".
+	Algorithm string `json:"algorithm" required:"true"`
+	// List of retention rules.
+	Rules []Rule `json:"rules" required:"true"`
+}
+
+// This function is used to modify an image retention policy.
+func Update(client *golangsdk.ServiceClient, organization, repository, policy string, opts UpdateOpts) (err error) {
+	b, err := build.RequestBody(opts, "")
+	if err != nil {
+		return
+	}
+
+	// PATCH /v2/manage/namespaces/{namespace}/repos/{repository}/retentions/{retention_id}
+	_, err = client.Patch(client.ServiceURL("manage", "namespaces", organization, "repos", repository, "retentions", policy), b, nil, &golangsdk.RequestOpts{
+		OkCodes: []int{201},
+	})
+	return
+}

openstack/swr/v2/policy/common.go

@@ -0,0 +1,22 @@
+package policy
+
+type Rule struct {
+	// Retention policy type.
+	// The value can be "date_rule" (number of days) or "tag_rule" (number of tags).
+	Template string `json:"template" required:"true"`
+	// Parameters for the retention rule.
+	// If Template is "date_rule", Params should contain {"days": "xxx"}.
+	// If Template is "tag_rule", Params should contain {"num": "xxx"}.
+	Params map[string]string `json:"params" required:"true"`
+	// Exception image selectors that should not be affected by retention.
+	TagSelectors []TagSelector `json:"tag_selectors" required:"true"`
+}
+
+type TagSelector struct {
+	// Matching rule type for tags.
+	// The value can be "label" or "regexp".
+	Kind string `json:"kind" required:"true"`
+	// If Kind is "label", the tag to match.
+	// If Kind is "regexp", the regular expression to match.
+	Pattern string `json:"pattern" required:"true"`
+}