Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 66 for lastUpdated (0.08 seconds)

  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
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 59.3K bytes
    - Click Count (0)
  2. cmd/batch-handlers.go

    	Version       int       `json:"-" msg:"v"`
    	JobID         string    `json:"jobID" msg:"jid"`
    	JobType       string    `json:"jobType" msg:"jt"`
    	StartTime     time.Time `json:"startTime" msg:"st"`
    	LastUpdate    time.Time `json:"lastUpdate" msg:"lu"`
    	RetryAttempts int       `json:"retryAttempts" msg:"ra"`
    	Attempts      int       `json:"attempts" msg:"at"`
    
    	Complete bool `json:"complete" msg:"cmp"`
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  3. 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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  4. cmd/metrics-v3-scanner.go

    	dui, err := c.dataUsageInfo.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		m.Set(scannerLastActivitySeconds, time.Since(dui.LastUpdate).Seconds())
    	}
    
    	return nil
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 19:29:25 GMT 2024
    - 2.8K bytes
    - Click Count (0)
  5. 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")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 85.5K bytes
    - Click Count (0)
  6. 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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  7. cmd/bucket-metadata-sys.go

    					wait() // wait to proceed to next entry.
    					continue
    				}
    
    				sys.Lock()
    				// Update if the bucket metadata in the memory is older than on-disk one
    				if lu := sys.metadataMap[bucket].lastUpdate(); lu.Before(meta.lastUpdate()) {
    					updated = true
    					sys.metadataMap[bucket] = meta
    				}
    				sys.Unlock()
    
    				if updated {
    					globalEventNotifier.set(bucket, meta)
    					globalBucketTargetSys.set(bucket, meta)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  8. 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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  9. 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():
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  10. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
Back to Top