Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for merge (0.65 sec)

  1. cmd/bucket-replication-stats.go

    			tq = tq.merge(q.QStats)
    		}
    
    		for arn, stat := range bucketStat.ReplicationStats.Stats {
    			oldst := stats[arn]
    			if oldst == nil {
    				oldst = &BucketReplicationStat{
    					XferRateLrg: newXferStats(),
    					XferRateSml: newXferStats(),
    				}
    			}
    			fstats := stat.FailStats.merge(oldst.FailStats)
    			lrg := oldst.XferRateLrg.merge(*stat.XferRateLrg)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.4K bytes
    - Viewed (0)
  2. cmd/metacache-entries.go

    			// Same, discard one.
    			merged = append(merged, a[0])
    			a = a[1:]
    			b = b[1:]
    		case a[0].name < b[0].name:
    			merged = append(merged, a[0])
    			a = a[1:]
    		default:
    			merged = append(merged, b[0])
    			b = b[1:]
    		}
    		if limit > 0 && len(merged) >= limit {
    			break
    		}
    	}
    	// Append anything left.
    	if limit < 0 || len(merged) < limit {
    		merged = append(merged, a...)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. clause/locking.go

    		builder.WriteString(" OF ")
    		builder.WriteQuoted(locking.Table)
    	}
    
    	if locking.Options != "" {
    		builder.WriteByte(' ')
    		builder.WriteString(locking.Options)
    	}
    }
    
    // MergeClause merge order by clauses
    func (locking Locking) MergeClause(clause *Clause) {
    	clause.Expression = locking
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Fri Dec 15 08:32:56 GMT 2023
    - 773 bytes
    - Viewed (0)
  6. cmd/metrics-realtime.go

    		m.ByDisk = make(map[string]madmin.DiskMetric)
    		aggr := madmin.DiskMetric{
    			CollectedAt: time.Now(),
    		}
    		for name, disk := range collectLocalDisksMetrics(opts.disks) {
    			m.ByDisk[name] = disk
    			aggr.Merge(&disk)
    		}
    		m.Aggregated.Disk = &aggr
    	}
    
    	if types.Contains(madmin.MetricsScanner) {
    		metrics := globalScannerMetrics.report()
    		m.Aggregated.Scanner = &metrics
    	}
    	if types.Contains(madmin.MetricsOS) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 10 16:28:08 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  7. clause/set.go

    			builder.AddVar(builder, assignment.Value)
    		}
    	} else {
    		builder.WriteQuoted(Column{Name: PrimaryKey})
    		builder.WriteByte('=')
    		builder.WriteQuoted(Column{Name: PrimaryKey})
    	}
    }
    
    // MergeClause merge assignments clauses
    func (set Set) MergeClause(clause *Clause) {
    	copiedAssignments := make([]Assignment, len(set))
    	copy(copiedAssignments, set)
    	clause.Expression = Set(copiedAssignments)
    }
    
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Nov 29 03:02:44 GMT 2021
    - 1.4K bytes
    - Viewed (0)
  8. clause/returning.go

    		for idx, column := range returning.Columns {
    			if idx > 0 {
    				builder.WriteByte(',')
    			}
    
    			builder.WriteQuoted(column)
    		}
    	} else {
    		builder.WriteByte('*')
    	}
    }
    
    // MergeClause merge order by clauses
    func (returning Returning) MergeClause(clause *Clause) {
    	if v, ok := clause.Expression.(Returning); ok {
    		returning.Columns = append(v.Columns, returning.Columns...)
    	}
    
    	clause.Expression = returning
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Wed Oct 27 23:56:55 GMT 2021
    - 681 bytes
    - Viewed (0)
  9. clause/limit.go

    	}
    	if limit.Offset > 0 {
    		if limit.Limit != nil && *limit.Limit >= 0 {
    			builder.WriteByte(' ')
    		}
    		builder.WriteString("OFFSET ")
    		builder.AddVar(builder, limit.Offset)
    	}
    }
    
    // MergeClause merge order by clauses
    func (limit Limit) MergeClause(clause *Clause) {
    	clause.Name = ""
    
    	if v, ok := clause.Expression.(Limit); ok {
    		if (limit.Limit == nil || *limit.Limit == 0) && v.Limit != nil {
    			limit.Limit = v.Limit
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Tue Feb 06 02:54:40 GMT 2024
    - 942 bytes
    - Viewed (0)
  10. internal/hash/reader.go

    //
    // If size resp. actualSize is unknown at the time of calling
    // NewReader then it should be set to -1.
    // When size is >=0 it *must* match the amount of data provided by r.
    //
    // NewReader may try merge the given size, MD5 and SHA256 values
    // into src - if src is a Reader - to avoid computing the same
    // checksums multiple times.
    // NewReader enforces S3 compatibility strictly by ensuring caller
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.8K bytes
    - Viewed (0)
Back to top