- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for It (0.02 sec)
-
pilot/pkg/xds/deltatest.go
wantUnchanged := sets.New[string]() for _, c := range current { n := newByName[c.Name] if n == nil { // We had a resource, but SotW didn't generate it. if watched.Contains(c.Name) { // We only need to delete it if Envoy is watching. Otherwise, it may have simply unsubscribed wantDeleted.Insert(c.Name) } } else if diff := cmp.Diff(c.Resource, n.Resource, protocmp.Transform()); diff != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
// Each log is 2x: one direct, and one over UDS. Just test the UDS one continue } // remove scope since it is constant and not needed to test delete(parsedLog, "scope") // check time is there if _, f := parsedLog["time"]; !f { t.Fatalf("log %v did not have time", i) } // but remove time since it changes on each test delete(parsedLog, "time") want := map[string]any{ "level": cases[i].level,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/envoy/proxy.go
// At high QPS (>250 QPS) we will log the same amount as we will log due to exceeding buffer size, rather // than the flush interval. "--file-flush-interval-msec", "1000", "--disable-hot-restart", // We don't use it, so disable it to simplify Envoy's logic "--allow-unknown-static-fields", } startupArgs = append(startupArgs, e.extraArgs...) if overrideFname != "" { s, err := readBootstrapToJSON(overrideFname)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 6.9K bytes - Viewed (0) -
cni/cmd/istio-cni/main.go
// Log sync will send logs to install-cni container via UDS. // We don't need a timeout here because underlying the log pkg already handles it. // this may fail, but it should be safe to ignore according // to https://github.com/uber-go/zap/issues/328 _ = log.Sync() }() // TODO: implement plugin version funcs := skel.CNIFuncs{ Add: plugin.CmdAdd, Del: plugin.CmdDelete, Check: plugin.CmdCheck, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 2K bytes - Viewed (0) -
common/scripts/setup_env.sh
fi # echo ${CONDITIONAL_HOST_MOUNTS} # This function checks if the file exists. If it does, it creates a randomly named host location # for the file, adds it to the host KUBECONFIG, and creates a mount for it. Note that we use a copy # of the original file, so that the container can write to it. add_KUBECONFIG_if_exists () { if [[ -f "$1" ]]; then local local_config local_config="$(mktemp)"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 14:37:27 UTC 2024 - 8.3K bytes - Viewed (0) -
pilot/pkg/model/destination_rule.go
// If the incoming rule has a workload selector, it has to be merged with the existing rules with workload selector, and // at the same time added as a unique entry in the processedDestRules. if bothWithoutSelector || (rule.GetWorkloadSelector() != nil && selectorsMatch) { addRuleToProcessedDestRules = false } // Deep copy destination rule, to prevent mutate it later when merge with a new one.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 07:22:29 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/features/telemetry.go
"If true, pilot will add metadata exchange filters, which will be consumed by telemetry filter.", ).Get() // This is an experimental feature flag, can be removed once it became stable, and should introduced to Telemetry API. MetricRotationInterval = env.Register("METRIC_ROTATION_INTERVAL", 0*time.Second, "Metric scope rotation interval, set to 0 to disable the metric scope rotation").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:36:01 UTC 2024 - 2.3K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
log.Debugf("netns: %s", addCmd.Netns) // The CNI node plugin should have already checked the pod against the k8s API before forwarding us the event, // but we have to invoke the K8S client anyway, so to be safe we check it again here to make sure we get the same result. ambientPod, err := s.getPodWithRetry(log, addCmd.PodName, addCmd.PodNamespace) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/test/framework/components/cluster/clusters.go
// Cluster in the list. func (c Clusters) GetOrDefault(cluster Cluster) Cluster { if cluster != nil { return cluster } return c.Default() } // GetByName returns the Cluster with the given name or nil if it is not in the list. func (c Clusters) GetByName(name string) Cluster { for _, cc := range c { if cc.Name() == name { return cc } } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 4.7K bytes - Viewed (0) -
manifests/addons/dashboards/lib/lib-grid.libsonnet
||| `makeGrid` returns an array of `panels` organized in a grid with equal width and `panelHeight`. Row panels are used as "linebreaks", if a Row panel is collapsed, then all panels below it will be folded into the row. Optional `startY` can be provided to place generated grid above or below existing panels. |||, args=[ d.arg('panels', d.T.array), d.arg('panelHeight', d.T.number),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 18:05:06 UTC 2024 - 2.3K bytes - Viewed (0)