go p.startResyncRoutine(ctx, buckets, objAPI)
	return nil
}

func (p *ReplicationPool) startResyncRoutine(ctx context.Context, buckets []string, objAPI ObjectLayer) {
	r := rand.New(rand.NewSource(time.Now().UnixNano()))
	// Run the replication resync in a loop
	for {
		if err := p.loadResync(ctx, buckets, objAPI); err == nil {
			<-ctx.Done()
			return
		}

}

// Init - initialize the site replication manager.
func (c *SiteReplicationSys) Init(ctx context.Context, objAPI ObjectLayer) error {
	go c.startHealRoutine(ctx, objAPI)
	r := rand.New(rand.NewSource(time.Now().UnixNano()))
	for {
		err := c.loadFromDisk(ctx, objAPI)
		if err == errConfigNotFound {
			return nil
		}
		if err == nil {
			break
		}

pkg time, method (Time) String() string
pkg time, method (Time) Sub(Time) Duration
pkg time, method (Time) UTC() Time
pkg time, method (Time) Unix() int64
pkg time, method (Time) UnixNano() int64
pkg time, method (Time) Weekday() Weekday
pkg time, method (Time) Year() int
pkg time, method (Time) Zone() (string, int)
pkg time, method (Weekday) String() string
pkg time, type Duration int64