Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for IPv4Protocol (0.12 sec)

  1. pkg/proxy/endpointschangetracker_test.go

    			endpointsChangeTracker: NewEndpointsChangeTracker("", nil, v1.IPv4Protocol, nil, nil),
    			expectedChanges:        []*endpointsChange{},
    			appliedSlices:          []*discovery.EndpointSlice{},
    			pendingSlices:          []*discovery.EndpointSlice{},
    		},
    		"adding initial slice": {
    			endpointsChangeTracker: NewEndpointsChangeTracker("", nil, v1.IPv4Protocol, nil, nil),
    			expectedChanges: []*endpointsChange{{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 79.9K bytes
    - Viewed (0)
  2. pkg/controller/endpointslice/endpointslice_controller_test.go

    						{Name: "sctp-example", TargetPort: intstr.FromInt32(3456), Protocol: v1.ProtocolSCTP},
    					},
    					Selector:   map[string]string{"foo": "bar"},
    					IPFamilies: []v1.IPFamily{v1.IPv4Protocol},
    				},
    			},
    			pods: []*v1.Pod{
    				{
    					ObjectMeta: metav1.ObjectMeta{
    						Namespace:         "default",
    						Name:              "pod0",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  3. pkg/proxy/nftables/proxier.go

    	initOnly bool,
    ) (proxy.Provider, error) {
    	// Create an ipv4 instance of the single-stack proxier
    	ipv4Proxier, err := NewProxier(ctx, v1.IPv4Protocol,
    		syncPeriod, minSyncPeriod, masqueradeAll, masqueradeBit,
    		localDetectors[v1.IPv4Protocol], hostname, nodeIPs[v1.IPv4Protocol],
    		recorder, healthzServer, nodePortAddresses, initOnly)
    	if err != nil {
    		return nil, fmt.Errorf("unable to create ipv4 proxier: %v", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  4. pkg/controller/endpoint/endpoints_controller_test.go

    var oldTriggerTimeString = triggerTime.Add(-time.Hour).Format(time.RFC3339Nano)
    
    var ipv4only = []v1.IPFamily{v1.IPv4Protocol}
    var ipv6only = []v1.IPFamily{v1.IPv6Protocol}
    var ipv4ipv6 = []v1.IPFamily{v1.IPv4Protocol, v1.IPv6Protocol}
    var ipv6ipv4 = []v1.IPFamily{v1.IPv6Protocol, v1.IPv4Protocol}
    
    func testPod(namespace string, id int, nPorts int, isReady bool, ipFamilies []v1.IPFamily) *v1.Pod {
    	p := &v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  5. pkg/proxy/iptables/proxier.go

    ) (proxy.Provider, error) {
    	// Create an ipv4 instance of the single-stack proxier
    	ipv4Proxier, err := NewProxier(ctx, v1.IPv4Protocol, ipt[0], sysctl,
    		exec, syncPeriod, minSyncPeriod, masqueradeAll, localhostNodePorts, masqueradeBit,
    		localDetectors[v1.IPv4Protocol], hostname, nodeIPs[v1.IPv4Protocol],
    		recorder, healthzServer, nodePortAddresses, initOnly)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  6. pkg/proxy/winkernel/proxier.go

    	// Create an ipv4 instance of the single-stack proxier
    	ipv4Proxier, err := NewProxier(v1.IPv4Protocol, syncPeriod, minSyncPeriod,
    		hostname, nodeIPs[v1.IPv4Protocol], recorder, healthzServer,
    		healthzBindAddress, config)
    
    	if err != nil {
    		return nil, fmt.Errorf("unable to create ipv4 proxier: %v, hostname: %s, nodeIP:%v", err, hostname, nodeIPs[v1.IPv4Protocol])
    	}
    
    	ipv6Proxier, err := NewProxier(v1.IPv6Protocol, syncPeriod, minSyncPeriod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  7. pkg/proxy/ipvs/proxier.go

    	// Create an ipv4 instance of the single-stack proxier
    	ipv4Proxier, err := NewProxier(ctx, v1.IPv4Protocol, ipt[0], ipvs, ipset, sysctl,
    		exec, syncPeriod, minSyncPeriod, filterCIDRs(false, excludeCIDRs), strictARP,
    		tcpTimeout, tcpFinTimeout, udpTimeout, masqueradeAll, masqueradeBit,
    		localDetectors[v1.IPv4Protocol], hostname, nodeIPs[v1.IPv4Protocol], recorder,
    		healthzServer, scheduler, nodePortAddresses, initOnly)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
Back to top