Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newBucketResyncStatus (0.07 sec)

  1. 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)
  2. 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 (1)
Back to top