Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Merged (0.15 sec)

  1. cmd/tier-last-day-stats.go

    	return clone
    }
    
    func (l lastDayTierStats) merge(m lastDayTierStats) (merged lastDayTierStats) {
    	cl := l.clone()
    	cm := m.clone()
    
    	if cl.UpdatedAt.After(cm.UpdatedAt) {
    		cm.forwardTo(cl.UpdatedAt)
    		merged.UpdatedAt = cl.UpdatedAt
    	} else {
    		cl.forwardTo(cm.UpdatedAt)
    		merged.UpdatedAt = cm.UpdatedAt
    	}
    
    	for i := range cl.Bins {
    		merged.Bins[i] = cl.Bins[i].add(cm.Bins[i])
    	}
    
    	return merged
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. docs/hotfixes.md

        prefixes instead of exact match.
    ```
    
    - There is always a possibility of a fix that is new, it is advised that the developer must make sure that the fix is sent upstream, reviewed and merged to the master branch.
    
    ## Creating a hotfix branch
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 14 21:36:02 GMT 2024
    - 5K bytes
    - Viewed (0)
  3. cmd/erasure-common.go

    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			return disks[index].ReadMultiple(ctx, req, resps[index])
    		}, index)
    	}
    
    	dataArray := make([]ReadMultipleResp, 0, len(req.Files))
    	// Merge results. They should come in order from each.
    	for _, wantFile := range req.Files {
    		quorum := 0
    		toAdd := ReadMultipleResp{
    			Bucket: req.Bucket,
    			Prefix: req.Prefix,
    			File:   wantFile,
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  4. cmd/site-replication-metrics.go

    	}
    }
    
    func (rt *RTimedMetrics) merge(o RTimedMetrics) (n RTimedMetrics) {
    	n.SinceUptime.Bytes = atomic.LoadInt64(&rt.SinceUptime.Bytes) + atomic.LoadInt64(&o.SinceUptime.Bytes)
    	n.SinceUptime.Count = atomic.LoadInt64(&rt.SinceUptime.Count) + atomic.LoadInt64(&o.SinceUptime.Count)
    
    	n.LastMinute = n.LastMinute.merge(rt.LastMinute)
    	n.LastMinute = n.LastMinute.merge(o.LastMinute)
    	n.LastHour = n.LastHour.merge(rt.LastHour)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  5. cmd/metrics-v3-system-drive.go

    		allDriveLabels...)
    	driveReadsKBPerSecMD = NewGaugeMD(driveReadsKBPerSec,
    		"Kilobytes read per second on a drive",
    		allDriveLabels...)
    	driveReadsAwaitMD = NewGaugeMD(driveReadsAwait,
    		"Average time for read requests served on a drive",
    		allDriveLabels...)
    	driveWritesPerSecMD = NewGaugeMD(driveWritesPerSec,
    		"Writes per second on a drive",
    		allDriveLabels...)
    	driveWritesKBPerSecMD = NewGaugeMD(driveWritesKBPerSec,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  6. internal/kms/config.go

    	EnvKESKeyCacheInterval = "MINIO_KMS_KEY_CACHE_INTERVAL" // Period between polls of the KES KMS Master Key cache, to prevent it from being unused and purged
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 07:42:50 GMT 2024
    - 2K bytes
    - Viewed (0)
  7. internal/config/lambda/parse.go

    func GetLambdaWebhook(webhookKVS map[string]config.KVS, transport *http.Transport) (
    	map[string]target.WebhookArgs, error,
    ) {
    	webhookTargets := make(map[string]target.WebhookArgs)
    	for k, kv := range config.Merge(webhookKVS, target.EnvWebhookEnable, DefaultWebhookKVS) {
    		enableEnv := target.EnvWebhookEnable
    		if k != config.Default {
    			enableEnv = enableEnv + config.Default + k
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  8. internal/pubsub/pubsub.go

    	combined := Mask(atomic.LoadUint64(&ps.types))
    	combined.Merge(Mask(mask.Mask()))
    	atomic.StoreUint64(&ps.types, uint64(combined))
    
    	go func() {
    		<-doneCh
    
    		ps.Lock()
    		defer ps.Unlock()
    		var remainTypes Mask
    		for i, s := range ps.subs {
    			if s == sub {
    				ps.subs = append(ps.subs[:i], ps.subs[i+1:]...)
    			} else {
    				remainTypes.Merge(s.types)
    			}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  9. internal/grid/grid.go

    	// This is the assumed size of bigger buffers and allocation size.
    	biggerBufMin = 32 << 10
    
    	// This is the maximum size of bigger buffers.
    	biggerBufMax = maxBufferSize
    
    	// If there is a queue, merge up to this many messages.
    	maxMergeMessages = 30
    
    	// clientPingInterval will ping the remote handler every 15 seconds.
    	// Clients disconnect when we exceed 2 intervals.
    	clientPingInterval = 15 * time.Second
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 15:56:18 GMT 2024
    - 4.8K bytes
    - Viewed (0)
Back to top