Get Specific Replication Pair

inttests/replication_test.go

@@ -327,6 +327,17 @@ func TestQueryReplicationPairs(t *testing.T) {
 	}
 }
 
+// Query Specific Replication Pair
+func TestQueryReplicationPair(t *testing.T) {
+	if C2 == nil {
+		t.Skip("no client connection to replication target system")
+	}
+
+	pair, err := rep.pair.GetReplicationPair(rep.pair.ReplicaitonPair.ID)
+	assert.Nil(t, err)
+	assert.NotNil(t, pair)
+}
+
 // Query Replication Pair Statistics
 func TestQueryReplicationPairsStatistics(t *testing.T) {
 	if C2 == nil {

replication.go

@@ -212,6 +212,17 @@ func (c *Client) GetAllReplicationPairs() ([]*types.ReplicationPair, error) {
 	return pairs, err
 }
 
+// GetReplicationPair returns a specific replication pair on the system.
+func (rp *ReplicationPair) GetReplicationPair(id string) (*types.ReplicationPair, error) {
+	defer TimeSpent("GetReplicationPairs", time.Now())
+
+	path := "/api/instances/ReplicationPair::" + id
+
+	var pair *types.ReplicationPair
+	err := rp.client.getJSONWithRetry(http.MethodGet, path, nil, &pair)
+	return pair, err
+}
+
 // GetReplicationPairs returns a list of replication pairs associated to the rcg.
 func (rcg *ReplicationConsistencyGroup) GetReplicationPairs() ([]*types.ReplicationPair, error) {
 	defer TimeSpent("GetReplicationPairs", time.Now())