Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 61 for lastUpdate (0.08 sec)

  1. cmd/bucket-replication-utils_gen.go

    			}
    		case "id":
    			z.ID, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "ID")
    				return
    			}
    		case "lu":
    			z.LastUpdate, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "LastUpdate")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Apr 03 06:45:06 UTC 2025
    - 59.8K bytes
    - Viewed (0)
  2. cmd/data-usage-cache.go

    		return
    	}
    	if otherRoot == nil {
    		return
    	}
    	if existingRoot == nil {
    		*d = other.clone()
    		return
    	}
    	if other.Info.LastUpdate.After(d.Info.LastUpdate) {
    		d.Info.LastUpdate = other.Info.LastUpdate
    	}
    	existingRoot.merge(*otherRoot)
    	eHash := d.rootHash()
    	for key := range otherRoot.Children {
    		entry := other.Cache[key]
    		flat := other.flatten(entry)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  3. cmd/data-usage-cache_gen.go

    			}
    		case "NextCycle":
    			z.NextCycle, err = dc.ReadUint32()
    			if err != nil {
    				err = msgp.WrapError(err, "NextCycle")
    				return
    			}
    		case "LastUpdate":
    			z.LastUpdate, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "LastUpdate")
    				return
    			}
    		case "SkipHealing":
    			z.SkipHealing, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "SkipHealing")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 86.4K bytes
    - Viewed (0)
  4. cmd/bucket-metadata.go

    	LifecycleConfigUpdatedAt         time.Time
    	NotificationConfigUpdatedAt      time.Time
    	BucketTargetsConfigUpdatedAt     time.Time
    	BucketTargetsConfigMetaUpdatedAt time.Time
    	// Add a new UpdatedAt field and update lastUpdate function
    
    	// Unexported fields. Must be updated atomically.
    	policyConfig           *policy.BucketPolicy
    	notificationConfig     *event.Config
    	lifecycleConfig        *lifecycle.Lifecycle
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    func (f *folderScanner) sendUpdate() {
    	// Send at most an update every minute.
    	if f.updates == nil || time.Since(f.lastUpdate) < time.Minute {
    		return
    	}
    	if flat := f.updateCache.sizeRecursive(f.newCache.Info.Name); flat != nil {
    		select {
    		case f.updates <- flat.clone():
    		default:
    		}
    		f.lastUpdate = time.Now()
    	}
    }
    
    // scanFolder will scan the provided folder.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    			for _, info := range results {
    				if info.Info.LastUpdate.IsZero() {
    					// Not filled yet.
    					return
    				}
    				allMerged.merge(info)
    			}
    			if allMerged.root() != nil && allMerged.Info.LastUpdate.After(lastUpdate) {
    				updates <- allMerged.dui(allMerged.Info.Name, allBuckets)
    				lastUpdate = allMerged.Info.LastUpdate
    			}
    		}
    		for {
    			select {
    			case <-ctx.Done():
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  7. cmd/metrics.go

    		return
    	}
    
    	dataUsageInfo, err := loadDataUsageFromBackend(GlobalContext, objLayer)
    	if err != nil {
    		return
    	}
    	// data usage has not captured any data yet.
    	if dataUsageInfo.LastUpdate.IsZero() {
    		return
    	}
    
    	for bucket, usageInfo := range dataUsageInfo.BucketsUsage {
    		stat := globalReplicationStats.Load().getLatestReplicationStats(bucket)
    		// Total space used by bucket
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    				for _, st := range brs.TargetsMap {
    					if st.LastUpdate.Equal(timeSentinel) {
    						updt = true
    						break
    					}
    				}
    				// Save the replication status if a new stats update is found and not saved in the backend yet
    				if brs.LastUpdate.After(lastResyncStatusSave[bucket]) {
    					updt = true
    				}
    				if updt {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  9. cmd/bucket-replication-handlers.go

    			continue
    		}
    		rinfo.Targets = append(rinfo.Targets, ResyncTarget{
    			Arn:             tarn,
    			ResetID:         st.ResyncID,
    			StartTime:       st.StartTime,
    			EndTime:         st.LastUpdate,
    			ResyncStatus:    st.ResyncStatus.String(),
    			ReplicatedSize:  st.ReplicatedSize,
    			ReplicatedCount: st.ReplicatedCount,
    			FailedSize:      st.FailedSize,
    			FailedCount:     st.FailedCount,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    			metricsLogIf(ctx, err)
    			return
    		}
    
    		// data usage has not captured any data yet.
    		if dataUsageInfo.LastUpdate.IsZero() {
    			return
    		}
    
    		metrics = append(metrics, MetricV2{
    			Description: getUsageLastScanActivityMD(),
    			Value:       float64(time.Since(dataUsageInfo.LastUpdate)),
    		})
    
    		var (
    			clusterSize               uint64
    			clusterBuckets            uint64
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
Back to top