Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for inside (0.15 sec)

  1. cni/pkg/nodeagent/server.go

    	if err != nil {
    		return nil, fmt.Errorf("error configuring iptables: %w", err)
    	}
    
    	// Create hostprobe rules now, in the host netns
    	// Later we will reuse this same configurator inside the pod netns for adding other rules
    	iptablesConfigurator.DeleteHostRules()
    
    	if err := iptablesConfigurator.CreateHostRulesForHealthChecks(&HostProbeSNATIP, &HostProbeSNATIPV6); err != nil {
    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)
  2. cni/pkg/nodeagent/net.go

    	}
    
    	return openNetns, nil
    }
    
    // AddPodToMesh adds a pod to mesh by
    // 1. Getting the netns
    // 2. Adding the pod's IPs to the hostnetns ipsets for node probe checks
    // 3. Creating iptables rules inside the pod's netns
    // 4. Notifying ztunnel via GRPC to create a proxy for the pod
    //
    // You may ask why we pass the pod IPs separately from the pod manifest itself (which contains the pod IPs as a field)
    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)
  3. operator/cmd/mesh/manifest_shared_test.go

    			}
    		case cmdApply:
    			objs, err = fakeApplyManifest(inFile, flags, chartSource)
    		case cmdController:
    			objs, err = fakeControllerReconcile(inFile, chartSource, nil)
    		default:
    		}
    		if err != nil {
    			return nil, err
    		}
    		out[cmd] = objs
    	}
    
    	return out, nil
    }
    
    // fakeApplyManifest runs istioctl install.
    func fakeApplyManifest(inFile, flags string, chartSource chartSourceType) (*ObjectSet, error) {
    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)
  4. cni/pkg/repair/netns.go

    // * /var/lib/cni/results shows the outputs of CNI plugins; this containers the bind-mounted network namespace file.
    //
    // 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.
    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)
  5. istioctl/pkg/writer/envoy/configdump/listener.go

    		if describeDomains(vh) == "" {
    			vhosts = append(vhosts, describeRoutes(vh))
    		} else {
    			vhosts = append(vhosts, fmt.Sprintf("%s %s", describeDomains(vh), describeRoutes(vh)))
    		}
    	}
    	return fmt.Sprintf("Inline Route: %s", strings.Join(vhosts, "; "))
    }
    
    // If this is a route that matches everything and forwards to a cluster, just report the cluster.
    func getMatchAllCluster(er *route.RouteConfiguration) string {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/options.go

    	HostProbeSNATIPV6 = netip.MustParseAddr(env.RegisterStringVar("HOST_PROBE_SNAT_IPV6", DefaultHostProbeSNATIPV6, "").Get())
    )
    
    const (
    	// to reliably identify kubelet healthprobes from inside the pod (versus standard kube-proxy traffic,
    	// since the IP is normally the same), we SNAT identified host probes in the host netns to a fixed
    	// APIPA/"link-local" IP.
    	//
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 2K bytes
    - Viewed (0)
  7. istioctl/pkg/multicluster/remote_secret.go

    	}
    	server := restCfg.Host
    	if strings.Contains(server, "127.0.0.1") || strings.Contains(server, "localhost") {
    		return server, fmt.Errorf(
    			"server in Kubeconfig is %s. This is likely not reachable from inside the cluster, "+
    				"if you're using Kubernetes in Docker, pass --server with the container IP for the API Server",
    			server), nil
    	}
    	return server, nil, nil
    }
    
    const (
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Oct 11 01:43:17 GMT 2023
    - 24K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/netns_linux.go

    	"fmt"
    	"runtime"
    	"sync"
    
    	netns "github.com/containernetworking/plugins/pkg/ns"
    	"golang.org/x/sys/unix"
    )
    
    type NetnsWrapper struct {
    	innerNetns netns.NetNS
    	inode      uint64
    }
    
    func (n *NetnsWrapper) Inode() uint64 {
    	return n.inode
    }
    
    func (n *NetnsWrapper) Close() error {
    	return n.innerNetns.Close()
    }
    
    func (n *NetnsWrapper) Fd() uintptr {
    	return n.innerNetns.Fd()
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 31 10:05:36 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/podcgroupns_linux.go

    import (
    	"fmt"
    	"io/fs"
    	"syscall"
    )
    
    func GetInode(fi fs.FileInfo) (uint64, error) {
    	if stat, ok := fi.Sys().(*syscall.Stat_t); ok {
    		return stat.Ino, nil
    	}
    	return 0, fmt.Errorf("unable to get inode")
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 814 bytes
    - Viewed (0)
  10. istioctl/pkg/kubeinject/kubeinject_test.go

    				" "),
    			GoldenFilename: "testdata/deployment/hello.yaml.injected",
    		},
    		{ // case 3
    			Args: strings.Split(
    				"--meshConfigFile testdata/mesh-config.yaml"+
    					" --injectConfigFile testdata/inject-config-inline.yaml -f testdata/deployment/hello.yaml"+
    					" --valuesFile testdata/inject-values.yaml",
    				" "),
    			GoldenFilename: "testdata/deployment/hello.yaml.injected",
    		},
    		{ // case 4 with only iop files
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 3.4K bytes
    - Viewed (0)
Back to top