- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Gugger (0.2 sec)
-
cni/pkg/log/uds_test.go
// Start UDS log server udsSockDir := t.TempDir() udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
operator/cmd/mesh/operator-remove.go
return nil }, } } // operatorRemove removes the Istio operator controller from the cluster. func operatorRemove(cmd *cobra.Command, cliClient kube.CLIClient, args *RootArgs, orArgs *operatorRemoveArgs, l clog.Logger) { kubeClient, client, err := KubernetesClients(cliClient, l) if err != nil { l.LogAndFatal(err) } // If the user is performing purge but also specified a revision, we should warn
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.4K bytes - Viewed (0) -
operator/cmd/mesh/profile-dump.go
} prettyJSON, err := json.MarshalIndent(decoded, "", " ") if err != nil { return "", err } return string(prettyJSON), nil } func profileDump(args []string, pdArgs *profileDumpArgs, l clog.Logger) error { if len(args) == 1 && pdArgs.inFilenames != nil { return fmt.Errorf("cannot specify both profile name and filename flag") } if err := validateProfileOutputFormatFlag(pdArgs.outputFormat); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate.go
return ManifestGenerate(kubeClient, rootArgs, mgArgs, l) }, } } func ManifestGenerate(kubeClient kube.CLIClient, args *RootArgs, mgArgs *ManifestGenerateArgs, l clog.Logger) error { manifests, _, err := manifest.GenManifests(mgArgs.InFilenames, applyFlagAliases(mgArgs.Set, mgArgs.ManifestsPath, mgArgs.Revision), mgArgs.Force, mgArgs.Filter, kubeClient, l) if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version_test.go
k8sClient := kube.NewFakeClient() k8sClient.Kube().Discovery().(*fakediscovery.FakeDiscovery).FakedServerVersion = c.version logger := clog.NewConsoleLogger(&outBuf, &errBuf, nil) IsK8VersionSupported(k8sClient, logger) errMsgTrim := strings.TrimSpace(c.logMsg) outBufTrim := strings.TrimSpace(outBuf.String()) if !c.isValid && strings.Compare(errMsgTrim, outBufTrim) != 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 19 02:46:48 GMT 2024 - 6.3K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
return nil }, } } // operatorInit installs the Istio operator controller into the cluster. func operatorInit(cliClient kube.CLIClient, args *RootArgs, oiArgs *operatorInitArgs, l clog.Logger) { kubeClient, client, err := kubeClients(cliClient, l) if err != nil { l.LogAndFatal(err) } if oiArgs.common.revision == "default" { oiArgs.common.revision = "" }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0) -
operator/cmd/mesh/operator_test.go
if err != nil { t.Fatal(err) } if diff := util.YAMLDiff(wantYAML, gotYAML); diff != "" { t.Fatalf("diff: %s", diff) } } func MockKubernetesClients(_ kube.CLIClient, _ clog.Logger) (kube.CLIClient, client.Client, error) { extendedClient = kube.NewFakeClient() kubeClient, _ = client.New(&rest.Config{}, client.Options{}) return extendedClient, kubeClient, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Aug 29 14:15:33 GMT 2023 - 6.4K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig_test.go
expectedString: "unrecognized logging level: xxx", wantException: true, }, { // logger name invalid execClientConfig: loggingConfig, args: strings.Split("log details-v1-5b7f94f9bc-wp5tb --level xxx:debug", " "), expectedString: "unrecognized logger name: xxx", wantException: true, }, { // logger name valid, but logging level invalid execClientConfig: loggingConfig,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 8.9K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
return false } switch strings.ToUpper(response) { case "Y", "YES": return true case "N", "NO": return false } } } func KubernetesClients(kubeClient kube.CLIClient, l clog.Logger) (kube.CLIClient, client.Client, error) { client, err := client.New(kubeClient.RESTConfig(), client.Options{Scheme: kube.IstioScheme}) if err != nil { return nil, nil, err }
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) -
istioctl/pkg/ztunnelconfig/ztunnelconfig_test.go
}, { // logger name invalid when namespacing is used improperly execClientConfig: loggingConfig, args: strings.Split("log ztunnel-9v7nw --level ztunnel:::pool:debug", " "), expectedString: "unrecognized logging level: pool:debug", wantException: true, }, { // logger name valid and logging level valid execClientConfig: loggingConfig,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 3.8K bytes - Viewed (0)