- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 49 for Merge (0.13 sec)
-
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 May 05 09:35:13 GMT 2024 - Last Modified: Fri Oct 07 05:46:20 GMT 2022 - 1.3K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
return nil, err } if isRevisioned(revision) && meshConfig.DefaultConfig.DiscoveryAddress == "" { meshConfig.DefaultConfig.DiscoveryAddress = IstiodAddr(istioNamespace, revision) } // performing separate map-merge, apply seems to completely overwrite all metadata proxyMetadata := meshConfig.DefaultConfig.ProxyMetadata // support proxy.istio.io/config on the WorkloadGroup, in the WorkloadGroup spec
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K 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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 46.4K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
// InQueueMetric holds queue stats for replication type InQueueMetric struct { Curr QStat `json:"curr" msg:"cq"` Avg QStat `json:"avg" msg:"aq"` Max QStat `json:"max" msg:"pq"` } func (qm InQueueMetric) merge(o InQueueMetric) InQueueMetric { return InQueueMetric{ Curr: qm.Curr.add(o.Curr), Avg: qm.Avg.add(o.Avg), Max: qm.Max.add(o.Max), } } type queueCache struct { srQueueStats InQueueStats
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
clause/where.go
} if wrapInParentheses { builder.WriteByte('(') expr.Build(builder) builder.WriteByte(')') wrapInParentheses = false } else { expr.Build(builder) } } } // MergeClause merge where clauses func (where Where) MergeClause(clause *Clause) { if w, ok := clause.Expression.(Where); ok { exprs := make([]Expression, len(w.Exprs)+len(where.Exprs)) copy(exprs, w.Exprs)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Apr 25 12:22:53 GMT 2024 - 5.1K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
if objLayer == nil { return } storageInfo := objLayer.LocalStorageInfo(GlobalContext, true) onlineDrives, offlineDrives := getOnlineOfflineDisksStats(storageInfo.Disks) totalDrives := onlineDrives.Merge(offlineDrives) v = storageMetrics{ storageInfo: storageInfo, onlineDrives: onlineDrives.Sum(), offlineDrives: offlineDrives.Sum(), totalDrives: totalDrives.Sum(),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 7.9K bytes - Viewed (0) -
internal/grid/grid.go
// This is the assumed size of bigger buffers and allocation size. biggerBufMin = 32 << 10 // This is the maximum size of bigger buffers. biggerBufMax = maxBufferSize // If there is a queue, merge up to this many messages. maxMergeMessages = 30 // clientPingInterval will ping the remote handler every 15 seconds. // Clients disconnect when we exceed 2 intervals. clientPingInterval = 15 * time.Second
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
internal/config/lambda/parse.go
func GetLambdaWebhook(webhookKVS map[string]config.KVS, transport *http.Transport) ( map[string]target.WebhookArgs, error, ) { webhookTargets := make(map[string]target.WebhookArgs) for k, kv := range config.Merge(webhookKVS, target.EnvWebhookEnable, DefaultWebhookKVS) { enableEnv := target.EnvWebhookEnable if k != config.Default { enableEnv = enableEnv + config.Default + k }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/iam-store.go
cache.iamUserGroupMemberships = newCache.iamUserGroupMemberships cache.iamUserPolicyMap = newCache.iamUserPolicyMap cache.iamUsersMap = newCache.iamUsersMap // For STS policy map, we need to merge the new cache with the existing // cache because the periodic IAM reload is partial. The periodic load // here is to account for STS policy mapping changes that should apply
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
operator/cmd/mesh/manifest-generate_test.go
}, }, // TODO https://github.com/istio/istio/issues/22347 this is broken for overriding things to default value // This can be seen from REGISTRY_ONLY not applying { desc: "pilot_merge_meshconfig", diffSelect: "ConfigMap:*:istio$", fileSelect: []string{"templates/configmap.yaml", "templates/_helpers.tpl"}, }, { desc: "pilot_disable_tracing", diffSelect: "ConfigMap:*:istio$",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0)