- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for still (0.24 sec)
-
cni/pkg/nodeagent/net.go
// in that case, try finding the netns using procfs. if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err) return nil, err } // try again. we can still get here if the pod is in the process of being created. // in this case the CNI will be invoked soon and provide us with the netns. openNetns = s.currentPodSnapshot.Get(string(pod.UID)) if openNetns == nil {
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) -
cni/pkg/nodeagent/pod_cache.go
type PodNetnsCache interface { ReadCurrentPodSnapshot() map[string]WorkloadInfo } // Hold a cache of node local pods with their netns // if we don't know the netns, the pod will still be here with a nil netns. type podNetnsCache struct { openNetns func(nspath string) (NetnsCloser, error) currentPodCache map[string]WorkloadInfo mu sync.RWMutex } type WorkloadInfo struct {
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) -
cni/test/install_cni.go
} else if err := os.Remove(resultFile); err != nil { t.Fatalf("error removing CNI config file: %s", resultFile) } // Verify configuration is still valid after removal compareConfResult(resultFile, expectedOutputFile, t) t.Log("PASS: Istio CNI configuration still valid after removal") // Shutdown the install-cni cancel() wg.Wait() t.Logf("Check the cleanup worked") if chainedCNIPlugin {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} case <-time.After(ztunnelKeepAliveCheckInterval): // do a short read, just to see if the connection to ztunnel is // still alive. As ztunnel shouldn't send anything unless we send // something first, we expect to get an os.ErrDeadlineExceeded error // here if the connection is still alive. // note that unlike tcp connections, reading is a good enough test here. _, err := conn.readMessage(time.Second / 100)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/tag/tag_test.go
Name: "dependent", Labels: map[string]string{label.IoIstioRev.Name: "match"}, }, }, }, }, outputMatches: []string{"Caution, found 1 namespace(s) still injected by tag \"match\": dependent"}, skipConfirmation: false, error: "", }, } for _, tc := range tcs { t.Run(tc.name, func(t *testing.T) { var out bytes.Buffer
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Nov 17 22:41:06 GMT 2023 - 8.7K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// iptables rules within a pod context into `legacy` tables, but your host context preferred // `nft`, we would still inject our rules in-pod into nft tables, which is a bit wonky. // // But that's stunningly unlikely (and would still work either way) iptVer, err := ext.DetectIptablesVersion(false) if err != nil { return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer.go
// The auth package provides support for checking the authentication and authorization policy applied // in the mesh. It aims to increase the debuggability and observability of auth policies. // Note: this is still under active development and is not ready for real use. package authz import ( "fmt" "io" envoy_admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jul 13 01:59:17 GMT 2022 - 2.1K bytes - Viewed (0) -
operator/cmd/mesh/operator-remove.go
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 // that the purge will still remove all resources if orArgs.purge && orArgs.revision != "" { orArgs.revision = "" l.LogAndPrint("Purge remove will remove all Istio operator controller, ignoring the specified revision\n") } var installed bool
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) -
istioctl/pkg/tag/tag.go
} taggedNamespaces, err := GetNamespacesWithTag(ctx, kubeClient, tagName) if err != nil { return fmt.Errorf("failed to retrieve namespaces dependent on tag %q", tagName) } // warn user if deleting a tag that still has namespaces pointed to it if len(taggedNamespaces) > 0 && !skipConfirmation { if !util.Confirm(buildDeleteTagConfirmation(tagName, taggedNamespaces), w) { fmt.Fprintf(w, "Aborting operation.\n") return nil }
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) -
istioctl/pkg/authz/authz.go
return nil, fmt.Errorf("failed to unmarshal proxy config: %s", err) } return envoyConfig, nil } // AuthZ groups commands used for inspecting and interacting the authorization policy. // Note: this is still under active development and is not ready for real use. func AuthZ(ctx cli.Context) *cobra.Command { cmd := &cobra.Command{ Use: "authz", Short: "Inspect Istio AuthorizationPolicy", }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 5K bytes - Viewed (0)