Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 26 for LastUpdate (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 59.3K bytes
    - Click Count (0)
  2. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.2K bytes
    - Click Count (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")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 85.5K bytes
    - Click Count (0)
  4. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  5. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.4K bytes
    - Click Count (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():
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  7. cmd/metrics-v3-cluster-usage.go

    	if err != nil {
    		metricsLogIf(ctx, err)
    		return nil
    	}
    
    	// data usage has not been captured yet.
    	if dataUsageInfo.LastUpdate.IsZero() {
    		return nil
    	}
    
    	m.Set(usageSinceLastUpdateSeconds, float64(time.Since(dataUsageInfo.LastUpdate)))
    
    	for bucket, usage := range dataUsageInfo.BucketsUsage {
    		quota, err := globalBucketQuotaSys.Get(ctx, bucket)
    		if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  8. cmd/metacache_gen.go

    				return
    			}
    		case "lh":
    			z.lastHandout, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "lastHandout")
    				return
    			}
    		case "u":
    			z.lastUpdate, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "lastUpdate")
    				return
    			}
    		case "b":
    			z.bucket, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "bucket")
    				return
    			}
    		case "flt":
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10K bytes
    - Click Count (0)
  9. cmd/batch-handlers_gen.go

    			}
    		case "st":
    			z.StartTime, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "StartTime")
    				return
    			}
    		case "lu":
    			z.LastUpdate, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "LastUpdate")
    				return
    			}
    		case "ra":
    			z.RetryAttempts, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "RetryAttempts")
    				return
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  10. cmd/metacache-manager.go

    				exit = true
    			}
    			m.mu.RLock()
    			for _, v := range m.buckets {
    				if !exit {
    					v.cleanup()
    				}
    			}
    			m.mu.RUnlock()
    			m.mu.Lock()
    			for k, v := range m.trash {
    				if time.Since(v.lastUpdate) > metacacheMaxRunningAge {
    					v.delete(context.Background())
    					delete(m.trash, k)
    				}
    			}
    			m.mu.Unlock()
    		}
    	}()
    }
    
    // updateCacheEntry will update non-transient state.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 5.2K bytes
    - Click Count (0)
Back to Top