Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for Merge (0.12 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/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)
  3. cmd/metacache-entries.go

    		if err := selectFrom(bestIdx); err != nil {
    			return err
    		}
    	}
    }
    
    // merge will merge other into m.
    // If the same entries exists in both and metadata matches only one is added,
    // otherwise the entry from m will be placed first.
    // Operation time is expected to be O(n+m).
    func (m *metaCacheEntriesSorted) merge(other metaCacheEntriesSorted, limit int) {
    	merged := make(metaCacheEntries, 0, m.len()+other.len())
    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)
  4. clause/from.go

    			builder.WriteQuoted(table)
    		}
    	} else {
    		builder.WriteQuoted(currentTable)
    	}
    
    	for _, join := range from.Joins {
    		builder.WriteByte(' ')
    		join.Build(builder)
    	}
    }
    
    // MergeClause merge from clause
    func (from From) MergeClause(clause *Clause) {
    	clause.Expression = from
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Wed Jul 15 02:25:10 GMT 2020
    - 630 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. cmd/tier-last-day-stats.go

    	return merged
    }
    
    // DailyAllTierStats is used to aggregate last day tier stats across MinIO servers
    type DailyAllTierStats map[string]lastDayTierStats
    
    func (l DailyAllTierStats) merge(m DailyAllTierStats) {
    	for tier, st := range m {
    		l[tier] = l[tier].merge(st)
    	}
    }
    
    func (l DailyAllTierStats) addToTierInfo(tierInfos []madmin.TierInfo) []madmin.TierInfo {
    	for i := range tierInfos {
    		lst, ok := l[tierInfos[i].Name]
    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)
  9. 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)
  10. clause/insert.go

    		builder.WriteByte(' ')
    	}
    
    	builder.WriteString("INTO ")
    	if insert.Table.Name == "" {
    		builder.WriteQuoted(currentTable)
    	} else {
    		builder.WriteQuoted(insert.Table)
    	}
    }
    
    // MergeClause merge insert clause
    func (insert Insert) MergeClause(clause *Clause) {
    	if v, ok := clause.Expression.(Insert); ok {
    		if insert.Modifier == "" {
    			insert.Modifier = v.Modifier
    		}
    		if insert.Table.Name == "" {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Mar 09 09:07:00 GMT 2020
    - 767 bytes
    - Viewed (0)
Back to top