Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newBucketResyncStatus (0.23 sec)

  1. cmd/bucket-replication-utils.go

    func (rs *BucketReplicationResyncStatus) cloneTgtStats() (m map[string]TargetReplicationResyncStatus) {
    	m = make(map[string]TargetReplicationResyncStatus)
    	maps.Copy(m, rs.TargetsMap)
    	return
    }
    
    func newBucketResyncStatus(bucket string) BucketReplicationResyncStatus {
    	return BucketReplicationResyncStatus{
    		TargetsMap: make(map[string]TargetReplicationResyncStatus),
    		Version:    resyncMetaVersion,
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    	}
    	return nil
    }
    
    // load bucket resync metadata from disk
    func loadBucketResyncMetadata(ctx context.Context, bucket string, objAPI ObjectLayer) (brs BucketReplicationResyncStatus, e error) {
    	brs = newBucketResyncStatus(bucket)
    	resyncDirPath := path.Join(bucketMetaPrefix, bucket, replicationDir)
    	data, err := readConfig(GlobalContext, objAPI, pathJoin(resyncDirPath, resyncFileName))
    	if err != nil && err != errConfigNotFound {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    				continue
    			}
    			// update resync state for the bucket
    			globalReplicationPool.Get().resyncer.Lock()
    			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()
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
Back to top