- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for merge (0.14 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) -
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) -
internal/logger/config.go
Enabled: true, Endpoint: url, } } } return cfg } func lookupAuditKafkaConfig(scfg config.Config, cfg Config) (Config, error) { for k, kv := range config.Merge(scfg[config.AuditKafkaSubSys], EnvKafkaEnable, DefaultAuditKafkaKVS) { enabledCfgVal := getCfgVal(EnvKafkaEnable, k, kv.Get(config.Enable)) enabled, err := config.ParseBool(enabledCfgVal) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.8K bytes - Viewed (0) -
internal/hash/reader_test.go
"88d4266fd4e6338d13b845fcf289579d209c897823b9217da3e161936f031580", "88d4266fd4e6338d13b845fcf289579d209c897823b9217da3e161936f031589", }, }, { desc: "Nested hash reader NewReader() should merge.", src: mustReader(t, bytes.NewReader([]byte("abcd")), 4, "", "", 4), size: 4, actualSize: 4, }, { desc: "Incorrect sha256, nested",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.3K bytes - Viewed (0) -
cmd/metacache-server-pool.go
var errs []error allAtEOF := true var inputs []chan metaCacheEntry mu.Lock() // Ask all sets and merge entries. listCtx, cancelList := context.WithCancel(ctx) defer cancelList() for _, pool := range z.serverPools { for _, set := range pool.sets { wg.Add(1) innerResults := make(chan metaCacheEntry, 100) inputs = append(inputs, innerResults) go func(i int, set *erasureObjects) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/bucket-stats.go
Totals [60]AccElem LastMin int64 } // Merge data of two ReplicationLastHour structure func (l ReplicationLastHour) merge(o ReplicationLastHour) (merged ReplicationLastHour) { if l.LastMin > o.LastMin { o.forwardTo(l.LastMin) merged.LastMin = l.LastMin } else { l.forwardTo(o.LastMin) merged.LastMin = o.LastMin } for i := range merged.Totals { merged.Totals[i] = AccElem{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
cmd/data-usage-cache.go
} for k, v := range d.Cache { clone.Cache[k] = v.clone() } return clone } // merge root of other into d. // children of root will be flattened before being merged. // Last update time will be set to the last updated. func (d *dataUsageCache) merge(other dataUsageCache) { existingRoot := d.root() otherRoot := other.root() if existingRoot == nil && otherRoot == nil { return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
cmd/metrics.go
} server := getLocalServerProperty(globalEndpoints, &http.Request{ Host: globalLocalNodeName, }, true) onlineDisks, offlineDisks := getOnlineOfflineDisksStats(server.Disks) totalDisks := offlineDisks.Merge(onlineDisks) // Report total capacity ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(minioNamespace, "capacity_raw", "total"), "Total capacity online in the cluster",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
internal/grid/connection.go
if err != nil { gridLogIf(ctx, fmt.Errorf("ws write: %w", err)) return } continue } // Merge entries and send queue = append(queue, toSend) if debugPrint { fmt.Println("Merging", len(queue), "messages") } toSend = merged[:0] m := message{Op: OpMerged, Seq: uint32(len(queue))} var err error toSend, err = m.MarshalMsg(toSend) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0)