- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for could (0.27 sec)
-
istioctl/pkg/writer/ztunnel/configdump/certificates.go
expDate, err := time.Parse(time.RFC3339, cert.ExpirationTime) if err != nil { log.Errorf("certificate timestamp (%v) could not be parsed: %v", cert.ExpirationTime, err) return false } fromDate, err := time.Parse(time.RFC3339, cert.ValidFrom) if err != nil { log.Errorf("certificate timestamp (%v) could not be parsed: %v", cert.ValidFrom, err) return false } if today.After(fromDate) && today.Before(expDate) {
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
// // Instead, we traverse the procfs. Comments on this method are inline. func getPodNetNs(pod *corev1.Pod) (string, error) { // First, find the network namespace id by looking the interface with the given Pod IP. // This could break on some platforms if they do not have an interface-per-pod. wantID, err := findNetworkIDByIP(pod.Status.PodIP) if err != nil { return "", fmt.Errorf("network id: %v", err) } fs, err := procfs.NewFS("/host/proc")
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/manifest-diff.go
renameResources, selectResources, ignoreResources string, ) (bool, error) { a, err := os.ReadFile(args[0]) if err != nil { return false, fmt.Errorf("could not read %q: %v", args[0], err) } b, err := os.ReadFile(args[1]) if err != nil { return false, fmt.Errorf("could not read %q: %v", args[1], err) } diff, err := compare.ManifestDiffWithRenameSelectIgnore(string(a), string(b), renameResources, selectResources,
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) -
operator/cmd/mesh/manifest_shared_test.go
} check, ok := obj.DeepCopyObject().(client.Object) if !ok { return errors.New("could not check for object in fake client") } if err := clnt.Get(ctx, client.ObjectKeyFromObject(obj), check); kerrors.IsNotFound(err) { if err := clnt.Create(ctx, check); err != nil { return fmt.Errorf("could not inject object creation for fake: %w", err) } } else if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
istioctl/pkg/multixds/gather.go
return nil, err } defer fw.Close() xdsOpts.Xds = fw.Address() response, err := GetXdsResponse(dr, istioNamespace, tokenServiceAccount, xdsOpts, dialOpts) if err != nil { return nil, fmt.Errorf("could not get XDS from discovery pod %q: %v", pod.Name, err) } responses = append(responses, response) if !all && len(responses) > 0 { break } } return responses, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
} else { path := "config_dump" envoyDump, err = kubeClient.EnvoyDo(context.TODO(), podName, ns, "GET", path) } if err != nil { return fmt.Errorf("could not contact sidecar: %w", err) } xdsRequest := discovery.DiscoveryRequest{ ResourceNames: []string{fmt.Sprintf("%s.%s", podName, ns)}, TypeUrl: pilotxds.TypeDebugConfigDump, }
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/writer/pilot/status.go
err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) } meta, err := model.ParseMetadata(clientConfig.GetNode().GetMetadata()) if err != nil { return nil, nil, fmt.Errorf("could not parse node metadata: %w", err) } if s.Namespace != "" && meta.Namespace != s.Namespace { continue }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version_test.go
expected: 8, errMsg: nil, isValid: true, }, { version: versionInvalid1, errMsg: fmt.Errorf("could not parse Malformed version: %v", versionInvalid1.GitVersion), isValid: false, }, { version: versionInvalid2, errMsg: fmt.Errorf("could not parse Malformed version: %v", versionInvalid2.GitVersion), isValid: false, }, } for i, c := range cases {
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) -
cni/pkg/nodeagent/net.go
s.iptablesConfigurator.DeleteHostRules() log.Debug("destroying host ipset") s.hostsideProbeIPSet.Flush() if err := s.hostsideProbeIPSet.DestroySet(); err != nil { log.Warnf("could not destroy host ipset on shutdown") } log.Debug("stopping ztunnel server") s.ztunnelServer.Close() } func (s *NetServer) rescanPod(pod *corev1.Pod) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
operator/cmd/mesh/manifest-generate.go
if err := os.MkdirAll(dirName, os.ModePerm); err != nil { return fmt.Errorf("could not create directory %s; %s", outputDir, err) } } fname := filepath.Join(dirName, componentName) + ".yaml" l.LogAndPrintf("Writing manifest to %s", fname) if !dryRun { if err := os.WriteFile(fname, []byte(ym), 0o644); err != nil { return fmt.Errorf("could not write manifest config; %s", 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)