Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for TargetReplicationResyncStatus (0.08 sec)

  1. cmd/bucket-replication-utils.go

    		return "Failed"
    	case ResyncPending:
    		return "Pending"
    	case ResyncCanceled:
    		return "Canceled"
    	default:
    		return ""
    	}
    }
    
    // TargetReplicationResyncStatus status of resync of bucket for a specific target
    type TargetReplicationResyncStatus struct {
    	StartTime  time.Time `json:"startTime" msg:"st"`
    	LastUpdate time.Time `json:"lastUpdated" msg:"lst"`
    	// Resync ID assigned to this reset
    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/site-replication-utils.go

    	BucketStatuses                map[string]ResyncStatusType `json:"buckets" msg:"bkts"`
    	TotBuckets                    int                         `json:"totbuckets" msg:"tb"`
    	TargetReplicationResyncStatus `json:"currSt" msg:"cst"`
    }
    
    func (s *SiteResyncStatus) clone() SiteResyncStatus {
    	if s == nil {
    		return SiteResyncStatus{}
    	}
    	o := *s
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils_gen.go

    				return
    			}
    			if z.TargetsMap == nil {
    				z.TargetsMap = make(map[string]TargetReplicationResyncStatus, zb0002)
    			} else if len(z.TargetsMap) > 0 {
    				for key := range z.TargetsMap {
    					delete(z.TargetsMap, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    				var za0002 TargetReplicationResyncStatus
    				za0001, err = dc.ReadString()
    				if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Apr 03 06:45:06 UTC 2025
    - 59.8K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    	defer cancel()
    	saveResyncStatus(ctx, opts.bucket, m, objAPI)
    }
    
    // update replication resync stats for bucket's remote target
    func (s *replicationResyncer) incStats(ts TargetReplicationResyncStatus, opts resyncOpts) {
    	s.Lock()
    	defer s.Unlock()
    	m := s.statusMap[opts.bucket]
    	st := m.TargetsMap[opts.arn]
    	st.Object = ts.Object
    	st.ReplicatedCount += ts.ReplicatedCount
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
Back to top