Add option for Single Active Replication (fixes #542) (#550)

Signed-off-by: flbla <flbla@users.noreply.github.com>

Author: flbla

client/replication.go

@@ -15,15 +15,16 @@ func GetReplicationBody(d *schema.ResourceData) models.ReplicationBody {
 	schedule := d.Get("schedule").(string)
 
 	body := models.ReplicationBody{
-		Name:                 d.Get("name").(string),
-		Description:          d.Get("description").(string),
-		Override:             d.Get("override").(bool),
-		Enabled:              d.Get("enabled").(bool),
-		Deletion:             d.Get("deletion").(bool),
-		DestNamespace:        d.Get("dest_namespace").(string),
-		DestNamespaceReplace: d.Get("dest_namespace_replace").(int),
-		CopyByChunk:          d.Get("copy_by_chunk").(bool),	
-		Speed:                d.Get("speed").(int),
+		Name:                    d.Get("name").(string),
+		Description:             d.Get("description").(string),
+		Override:                d.Get("override").(bool),
+		Enabled:                 d.Get("enabled").(bool),
+		Deletion:                d.Get("deletion").(bool),
+		DestNamespace:           d.Get("dest_namespace").(string),
+		DestNamespaceReplace:    d.Get("dest_namespace_replace").(int),
+		CopyByChunk:             d.Get("copy_by_chunk").(bool),
+		SingleActiveReplication: d.Get("single_active_replication").(bool),
+		Speed:                   d.Get("speed").(int),
 	}
 
 	if action == "push" {

docs/resources/replication.md

@@ -74,6 +74,7 @@ resource "harbor_replication" "alpine" {
 - `dest_namespace` (String) Specify the destination namespace. if empty, the resource will be put under the same namespace as the source.
 - `dest_namespace_replace` (Number) Specify the destination namespace flattening policy. Integers from `-1` to `3` are valid values in the harbor API. A value of `-1` will 'Flatten All Levels', `0` means 'No Flattening', `1` 'Flatten 1 Level', `2` 'Flatten 2 Levels', `3` 'Flatten 3 Levels' (Default: `-1`, see [Replication Rules](https://goharbor.io/docs/latest/administration/configuring-replication/create-replication-rules/) for more details)
 - `copy_by_chunk` (Boolean) Specify whether to enable the artifact blobs copied by chunks. (Default: `false`) 
+- `single_active_replication` (Boolean), prevent parallel runs under the same replication. (Default: `false`)
 - `enabled` (Boolean) Specify whether the replication is enabled. (Default: `true`)
 - `execute_on_changed` (Boolean) Specify whether to execute the replication rule if new or modified. (Default: `false`)
 - `filters` (Block Set) (see [below for nested schema](#nestedblock--filters))

models/replications.go

@@ -21,12 +21,13 @@ type ReplicationBody struct {
 			Cron string `json:"cron,omitempty"`
 		} `json:"trigger_settings,omitempty"`
 	} `json:"trigger,omitempty"`
-	Enabled     bool                 `json:"enabled"`
-	Deletion    bool                 `json:"deletion,omitempty"`
-	Override    bool                 `json:"override,omitempty"`
-	CopyByChunk bool                 `json:"copy_by_chunk,omitempty"`
-	Filters     []ReplicationFilters `json:"filters,omitempty"`
-	Speed       int                  `json:"speed,omitempty"`
+	Enabled                 bool                 `json:"enabled"`
+	Deletion                bool                 `json:"deletion,omitempty"`
+	Override                bool                 `json:"override,omitempty"`
+	CopyByChunk             bool                 `json:"copy_by_chunk,omitempty"`
+	SingleActiveReplication bool                 `json:"single_active_replication,omitempty"`
+	Filters                 []ReplicationFilters `json:"filters,omitempty"`
+	Speed                   int                  `json:"speed,omitempty"`
 }
 
 type ReplicationFilters struct {

provider/resource_replication.go

@@ -70,6 +70,11 @@ func resourceReplication() *schema.Resource {
 				Optional: true,
 				Default:  false,
 			},
+			"single_active_replication": {
+				Type:     schema.TypeBool,
+				Optional: true,
+				Default:  false,
+			},
 			"filters": {
 				Type:     schema.TypeSet,
 				Optional: true,
@@ -207,6 +212,7 @@ func resourceReplicationRead(d *schema.ResourceData, m interface{}) error {
 	d.Set("dest_namespace", jsonDataReplication.DestNamespace)
 	d.Set("dest_namespace_replace", jsonDataReplication.DestNamespaceReplace)
 	d.Set("copy_by_chunk", jsonDataReplication.CopyByChunk)
+	d.Set("single_active_replication", jsonDataReplication.SingleActiveReplication)
 
 	return nil
 }