From 057317f8b2aff6318e32df77171a00504e322a67 Mon Sep 17 00:00:00 2001 From: "zhenshan.cao" Date: Sun, 3 Oct 2021 20:54:13 +0800 Subject: [PATCH] [skip ci] Fix golint error in pulsar_client.go (#9155) Signed-off-by: zhenshan.cao --- internal/util/mqclient/pulsar_client.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/util/mqclient/pulsar_client.go b/internal/util/mqclient/pulsar_client.go index 6e0b75dd62..f6c1e04a7e 100644 --- a/internal/util/mqclient/pulsar_client.go +++ b/internal/util/mqclient/pulsar_client.go @@ -27,6 +27,8 @@ type pulsarClient struct { var sc *pulsarClient var once sync.Once +// GetPulsarClientInstance creates a pulsarClient object +// according to the parameter opts of type pulsar.ClientOptions func GetPulsarClientInstance(opts pulsar.ClientOptions) (*pulsarClient, error) { once.Do(func() { c, err := pulsar.NewClient(opts)