- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 101 for already (0.3 sec)
-
cni/pkg/repair/repaircontroller.go
// Instead, we track which UIDs we repaired and skip them if already repaired. // // An alternative would be to write something to the Pod (status, annotation, etc). // However, this requires elevated privileges we want to avoid if uid, f := c.repairedPods[key]; f { if uid == pod.UID { log.Debugf("Skipping pod, already repaired") } else {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
Workload: workload.Workload, Netns: existing.Netns, } // already in cache return existing.Netns } log.Debug("netns inode mismatch, using the new one") } p.addToCacheUnderLock(uid, workload) return workload.Netns } // Update the cache with the given uid and nspath. Return the Netns for the given uid. // If uid is already present, a cached Netns is returned, and the given nspath is ignored.
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/README.md
## Privileges required
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 12.3K bytes - Viewed (0) -
istioctl/pkg/xds/google.go
if err != nil { return err } for k, v := range ret { if !strings.EqualFold(k, "authorization") { if _, ok := dst[k]; ok { return fmt.Errorf("underlying %s credentials contain a %s header which is already present in the combined credentials", kind, k) } dst[k] = v } else { dst[dstHdr] = v } } return nil } type hubMembership struct { WorkloadIdentityPool string }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Nov 14 20:23:34 GMT 2022 - 3.4K bytes - Viewed (0) -
manifests/charts/install-OpenShift.md
To install with Helm, you must first create the namespace that you wish to install in if the namespace does not exist already. The default namespace used is `istio-system` and can be created as follows: ```console kubectl create namespace istio-system ```
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 16:01:31 GMT 2024 - 1.8K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
oiArgs.common.revision = "" } // Error here likely indicates Deployment is missing. If some other K8s error, we will hit it again later. already, _ := isControllerInstalled(kubeClient.Kube(), oiArgs.common.operatorNamespace, oiArgs.common.revision) if already { l.LogAndPrintf("Operator controller is already installed in %s namespace.", oiArgs.common.operatorNamespace)
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) -
cni/pkg/nodeagent/server.go
if err != nil { return nil, fmt.Errorf("error starting cni server: %w", err) } s.cniServerStopFunc = cniServer.Stop return s, nil } func (s *Server) Ready() { s.isReady.Store(true) } func (s *Server) NotReady() { s.isReady.Store(false) } // buildKubeClient creates the kube client func buildKubeClient(kubeConfig string) (kube.Client, error) { // Used by validation
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) -
cni/pkg/nodeagent/informers.go
} else { // If oldpod != ready && newpod != ready, but the ambient annotation was added, // then assume this event was generated by the CNI plugin labeling the pod on startup, // and skip the event. // // This isn't perfect (someone could manually annotate an unready pod, // then install Istio, then the pod goes ready, and we'd miss capture) - but that // seems vanishingly unlikely
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
// `istioctl` can access the debug endpoint. // If `all` is true, `queryDebugSynczViaAgents` iterates all the pod having a proxy // except the pods of which status information is already queried. func queryDebugSynczViaAgents(all bool, dr *discovery.DiscoveryRequest, istioNamespace string, kubeClient kube.CLIClient, centralOpts clioptions.CentralControlPlaneOptions, options Options,
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/tag/generate_test.go
_, ok := wh.GetLabels()[operatorManaged] assert.Equal(t, ok, false) } for _, webhook := range wh.Webhooks { validationWhConf := webhook.ClientConfig // this is nil since we've already have one with failed FailurePolicy in the fake client if webhook.FailurePolicy != nil { t.Fatalf("expected FailurePolicy to be nil, got %v", *webhook.FailurePolicy) } if tc.whSVC != "" {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0)