diff options
| author | chrislu <chris.lu@gmail.com> | 2023-08-27 18:59:04 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-08-27 18:59:04 -0700 |
| commit | dbcba75271a4617b5931c4779ca0f7c924369a8f (patch) | |
| tree | c80b6297bc371e6bd30223d87c39444bec82aeab /weed/mq/topic/local_partition.go | |
| parent | c9caf3311995290c36ed369b48fbbab23d6bc7b5 (diff) | |
| download | seaweedfs-dbcba75271a4617b5931c4779ca0f7c924369a8f.tar.xz seaweedfs-dbcba75271a4617b5931c4779ca0f7c924369a8f.zip | |
rename to lookup
Diffstat (limited to 'weed/mq/topic/local_partition.go')
| -rw-r--r-- | weed/mq/topic/local_partition.go | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go index 6dbaaea39..a87922d9c 100644 --- a/weed/mq/topic/local_partition.go +++ b/weed/mq/topic/local_partition.go @@ -27,15 +27,11 @@ func (p LocalPartition) Subscribe(clientName string, startReadTime time.Time, ea }, eachMessageFn) } -func FromPbBrokerPartitionsAssignment(self pb.ServerAddress, assignment *mq_pb.BrokerPartitionsAssignment) *LocalPartition { +func FromPbBrokerPartitionAssignment(self pb.ServerAddress, assignment *mq_pb.BrokerPartitionAssignment) *LocalPartition { isLeaer := assignment.LeaderBroker == string(self) localPartition := &LocalPartition{ - Partition: Partition{ - RangeStart: assignment.PartitionStart, - RangeStop: assignment.PartitionStop, - RingSize: PartitionCount, - }, - isLeader: isLeaer, + Partition: FromPbPartition(assignment.Partition), + isLeader: isLeaer, } if !isLeaer { return localPartition |