Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ClearEntriesForPort (0.14 sec)

  1. pkg/proxy/conntrack/conntrack.go

    	// protocol, to the given IP.
    	ClearEntriesForIP(ip string, protocol v1.Protocol) error
    
    	// ClearEntriesForPort deletes conntrack entries for connections of the given
    	// protocol and IP family, to the given port.
    	ClearEntriesForPort(port int, isIPv6 bool, protocol v1.Protocol) error
    
    	// ClearEntriesForNAT deletes conntrack entries for connections of the given
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 15 18:09:05 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. pkg/proxy/conntrack/fake.go

    	if protocol != v1.ProtocolUDP {
    		return fmt.Errorf("FakeInterface currently only supports UDP")
    	}
    
    	fake.ClearedIPs.Insert(ip)
    	return nil
    }
    
    // ClearEntriesForPort is part of Interface
    func (fake *FakeInterface) ClearEntriesForPort(port int, isIPv6 bool, protocol v1.Protocol) error {
    	if protocol != v1.ProtocolUDP {
    		return fmt.Errorf("FakeInterface currently only supports UDP")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 26 04:15:49 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. pkg/proxy/conntrack/conntrack_test.go

    			port:   6666,
    			isIPv6: true,
    
    			expectCommand: "conntrack -D -p udp --dport 6666 -f ipv6",
    		},
    	}
    
    	for _, tc := range testCases {
    		ct := makeCT(success)
    		err := ct.ClearEntriesForPort(tc.port, tc.isIPv6, v1.ProtocolUDP)
    		if err != nil {
    			t.Errorf("%s/success: Unexpected error: %v", tc.name, err)
    		}
    		execCommand := ct.getExecutedCommand()
    		if tc.expectCommand != execCommand {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 15 18:08:36 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. pkg/proxy/conntrack/cleanup.go

    		}
    	}
    	klog.V(4).InfoS("Deleting conntrack stale entries for services", "nodePorts", conntrackCleanupServiceNodePorts.UnsortedList())
    	for _, nodePort := range conntrackCleanupServiceNodePorts.UnsortedList() {
    		err := ct.ClearEntriesForPort(nodePort, isIPv6, v1.ProtocolUDP)
    		if err != nil {
    			klog.ErrorS(err, "Failed to clear udp conntrack", "nodePort", nodePort)
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 15 18:09:05 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top