- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for Ball (0.14 sec)
-
istioctl/pkg/multixds/gather.go
err error ) if options.XdsViaAgents { responses, err = queryDebugSynczViaAgents(all, dr, istioNamespace, kubeClient, centralOpts, options) } else { // Self-administered case. Find all Istiods in revision using K8s, port-forward and call each in turn responses, err = queryEachShard(all, dr, istioNamespace, kubeClient, centralOpts) } if err != nil { if _, ok := err.(ControlPlaneNotFoundError); ok {
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) -
cni/pkg/nodeagent/net.go
} // addPodToHostNSIpset: // 1. get pod manifest // 2. Get all pod ips (might be several, v6/v4) // 3. update ipsets accordingly func addPodToHostNSIpset(pod *corev1.Pod, podIPs []netip.Addr, hostsideProbeSet *ipset.IPSet) error { // Add the pod UID as an ipset entry comment, so we can (more) easily find and delete // all relevant entries for a pod later. podUID := string(pod.ObjectMeta.UID)
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) -
istioctl/pkg/workload/workload_test.go
t.Errorf("want %s, got %s", c.want, str) } }) } } // TestWorkloadEntryConfigureNilProxyMetadata tests a particular use case when the // proxyMetadata is nil, no metadata would be generated at all. func TestWorkloadEntryConfigureNilProxyMetadata(t *testing.T) { testdir := "testdata/vmconfig-nil-proxy-metadata" noClusterID := "failed to automatically determine the --clusterID" t.Cleanup(func() {
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/net_test.go
// make sure the uid was taken from cache and netns closed netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns: //revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns runtime.GC() assertNSClosed(t, closed) } func TestServerDeletePod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
ext: ext, nlDeps: nlDeps, cfg: cfg, } // By detecting iptables versions *here* once-for-all we are // committing to using the same binary/variant (legacy or nft) // within all pods as we do on the host. // // This should be fine, as the host binaries are all we have to work with here anyway, // as we are running within a privileged container - and we don't want to take the time to
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) -
cni/pkg/nodeagent/ztunnelserver.go
return len(c.connectionSet) } type ztunnelServer struct { listener *net.UnixListener // connections to pod delivered map // add pod goes to newest connection // delete pod goes to all connections conns *connMgr pods PodNetnsCache } var _ ZtunnelServer = &ztunnelServer{} func newZtunnelServer(addr string, pods PodNetnsCache) (*ztunnelServer, error) { if addr == "" {
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/dashboard/dashboard.go
client kube.CLIClient, writer io.Writer, browser bool, ) error { // port preference: // - If --listenPort is specified, use it // - without --listenPort, prefer the remotePort but fall back to a random port var portPrefs []int if listenPort != 0 { portPrefs = []int{listenPort} } else { portPrefs = []int{remotePort, 0} } var err error for _, localPort := range portPrefs {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
allConfigCmd := &cobra.Command{ Use: "all [<type>/]<name>[.<namespace>]", Short: "Retrieves all configuration for the Envoy in the specified pod", Long: `Retrieve information about all configuration for the Envoy instance in the specified pod.`, Example: ` # Retrieve summary about all configuration for a given pod from Envoy. istioctl proxy-config all <pod-name[.namespace]> # Retrieve full cluster dump as JSON
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
} else { injector, err = setUpExternalInjector(cliContext, revision, injectorAddress) if err != nil || injector.clientConfig == nil { log.Warnf("failed to get injection config from mutatingWebhookConfigurations %q, will fall back to "+ "get injection from the injection configmap %q : %v", whcName, defaultInjectWebhookConfigName, err) if *sidecarTemplate, err = getInjectConfigFromConfigMap(cliContext, revision); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
operator/cmd/mesh/install.go
InFilenames []string // ReadinessTimeout is maximum time to wait for all Istio resources to be ready. wait must be true for this setting // to take effect. ReadinessTimeout time.Duration // SkipConfirmation determines whether the user is prompted for confirmation. // If set to true, the user is not prompted and a Yes response is assumed in all cases. SkipConfirmation bool // Force proceeds even if there are validation errors
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1)