- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 96 for from (0.15 sec)
-
istioctl/pkg/wait/wait.go
w = getAndWatchResource(ctx, cliCtx) // setup version getter from kubernetes } else { w = withContext(ctx) w.Go(func(result chan string) error { result <- generation return nil }) } // wait for all deployed versions to be contained in generations t := time.NewTicker(pollInterval) printVerbosef(cmd, "getting first version from chan") firstVersion, err := w.BlockingRead() if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
} if revision != "" && revision != "default" { flags = append(flags, fmt.Sprintf("revision=%s", revision)) } return flags } // getCRAndNamespaceFromFile returns the CR name and istio namespace from a file containing an IstioOperator CR. func getCRAndNamespaceFromFile(filePath string, l clog.Logger) (customResource string, istioNamespace string, err error) { if filePath == "" { return "", "", nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 5.1K bytes - Viewed (0) -
cni/pkg/nodeagent/healthServer_test.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
error rate, and request latency at p50, p90, and p99 percentiles. The query results are printed to the console, organized by workload name. All metrics returned are from server-side reports. This means that latencies and error rates are from the perspective of the service itself and not of an individual client (or aggregate set of clients). Rates and latencies are calculated over a time interval of 1 minute. `,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 8.4K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
sa.AddRunningKubeSourceWithRevision(k, revisionSpecified, c.remote) } } // If we explicitly specify mesh config, use it. // This takes precedence over default mesh config or mesh config from a running Kube instance. if meshCfgFile != "" { _ = sa.AddFileKubeMeshConfig(meshCfgFile) } // If we're not using kube (files only), add defaults for some resources we expect to be provided by Istio
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
istioctl/pkg/validate/validate_test.go
name: "filename missing", wantError: true, }, { name: "valid resources from file", args: []string{"--filename", validFilenameYAML}, }, { name: "extra args", args: []string{"--filename", validFilenameYAML, "extra-arg"}, wantError: true, }, { name: "invalid resources from file", args: []string{"--filename", invalidFilenameYAML}, wantError: true, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 25 08:08:36 GMT 2023 - 21.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/route.go
shouldDelete.Insert(h) } stripPartial := strings.TrimSuffix(h, ".svc") if unique.Contains(stripPartial) && stripPartial != h { shouldDelete.Insert(h) } } // Filter from original list to keep original order ret := make([]string, 0, len(domains)) for _, h := range domains { if !shouldDelete.Contains(h) { ret = append(ret, h) } } return ret }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 11 05:38:17 GMT 2023 - 7.2K bytes - Viewed (0) -
cni/pkg/plugin/plugin_dryrun_test.go
// Separate content with "COMMIT" parts := strings.Split(string(b), "COMMIT") tables := make(map[string]string) for _, table := range parts { // If table is not empty, get table name from the first line lines := strings.Split(strings.Trim(table, "\n"), "\n") if len(lines) >= 1 && strings.HasPrefix(lines[0], "* ") { tableName := lines[0][2:] lines = append(lines, "COMMIT")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 8.4K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
func routeDestinationMatchesSvc(vhRoute *route.Route, svc corev1.Service, vh *route.VirtualHost, port int32) bool { if vhRoute == nil { return false } // Infer from VirtualHost domains matching <service>.<namespace>.svc.cluster.local re := regexp.MustCompile(`(?P<service>[^\.]+)\.(?P<namespace>[^\.]+)\.svc\.cluster\.local$`) for _, domain := range vh.Domains {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
K8S_POD_INFRA_CONTAINER_ID types.UnmarshallableString // nolint: revive, stylecheck } // parseConfig parses the supplied configuration (and prevResult) from stdin. func parseConfig(stdin []byte) (*Config, error) { conf := Config{} if err := json.Unmarshal(stdin, &conf); err != nil { return nil, fmt.Errorf("failed to parse network configuration: %v", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0)