- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 197 for if (0.11 sec)
-
istioctl/pkg/writer/ztunnel/configdump/certificates.go
func (c *ConfigWriter) PrintSecretDump(outputFormat string) error { if c.ztunnelDump == nil { return fmt.Errorf("config writer has not been primed") } secretDump := c.ztunnelDump.Certificates out, err := json.MarshalIndent(secretDump, "", " ") if err != nil { return fmt.Errorf("failed to marshal secrets dump: %v", err) } if outputFormat == "yaml" { if out, err = yaml.JSONToYAML(out); err != nil { return err } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0) -
cni/pkg/repair/netns.go
} if id != wantID { // Not the network we want, skip continue } s, err := p.Stat() if err != nil { // Unexpected... we will use it, but only if we find nothing without errors log.Warnf("failed to read proc %v stats: %v", p.PID, err) if best == "" { best = ns } continue } // Get the oldest one. if s.Starttime < oldest { oldest = s.Starttime
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
operator/cmd/mesh/profile-dump_test.go
got, err := runProfileDump(inPath, tt.configPath, snapshotCharts, "") if err != nil { t.Fatal(err) } // installPackagePath may change, we will remove it for consistent output got = installPackagePathRegex.ReplaceAllString(got, "") if refreshGoldenFiles() { t.Logf("Refreshing golden file for %s", outPath) if err := os.WriteFile(outPath, []byte(got), 0o644); err != nil { t.Error(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 20 11:44:25 GMT 2022 - 3.7K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
var retErr error err := s.netServer.AddPodToMesh(ctx, pod, podIPs, netNs) if err != nil { log.Errorf("failed to add pod to ztunnel: %v", err) if !errors.Is(err, ErrPartialAdd) { return err } retErr = err } log.Debugf("annotating pod %s", pod.Name) if err := util.AnnotateEnrolledPod(s.kubeClient, &pod.ObjectMeta); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
operator/cmd/mesh/manifest-diff.go
if err != nil { return err } if !equal { os.Exit(1) } return nil } equal, err = compareManifestsFromFiles(args, diffArgs.verbose, diffArgs.renameResources, diffArgs.selectResources, diffArgs.ignoreResources) if err != nil { return err } if !equal { os.Exit(1) } return nil }, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.8K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
istiodDump := &configdump.Wrapper{} err := json.Unmarshal(resp, istiodDump) if err != nil { continue } c.istiod = istiodDump break } if c.istiod == nil { return nil, fmt.Errorf("unable to find config dump in Istiod responses") } envoyDump := &configdump.Wrapper{} err := json.Unmarshal(envoyResponse, envoyDump) if err != nil { return nil, err } c.envoy = envoyDump c.w = w c.context = 7
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 3.7K bytes - Viewed (1) -
istioctl/pkg/proxystatus/proxystatus.go
func readConfigFile(filename string) ([]byte, error) { file := os.Stdin if filename != "-" { var err error file, err = os.Open(filename) if err != nil { return nil, err } } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() data, err := io.ReadAll(file) if err != nil { return nil, err } return data, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
cmd.SetOut(&out) cmd.SetErr(&out) cmd.SilenceUsage = true if c.namespace != "" { namespace = c.namespace } fErr := cmd.Execute() output := out.String() if c.expectedException { if fErr == nil { t.Fatalf("Wanted an exception, "+ "didn't get one, output was %q", output) } } else { if fErr != nil { t.Fatalf("Unwanted exception: %v", fErr) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
// If uid is already present, a cached Netns is returned, and the given nspath is ignored. func (p *podNetnsCache) Get(uid string) Netns { // lock current snapshot pod map p.mu.RLock() defer p.mu.RUnlock() if info, f := p.currentPodCache[uid]; f { return info.Netns } return nil } // make sure uid is in the cache, even if we don't have a netns
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
if err != nil { return err } sw := DebugWriter{ Writer: c.OutOrStdout(), InternalDebugAllIstiod: internalDebugAllIstiod, } newResponse, err := HandlerForDebugErrors(kubeClient, ¢ralOpts, c.OutOrStdout(), ctx.IstioNamespace(), xdsResponses) if err != nil { return err } if newResponse != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0)