msd api to return kubernetes network policy object

Signed-off-by: Abhijeet V <[email protected]>

clients/go/msd/client.go

@@ -777,6 +777,44 @@ func (client MSDClient) EvaluateNetworkPolicyChange(detail *NetworkPolicyChangeI
 	}
 }
 
+func (client MSDClient) GetKubernetesNetworkPolicy(domainName DomainName, serviceName EntityName, networkPolicyType string, domainAsNamespace string, matchingTag string) (*KubernetesNetworkPolicy, string, error) {
+	var data *KubernetesNetworkPolicy
+	headers := map[string]string{
+		"If-None-Match": matchingTag,
+	}
+	url := client.URL + "/domain/" + fmt.Sprint(domainName) + "/service/" + fmt.Sprint(serviceName) + "/kubernetesnetworkpolicy" + encodeParams(encodeStringParam("type", string(networkPolicyType), ""), encodeStringParam("domainAsNamespace", string(domainAsNamespace), ""))
+	resp, err := client.httpGet(url, headers)
+	if err != nil {
+		return nil, "", err
+	}
+	defer resp.Body.Close()
+	switch resp.StatusCode {
+	case 200, 304:
+		if 304 != resp.StatusCode {
+			err = json.NewDecoder(resp.Body).Decode(&data)
+			if err != nil {
+				return nil, "", err
+			}
+		}
+		tag := resp.Header.Get(rdl.FoldHttpHeaderName("ETag"))
+		return data, tag, nil
+	default:
+		var errobj rdl.ResourceError
+		contentBytes, err := io.ReadAll(resp.Body)
+		if err != nil {
+			return nil, "", err
+		}
+		json.Unmarshal(contentBytes, &errobj)
+		if errobj.Code == 0 {
+			errobj.Code = resp.StatusCode
+		}
+		if errobj.Message == "" {
+			errobj.Message = string(contentBytes)
+		}
+		return nil, "", errobj
+	}
+}
+
 func (client MSDClient) GetRdlSchema() (*rdl.Schema, error) {
 	var data *rdl.Schema
 	url := client.URL + "/schema"