diff options
Diffstat (limited to 'weed/mq/pub_balancer/allocate_test.go')
| -rw-r--r-- | weed/mq/pub_balancer/allocate_test.go | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/weed/mq/pub_balancer/allocate_test.go b/weed/mq/pub_balancer/allocate_test.go index 4b36af388..63692af0f 100644 --- a/weed/mq/pub_balancer/allocate_test.go +++ b/weed/mq/pub_balancer/allocate_test.go @@ -95,8 +95,8 @@ func TestEnsureAssignmentsToActiveBrokersX(t *testing.T) { followerCount: 1, assignments: []*mq_pb.BrokerPartitionAssignment{ { - LeaderBroker: "", - Partition: &mq_pb.Partition{}, + LeaderBroker: "", + Partition: &mq_pb.Partition{}, FollowerBroker: "localhost:2", }, }, @@ -110,8 +110,8 @@ func TestEnsureAssignmentsToActiveBrokersX(t *testing.T) { followerCount: 1, assignments: []*mq_pb.BrokerPartitionAssignment{ { - LeaderBroker: "localhost:1", - Partition: &mq_pb.Partition{}, + LeaderBroker: "localhost:1", + Partition: &mq_pb.Partition{}, FollowerBroker: "", }, }, @@ -125,8 +125,8 @@ func TestEnsureAssignmentsToActiveBrokersX(t *testing.T) { followerCount: 1, assignments: []*mq_pb.BrokerPartitionAssignment{ { - LeaderBroker: "localhost:1", - Partition: &mq_pb.Partition{}, + LeaderBroker: "localhost:1", + Partition: &mq_pb.Partition{}, FollowerBroker: "localhost:200", }, }, @@ -140,8 +140,8 @@ func TestEnsureAssignmentsToActiveBrokersX(t *testing.T) { followerCount: 1, assignments: []*mq_pb.BrokerPartitionAssignment{ { - LeaderBroker: "localhost:100", - Partition: &mq_pb.Partition{}, + LeaderBroker: "localhost:100", + Partition: &mq_pb.Partition{}, FollowerBroker: "localhost:200", }, }, @@ -155,8 +155,8 @@ func TestEnsureAssignmentsToActiveBrokersX(t *testing.T) { followerCount: 3, assignments: []*mq_pb.BrokerPartitionAssignment{ { - LeaderBroker: "localhost:1", - Partition: &mq_pb.Partition{}, + LeaderBroker: "localhost:1", + Partition: &mq_pb.Partition{}, FollowerBroker: "localhost:2", }, }, @@ -184,8 +184,8 @@ func TestEnsureAssignmentsToActiveBrokersX(t *testing.T) { followerCount: 3, assignments: []*mq_pb.BrokerPartitionAssignment{ { - LeaderBroker: "localhost:1", - Partition: &mq_pb.Partition{}, + LeaderBroker: "localhost:1", + Partition: &mq_pb.Partition{}, FollowerBroker: "localhost:2", }, }, |