Skip to content

Commit

Permalink
fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
crossoverJie committed Dec 13, 2024
1 parent a4907cd commit e3e3246
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
2 changes: 1 addition & 1 deletion pulsar/client_impl_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -246,7 +246,7 @@ func TestTokenAuthWithClientVersion(t *testing.T) {
topicState, err := admin.Topics().GetStats(*topicName)
assert.Nil(t, err)
publisher := topicState.Publishers[0]
assert.True(t, strings.HasPrefix(publisher.ClientVersion, "Pulsar Go version"))
assert.True(t, strings.HasPrefix(publisher.ClientVersion, "Pulsar Go version"))
assert.True(t, strings.HasSuffix(publisher.ClientVersion, "-test-client"))
}

Expand Down
5 changes: 3 additions & 2 deletions pulsar/consumer_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@ import (
"os"
"regexp"
"strconv"
"strings"
"sync"
"sync/atomic"
"testing"
Expand Down Expand Up @@ -5033,7 +5034,7 @@ func TestClientVersion(t *testing.T) {
topicState, err = admin.Topics().GetStats(*topicName)
assert.Nil(t, err)
publisher = topicState.Publishers[0]
assert.True(t, strings.HasPrefix(publisher.ClientVersion, "Pulsar Go version"))
assert.True(t, strings.HasSuffix(publisher.ClientVersion, "-test-client"))
assert.True(t, strings.HasPrefix(publisher.ClientVersion, "Pulsar Go version"))
assert.True(t, strings.HasSuffix(publisher.ClientVersion, "-test-client"))

}

0 comments on commit e3e3246

Please sign in to comment.