(pulsar-client-go) branch master updated: Add test for admin topic creation (#1152)

[zike]

This is an automated email from the ASF dual-hosted git repository.

zike pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new ad7887e3 Add test for admin topic creation (#1152)
ad7887e3 is described below

commit ad7887e3f42171681a6fd4b16d7b4b8d389f5f89
Author: Zike Yang <z...@apache.org>
AuthorDate: Tue Jan 9 12:00:36 2024 +0800

    Add test for admin topic creation (#1152)
    
    ### Motivation
    
    Lacking tests for creating topic using pulsarAdmin
    
    ### Modifications
    
    - Add test for admin topic creation
---
 pulsaradmin/pkg/admin/topic_test.go | 55 +++++++++++++++++++++++++++++++++++++
 1 file changed, 55 insertions(+)

diff --git a/pulsaradmin/pkg/admin/topic_test.go 
b/pulsaradmin/pkg/admin/topic_test.go
new file mode 100644
index 00000000..06c33f2e
--- /dev/null
+++ b/pulsaradmin/pkg/admin/topic_test.go
@@ -0,0 +1,55 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package admin
+
+import (
+       "testing"
+
+       "github.com/apache/pulsar-client-go/pulsaradmin/pkg/admin/config"
+       "github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils"
+)
+
+func TestCreateTopic(t *testing.T) {
+       checkError := func(err error) {
+               if err != nil {
+                       t.Error(err)
+               }
+       }
+
+       cfg := &config.Config{}
+       admin, err := New(cfg)
+       checkError(err)
+
+       topic := "persistent://public/default/testCreateTopic"
+
+       topicName, err := utils.GetTopicName(topic)
+       checkError(err)
+
+       err = admin.Topics().Create(*topicName, 0)
+       checkError(err)
+
+       topicLists, err := admin.Namespaces().GetTopics("public/default")
+       checkError(err)
+
+       for _, t := range topicLists {
+               if t == topic {
+                       return
+               }
+       }
+       t.Error("Couldn't find topic: " + topic)
+}