package util

import "k8s.io/kubernetes/pkg/proxy/util"

Index ¶

• func ClearUDPConntrackForIP(execer exec.Interface, ip string) error
• func ClearUDPConntrackForPeers(execer exec.Interface, origin, dest string) error
• func ClearUDPConntrackForPort(execer exec.Interface, port int) error
• func ExecConntrackTool(execer exec.Interface, parameters ...string) error
• func IsLocalIP(ip string) (bool, error)
• func ShouldSkipService(svcName types.NamespacedName, service *api.Service) bool

Functions ¶

func ClearUDPConntrackForIP ¶

func ClearUDPConntrackForIP(execer exec.Interface, ip string) error

DeleteServiceConnections uses the conntrack tool to delete the conntrack entries for the UDP connections specified by the given service IP

func ClearUDPConntrackForPeers ¶

func ClearUDPConntrackForPeers(execer exec.Interface, origin, dest string) error

ClearUDPConntrackForPeers uses the conntrack tool to delete the conntrack entries for the UDP connections specified by the {origin, dest} IP pair.

func ClearUDPConntrackForPort ¶

func ClearUDPConntrackForPort(execer exec.Interface, port int) error

ClearUDPConntrackForPort uses the conntrack tool to delete the conntrack entries for the UDP connections specified by the port. When a packet arrives, it will not go through NAT table again, because it is not "the first" packet. The solution is clearing the conntrack. Known issues: https://github.com/docker/docker/issues/8795 https://github.com/kubernetes/kubernetes/issues/31983

func ExecConntrackTool ¶

func ExecConntrackTool(execer exec.Interface, parameters ...string) error

ExecConntrackTool executes the conntrack tool using the given parameters

func IsLocalIP ¶

func IsLocalIP(ip string) (bool, error)

func ShouldSkipService ¶

func ShouldSkipService(svcName types.NamespacedName, service *api.Service) bool

Source Files ¶

conntrack.go utils.go