- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 42 for So (2.49 sec)
-
istioctl/pkg/kubeinject/kubeinject.go
Use: "kube-inject", Short: "Inject Istio sidecar into Kubernetes pod resources", Long: ` kube-inject manually injects the Istio sidecar into Kubernetes workloads. Unsupported resources are left unmodified so it is safe to run kube-inject over a single file that contains multiple Service, ConfigMap, Deployment, etc. definitions for a complex application. When in
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) -
cni/pkg/install/install.go
) // Create file watcher before checking for installation // so that no file modifications are missed while and after checking // note: we create a file watcher for each invocation, otherwise when we write to the directories // we would get infinite looping of events // // Additionally, fsnotify will lose existing watches on atomic copies (due to overwrite/rename), // so we have to re-watch after re-copy to make sure we always have fresh watches.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
patchBytes := fmt.Sprintf(`{"metadata":{"labels":{%q:%q}}}`, c.cfg.LabelKey, c.cfg.LabelValue) // Both "pods" and "pods/status" can mutate the metadata. However, pods/status is lower privilege, so we use that instead. _, err := c.client.Kube().CoreV1().Pods(pod.Namespace).Patch(context.Background(), pod.Name, types.MergePatchType, []byte(patchBytes), metav1.PatchOptions{}, "status") if err != nil {
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/ipset/ipset.go
ipToInsert := ip.Unmap() // We have already Unmap'd, so we can do a simple IsV6 y/n check now if ipToInsert.Is6() { return m.Deps.addIP(m.V6Name, ipToInsert, ipProto, comment, replace) } return m.Deps.addIP(m.V4Name, ipToInsert, ipProto, comment, replace) } func (m *IPSet) DeleteIP(ip netip.Addr, ipProto uint8) error { ipToDel := ip.Unmap() // We have already Unmap'd, so we can do a simple IsV6 y/n check now if ipToDel.Is6() {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.9K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
// If they don't, the user will be warned and be presented with the command to label their namespace as ambient if they // choose to do so. // // NOTE: This is a warning and not an error because the user may not intend to label their namespace as ambient. // // e.g. Users are handling ambient redirection per workload rather than at the namespace level.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cni/pkg/util/podutil.go
Patch( context.Background(), pod.Name, types.MergePatchType, annotationPatch, metav1.PatchOptions{}, // Both "pods" and "pods/status" can mutate the metadata. However, pods/status is lower privilege, so we use that instead. "status", ) return err } func AnnotateUnenrollPod(client kubernetes.Interface, pod *metav1.ObjectMeta) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
PodName string PodNamespace string IPs []IPConfig } // IPConfig contains an interface/gateway/address combo defined for a newly-started pod by CNI. // This is "from the horse's mouth" so to speak and will be populated before Kube is informed of the // pod IP. type IPConfig struct { Interface *int Address net.IPNet Gateway net.IP } type CniPluginServer struct {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/nodeagent/netns.go
type NetnsWithFd struct { netns io.Closer fd uintptr inode uint64 } func (n *NetnsWithFd) Close() error { if n.netns == nil { return nil } ret := n.netns.Close() // set fd to invalid value, so if something uses it by mistake it will err uintZero := uintptr(0) n.fd = ^uintZero return ret } func (n *NetnsWithFd) Fd() uintptr { return n.fd } func (n *NetnsWithFd) Inode() uint64 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.2K bytes - Viewed (0) -
cni/pkg/nodeagent/options.go
// APIPA/"link-local" IP. // // It doesn't matter what this IP is, so long as it's not routable and doesn't collide with anything else. // // IPv6 link local ranges are designed to be collision-resistant by default, and so probably never need to be overridden DefaultHostProbeSNATIP = "169.254.7.127" DefaultHostProbeSNATIPV6 = "fd16:9254:7127:1337:ffff:ffff:ffff:ffff" )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 2K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
dpServer := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, dpServer, "istio-system") // We are not going to start the server, so the sockpath is irrelevant pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer) // label the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0)