- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for merge (0.65 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)