- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 76 for Case (0.14 sec)
-
istioctl/pkg/describe/describe_test.go
} cases := []execAndK8sConfigTestCase{ { // case 0 args: []string{}, expectedString: "Describe resource and related Istio configuration", }, { // case 2 no pod args: strings.Split("pod", " "), expectedString: "Error: expecting pod name", wantException: true, // "istioctl experimental inspect pod" should fail }, { // case 3 unknown pod
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Mar 28 09:54:01 GMT 2024 - 30.4K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
}, ) } switch ga.outputFormat { case "short": w := new(tabwriter.Writer).Init(out, 0, 8, 3, ' ', 0) _, _ = fmt.Fprintln(w, "ACTIVE SCOPE\tDESCRIPTION\tLOG LEVEL") for _, sll := range resultScopeLogLevel { _, _ = fmt.Fprintf(w, "%s\t%s\t%s\n", sll.ScopeName, sll.Description, sll.LogLevel) } return w.Flush() case "json", "yaml":
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
for k, v := range in { out[fmt.Sprintf("%v", k)] = transformMapValue(v) } return out } func transformMapValue(in any) any { switch v := in.(type) { case []any: return transformInterfaceArray(v) case map[any]any: return transformInterfaceMap(v) default: return v } } func servicePortPrefixed(n string) bool { i := strings.IndexByte(n, '-') if i >= 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/tag/revision.go
func ListRevisionDescriptions(client kube.CLIClient) (map[string]*RevisionDescription, error) { revisions := map[string]*RevisionDescription{} // Get a list of control planes which are installed in remote clusters // In this case, it is possible that they only have webhooks installed. webhooks, err := Webhooks(context.Background(), client) if err != nil { return nil, fmt.Errorf("error while listing mutating webhooks: %v", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Jan 28 13:16:05 GMT 2023 - 4.5K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
} select { case newVersion := <-w.resultsChan: printVerbosef(cmd, "received new target version: %s", newVersion) generations = append(generations, newVersion) case <-t.C: printVerbosef(cmd, "tick") continue case err = <-w.errorChan: t.Stop() return fmt.Errorf("unable to retrieve Kubernetes resource2 %s: %v", "", err) case <-ctx.Done():
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) -
istioctl/pkg/tag/util.go
// used rather than just deleting the webhook since we want to keep it around after changing the default so user can later // switch back to it. This is a hack but it is meant to cover a corner case where a user wants to migrate from a non-revisioned // old version and then later decides to switch back to the old revision again. func DeactivateIstioInjectionWebhook(ctx context.Context, client kubernetes.Interface) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:42 GMT 2024 - 5.4K bytes - Viewed (1) -
istioctl/pkg/tag/tag.go
if r := cmp.Compare(a.Revision, b.Revision); r != 0 { return r } return cmp.Compare(a.Tag, b.Tag) }) switch outputFormat { case util.JSONFormat: return PrintJSON(writer, tags) case util.TableFormat: default: return fmt.Errorf("unknown format: %s", outputFormat) } w := new(tabwriter.Writer).Init(writer, 0, 8, 1, ' ', 0)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
cni/pkg/install/cniconfig_test.go
// Create temp directory for files tempDir := t.TempDir() // Create existing config files if specified in test case for _, filename := range c.existingConfFiles { if err := file.AtomicCopy(filepath.Join("testdata", filepath.Base(filename)), tempDir, filepath.Base(filename)); err != nil { t.Fatal(err) } } cfg := pluginConfig{ mountedCNINetDir: tempDir,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 17 02:22:22 GMT 2023 - 15.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
} } // End previous result parsing return &conf, nil } func getLogLevel(logLevel string) log.Level { switch logLevel { case "debug": return log.DebugLevel case "warn": return log.WarnLevel case "error": return log.ErrorLevel case "info": return log.InfoLevel } return log.InfoLevel } func GetLoggingOptions(udsAddress string) *log.Options {
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) -
cni/pkg/util/pluginutil.go
} // Waits until a file is modified (returns nil), the context is cancelled (returns context error), or returns error func (w *Watcher) Wait(ctx context.Context) error { select { case <-w.Events: return nil case err := <-w.Errors: return err case <-ctx.Done(): return ctx.Err() } } func (w *Watcher) Close() { _ = w.watcher.Close() } // Creates a file watcher that watches for any changes to the directory
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0)