diff --git a/pulsaradmin/pkg/pulsar/cluster.go b/pulsaradmin/pkg/pulsar/cluster.go index 4c4acd690e..c9517d4f78 100644 --- a/pulsaradmin/pkg/pulsar/cluster.go +++ b/pulsaradmin/pkg/pulsar/cluster.go @@ -8,6 +8,7 @@ type Clusters interface { Create(ClusterData) error Delete(string) error Update(ClusterData) error + UpdatePeerClusters(string, []string) error } type clusters struct { @@ -50,3 +51,8 @@ func (c *clusters) Update(cdata ClusterData) error { endpoint := c.client.endpoint(c.basePath, cdata.Name) return c.client.post(endpoint, &cdata, nil) } + +func (c *clusters) UpdatePeerClusters(cluster string, peerClusters []string) error { + endpoint := c.client.endpoint(c.basePath, cluster, "peers") + return c.client.post(endpoint, peerClusters, nil) +}