- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 56 for merge (0.16 sec)
-
cmd/last-minute.go
type LastMinuteHistogram [sizeLastElemMarker]lastMinuteLatency // Merge safely merges two LastMinuteHistogram structures into one func (l LastMinuteHistogram) Merge(o LastMinuteHistogram) (merged LastMinuteHistogram) { for i := range l { merged[i] = l[i].merge(o[i]) } return merged } // Add latency t from object with the specified size.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jul 05 17:40:45 GMT 2023 - 4.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 Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
internal/pubsub/mask.go
return bits.OnesCount64(uint64(t)) == 1 } // FromUint64 will set a mask to the uint64 value. func (t *Mask) FromUint64(m uint64) { *t = Mask(m) } // Merge will merge other into t. func (t *Mask) Merge(other Mask) { *t |= other } // MergeMaskable will merge other into t. func (t *Mask) MergeMaskable(other Maskable) { *t |= Mask(other.Mask()) } // SetIf will add other if b is true.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jul 05 21:45:49 GMT 2022 - 1.3K bytes - Viewed (0) -
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 Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K 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 Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
clause/update.go
builder.WriteString(update.Modifier) builder.WriteByte(' ') } if update.Table.Name == "" { builder.WriteQuoted(currentTable) } else { builder.WriteQuoted(update.Table) } } // MergeClause merge update clause func (update Update) MergeClause(clause *Clause) { if v, ok := clause.Expression.(Update); ok { if update.Modifier == "" { update.Modifier = v.Modifier } if update.Table.Name == "" {
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Mon Mar 09 09:07:00 GMT 2020 - 737 bytes - Viewed (0) -
clause/values.go
builder.WriteByte(',') } builder.WriteByte('(') builder.AddVar(builder, value...) builder.WriteByte(')') } } else { builder.WriteString("DEFAULT VALUES") } } // MergeClause merge values clauses func (values Values) MergeClause(clause *Clause) { clause.Name = "" clause.Expression = values
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Sun May 24 03:35:19 GMT 2020 - 849 bytes - Viewed (0) -
clause/group_by.go
builder.WriteByte(',') } builder.WriteQuoted(column) } if len(groupBy.Having) > 0 { builder.WriteString(" HAVING ") Where{Exprs: groupBy.Having}.Build(builder) } } // MergeClause merge group by clause func (groupBy GroupBy) MergeClause(clause *Clause) { if v, ok := clause.Expression.(GroupBy); ok { copiedColumns := make([]Column, len(v.Columns)) copy(copiedColumns, v.Columns)
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Tue Mar 30 10:28:09 GMT 2021 - 1K bytes - Viewed (0) -
clause/on_conflict.go
onConflict.DoUpdates.Build(builder) } if len(onConflict.Where.Exprs) > 0 { builder.WriteString(" WHERE ") onConflict.Where.Build(builder) builder.WriteByte(' ') } } // MergeClause merge onConflict clauses func (onConflict OnConflict) MergeClause(clause *Clause) { clause.Expression = onConflict
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Fri Oct 07 05:46:20 GMT 2022 - 1.3K bytes - Viewed (0) -
internal/config/notify/parse.go
func GetNotifyKafka(kafkaKVS map[string]config.KVS) (map[string]target.KafkaArgs, error) { kafkaTargets := make(map[string]target.KafkaArgs) for k, kv := range config.Merge(kafkaKVS, target.EnvKafkaEnable, DefaultKafkaKVS) { enableEnv := target.EnvKafkaEnable if k != config.Default { enableEnv = enableEnv + config.Default + k }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 46.4K bytes - Viewed (0)