Add command cluster update_failure_domain (#36)

master issue: #2
streamnative · Mar 14, 2023 · 7901a46 · 7901a46
1 parent 200e3bc
commit 7901a46
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/pulsar/cluster.go b/pkg/pulsar/cluster.go
@@ -14,6 +14,7 @@ type Clusters interface {
 	GetFailureDomain(clusterName, domainName string) (FailureDomainData, error)
 	ListFailureDomains(string) (FailureDomainMap, error)
 	DeleteFailureDomain(FailureDomainData) error
+	UpdateFailureDomain(FailureDomainData) error
 }
 
 type clusters struct {
@@ -91,3 +92,7 @@ func (c *clusters) DeleteFailureDomain(data FailureDomainData) error {
 	endpoint := c.client.endpoint(c.basePath, data.ClusterName, "failureDomains", data.DomainName)
 	return c.client.delete(endpoint, nil)
 }
+func (c *clusters) UpdateFailureDomain(data FailureDomainData) error {
+	endpoint := c.client.endpoint(c.basePath, data.ClusterName, "failureDomains", data.DomainName)
+	return c.client.post(endpoint, &data, nil)
+}