kubernetes/pkg/proxy/conntrack/conntrack.go

type Interface …

type netlinkHandler …

type conntracker …

var _ …

func New() Interface { … }

func newConntracker(handler netlinkHandler) Interface { … }

// ListEntries list all conntrack entries for connections of the given IP family.
func (ct *conntracker) ListEntries(ipFamily uint8) ([]*netlink.ConntrackFlow, error) { … }

// ClearEntries deletes conntrack entries for connections of the given IP family,
// filtered by the given filters.
func (ct *conntracker) ClearEntries(ipFamily uint8, filters ...netlink.CustomConntrackFilter) (int, error) { … }