if (Constants.CRAWLER_STATUS.equals(key)) {
                    statusMap.put(key, value);
                }
            }

            @Override
            public Map<String, String> getInfoMap(String sessionId) {
                Map<String, String> result = new HashMap<>(infoMap);
                result.putAll(statusMap);
                return result;
            }
        };

type VersionPurgeStatusType = replication.VersionPurgeStatusType

type replicationResyncer struct {
	// map of bucket to their resync status
	statusMap      map[string]BucketReplicationResyncStatus
	workerSize     int
	resyncCancelCh chan struct{}
	workerCh       chan struct{}
	sync.RWMutex
}

const (
	replicationDir      = ".replication"

	s.Lock()
	defer s.Unlock()

	m := s.statusMap[opts.bucket]
	st := m.TargetsMap[opts.arn]
	st.LastUpdate = UTCNow()
	st.ResyncStatus = status
	m.TargetsMap[opts.arn] = st
	m.LastUpdate = UTCNow()
	s.statusMap[opts.bucket] = m

	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
	defer cancel()

			m, ok := globalReplicationPool.Get().resyncer.statusMap[bucket]
			if !ok {
				m = newBucketResyncStatus(bucket)
			}
			if st, ok := m.TargetsMap[t.Arn]; ok {
				st.LastUpdate = UTCNow()
				st.ResyncStatus = ResyncCanceled
				m.TargetsMap[t.Arn] = st
				m.LastUpdate = UTCNow()
			}
			globalReplicationPool.Get().resyncer.statusMap[bucket] = m
			globalReplicationPool.Get().resyncer.Unlock()