Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Wrobel (0.2 sec)

  1. 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
    //
    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)
  2. cmd/server-rlimit.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v2/sys"
    )
    
    func oldLinux() bool {
    	currentKernel, err := kernel.CurrentVersion()
    	if err != nil {
    		// Could not probe the kernel version
    		return false
    	}
    
    	if currentKernel == 0 {
    		// We could not get any valid value return false
    		return false
    	}
    
    	// legacy linux indicator for printing warnings
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/server.go

    		EnableIPv6:    args.EnableIPv6,
    	}
    
    	log.Debug("creating ipsets in the node netns")
    	set, err := createHostsideProbeIpset(cfg.EnableIPv6)
    	if err != nil {
    		return nil, fmt.Errorf("error initializing hostside probe ipset: %w", err)
    	}
    
    	podNsMap := newPodNetnsCache(openNetnsInRoot(pconstants.HostMountsPath))
    	ztunnelServer, err := newZtunnelServer(args.ServerSocket, podNsMap)
    	if 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)
  4. 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
    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. cni/pkg/iptables/iptables.go

    	RouteTableInbound    = 100
    
    	DNSCapturePort              = 15053
    	ZtunnelInboundPort          = 15008
    	ZtunnelOutboundPort         = 15001
    	ZtunnelInboundPlaintextPort = 15006
    	ProbeIPSet                  = "istio-inpod-probes"
    )
    
    var log = istiolog.RegisterScope("iptables", "iptables helper")
    
    type Config struct {
    	RestoreFormat bool `json:"RESTORE_FORMAT"`
    	TraceLogging  bool `json:"IPTABLES_TRACE_LOGGING"`
    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)
  6. cmd/warm-backend.go

    type remoteVersionID string
    
    // newWarmBackend instantiates the tier type specific WarmBackend, runs
    // checkWarmBackend on it.
    func newWarmBackend(ctx context.Context, tier madmin.TierConfig, probe bool) (d WarmBackend, err error) {
    	switch tier.Type {
    	case madmin.S3:
    		d, err = newWarmBackendS3(*tier.S3, tier.Name)
    	case madmin.Azure:
    		d, err = newWarmBackendAzure(*tier.Azure, tier.Name)
    	case madmin.GCS:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/net_test.go

    			},
    			{
    				Name:          "foo-2-port",
    				ContainerPort: 8020,
    			},
    		},
    		LivenessProbe: &corev1.Probe{
    			ProbeHandler: corev1.ProbeHandler{
    				HTTPGet: &corev1.HTTPGetAction{
    					Port: intstr.FromString("foo-2-port"),
    				},
    			},
    		},
    		StartupProbe: &corev1.Probe{
    			ProbeHandler: corev1.ProbeHandler{
    				HTTPGet: &corev1.HTTPGetAction{
    					Port: intstr.FromInt(7777),
    				},
    			},
    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)
  8. istioctl/pkg/workload/workload.go

    	}
    	if len(internalIP) > 0 {
    		overrides["ISTIO_SVC_IP"] = internalIP
    	} else if len(externalIP) > 0 {
    		overrides["ISTIO_SVC_IP"] = externalIP
    		overrides["REWRITE_PROBE_LEGACY_LOCALHOST_DESTINATION"] = "true"
    	}
    
    	// clusterEnv will use proxyMetadata from the proxyConfig + overrides specific to the WorkloadGroup and cmd args
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 17 20:06:41 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  9. internal/http/dial_linux.go

    				// TCP starts sending keepalive probes
    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPIDLE, 15)
    
    				// Number of probes.
    				// ~ cat /proc/sys/net/ipv4/tcp_keepalive_probes (defaults to 9, we reduce it to 5)
    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPCNT, 5)
    
    				// Wait time after successful probe in seconds.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 4.3K bytes
    - Viewed (3)
Back to top