Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for master (0.15 sec)

  1. cni/pkg/nodeagent/server.go

    // Note that if the ipset already exist by name, Create will not return an error.
    //
    // We will unconditionally flush our set before use here, so it shouldn't matter.
    func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) {
    	linDeps := ipset.RealNlDeps()
    	probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps)
    	if err != nil {
    		return probeSet, err
    	}
    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

    	"istio.io/istio/pkg/util/sets"
    	dep "istio.io/istio/tools/istio-iptables/pkg/dependencies"
    )
    
    var log = istiolog.RegisterScope("ambient", "ambient controller")
    
    // Adapts CNI to ztunnel server. decoupled from k8s for easier integration testing.
    type NetServer struct {
    	ztunnelServer        ZtunnelServer
    	currentPodSnapshot   *podNetnsCache
    	iptablesConfigurator *iptables.IptablesConfigurator
    	podNs                PodNetnsFinder
    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. cni/pkg/iptables/iptables.go

    	log.Info("configuring host-level iptables rules (healthchecks, etc)")
    
    	iptablesBuilder := builder.NewIptablesRuleBuilder(ipbuildConfig(cfg.cfg))
    
    	// For easier cleanup, insert a jump into an owned chain
    	// -A POSTROUTING -p tcp -j ISTIO_POSTRT
    	iptablesBuilder.AppendRule(
    		iptableslog.UndefinedCommand, iptablesconstants.POSTROUTING, iptablesconstants.NAT,
    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)
  4. cni/pkg/nodeagent/options.go

    	// since the IP is normally the same), we SNAT identified host probes in the host netns to a fixed
    	// 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
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 2K bytes
    - Viewed (0)
  5. istioctl/pkg/multicluster/remote_secret.go

    	remoteSecret, warn, err := createRemoteSecret(opt, client)
    	if err != nil {
    		return "", warn, err
    	}
    
    	// convert any binary data to the string equivalent for easier review. The
    	// kube-apiserver will convert this to binary before it persists it to storage.
    	remoteSecret.StringData = make(map[string]string, len(remoteSecret.Data))
    	for k, v := range remoteSecret.Data {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Oct 11 01:43:17 GMT 2023
    - 24K bytes
    - Viewed (0)
  6. operator/cmd/mesh/manifest-generate_test.go

    		}
    
    		serviceAccountName := mustGetPath(t, deployment, "spec.template.spec.serviceAccountName").(string)
    		mustFindObject(t, objs, serviceAccountName, name.SAStr)
    
    		// Check we aren't changing immutable fields. This only matters for in place upgrade (non revision)
    		// This one is not a selector, it must be an exact match
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 18 18:16:49 GMT 2024
    - 43.5K bytes
    - Viewed (0)
Back to top