Skip to content

Commit 9326d36

Browse files
committed
update groupbalancer.go and tests
1 parent 3fbbdfa commit 9326d36

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

groupbalancer.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ func (s int32Slice) Swap(i, j int) {
5959
s[i], s[j] = s[j], s[i]
6060
}
6161

62-
// To sort in reverse order
62+
// To sort in reverse order.
6363
func (s int32Slice) Reverse() sort.Interface {
6464
return sort.Reverse(s)
6565
}

groupbalancer_test.go

-2
Original file line numberDiff line numberDiff line change
@@ -2819,7 +2819,6 @@ func Test_stickyBalanceStrategy_Plan_ReassignmentAfterOneConsumerAdded(t *testin
28192819
verifyPlanIsBalancedAndSticky(t, s, members, plan2, nil)
28202820
}
28212821

2822-
// // I think this worked below,test passed
28232822
func Test_stickyBalanceStrategy_Plan_SameSubscriptions(t *testing.T) {
28242823
s := &StickyGroupBalancer{}
28252824

@@ -2882,7 +2881,6 @@ func Test_stickyBalanceStrategy_Plan_SameSubscriptions(t *testing.T) {
28822881
verifyPlanIsBalancedAndSticky(t, s, members, plan2, nil)
28832882
}
28842883

2885-
// test passing
28862884
func Test_stickyBalanceStrategy_Plan_LargeAssignmentWithMultipleConsumersLeaving(t *testing.T) {
28872885
s := &StickyGroupBalancer{}
28882886
r := rand.New(rand.NewSource(time.Now().UnixNano()))

0 commit comments

Comments
 (0)