fix rpo empty

Signed-off-by: iosmanthus <[email protected]>

common/region_info.go

@@ -66,6 +66,7 @@ type RegionState struct {
 }
 
 type Aggregator interface {
+	Get() *RegionInfos
 	Merge(b *RegionInfos)
 }
 
@@ -86,7 +87,6 @@ func NewRegionCollector() Collector {
 func (f *RegionCollector) Collect(ctx context.Context, fetchers []Fetcher, m Aggregator) (*RegionInfos, error) {
 	ch := make(chan Result, len(fetchers))
 
-	infos := NewRegionInfos()
 	for _, fetcher := range fetchers {
 		go func(fetcher Fetcher) {
 			ctx, cancel := context.WithTimeout(ctx, time.Minute*1)
@@ -109,5 +109,5 @@ func (f *RegionCollector) Collect(ctx context.Context, fetchers []Fetcher, m Agg
 		m.Merge(result.RegionInfos)
 	}
 
-	return infos, nil
+	return m.Get(), nil
 }

components/recover/resolver.go

@@ -19,6 +19,10 @@ func NewResolver() *Resolver {
 	}
 }
 
+func (r *Resolver) Get() *common.RegionInfos {
+	return nil
+}
+
 func (r *Resolver) Merge(b *common.RegionInfos) {
 	for _, state := range b.StateMap {
 		r.buffer = append(r.buffer, state)

components/rpo/rpo.go

@@ -86,6 +86,10 @@ func NewMaxApplyIndex() *MaxApplyIndex {
 	}
 }
 
+func (m *MaxApplyIndex) Get() *common.RegionInfos {
+	return m.inner
+}
+
 func (m *MaxApplyIndex) Merge(b *common.RegionInfos) {
 	inner := m.inner
 	for id, info := range b.StateMap {