Add auth parameter to cluster management (streamnative#986)

* feat: add parameters authenticationPlugin and authenticationParameters for cluster management

* feat: add new api SetReplicationClusters and GetReplicationClusters for topic

Author: FushuWang

pkg/pulsar/topic.go

@@ -224,6 +224,12 @@ type Topics interface {
 
 	// SetInactiveTopicPolicies sets the inactive topic policies on a topic
 	SetInactiveTopicPolicies(topic utils.TopicName, data utils.InactiveTopicPolicies) error
+
+	// GetReplicationClusters get the replication clusters of a topic
+	GetReplicationClusters(topic utils.TopicName) ([]string, error)
+
+	// SetReplicationClusters sets the replication clusters on a topic
+	SetReplicationClusters(topic utils.TopicName, data []string) error
 }
 
 type topics struct {
@@ -696,3 +702,15 @@ func (t *topics) SetInactiveTopicPolicies(topic utils.TopicName, data utils.Inac
 	endpoint := t.pulsar.endpoint(t.basePath, topic.GetRestPath(), "inactiveTopicPolicies")
 	return t.pulsar.Client.Post(endpoint, data)
 }
+
+func (t *topics) SetReplicationClusters(topic utils.TopicName, data []string) error {
+	endpoint := t.pulsar.endpoint(t.basePath, topic.GetRestPath(), "replication")
+	return t.pulsar.Client.Post(endpoint, data)
+}
+
+func (t *topics) GetReplicationClusters(topic utils.TopicName) ([]string, error) {
+	var data []string
+	endpoint := t.pulsar.endpoint(t.basePath, topic.GetRestPath(), "replication")
+	err := t.pulsar.Client.Get(endpoint, &data)
+	return data, err
+}

pkg/pulsar/utils/data.go

@@ -19,12 +19,14 @@ package utils
 
 // ClusterData information on a cluster
 type ClusterData struct {
-	Name                string   `json:"-"`
-	ServiceURL          string   `json:"serviceUrl"`
-	ServiceURLTls       string   `json:"serviceUrlTls"`
-	BrokerServiceURL    string   `json:"brokerServiceUrl"`
-	BrokerServiceURLTls string   `json:"brokerServiceUrlTls"`
-	PeerClusterNames    []string `json:"peerClusterNames"`
+	Name                     string   `json:"-"`
+	ServiceURL               string   `json:"serviceUrl"`
+	ServiceURLTls            string   `json:"serviceUrlTls"`
+	BrokerServiceURL         string   `json:"brokerServiceUrl"`
+	BrokerServiceURLTls      string   `json:"brokerServiceUrlTls"`
+	PeerClusterNames         []string `json:"peerClusterNames"`
+	AuthenticationPlugin     string   `json:"authenticationPlugin"`
+	AuthenticationParameters string   `json:"authenticationParameters"`
 }
 
 // FunctionData information for a Pulsar Function