package conntrack

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

Index ¶

• func CleanStaleEntries(ct Interface, ipFamily v1.IPFamily, svcPortMap proxy.ServicePortMap, serviceUpdateResult proxy.UpdateServiceMapResult, endpointsUpdateResult proxy.UpdateEndpointsMapResult)
• type FakeInterface
• func NewFake() *FakeInterface
• func (fake *FakeInterface) ClearEntries(_ uint8, filters ...netlink.CustomConntrackFilter) error
• func (fake *FakeInterface) Reset()
• type Interface
• func New() Interface

Functions ¶

func CleanStaleEntries ¶

func CleanStaleEntries(ct Interface, ipFamily v1.IPFamily, svcPortMap proxy.ServicePortMap,
	serviceUpdateResult proxy.UpdateServiceMapResult, endpointsUpdateResult proxy.UpdateEndpointsMapResult)

CleanStaleEntries takes care of flushing stale conntrack entries for services and endpoints.

Types ¶

type FakeInterface ¶

type FakeInterface struct {
	ClearedIPs      sets.Set[string]
	ClearedPorts    sets.Set[int]
	ClearedNATs     map[string]string // origin -> dest
	ClearedPortNATs map[int]string    // port -> dest
}

FakeInterface implements Interface by just recording entries that have been cleared.

func NewFake ¶

func NewFake() *FakeInterface

NewFake creates a new FakeInterface

func (*FakeInterface) ClearEntries ¶

func (fake *FakeInterface) ClearEntries(_ uint8, filters ...netlink.CustomConntrackFilter) error

ClearEntries is part of Interface

func (*FakeInterface) Reset ¶

func (fake *FakeInterface) Reset()

Reset clears fake's sets/maps

type Interface ¶

type Interface interface {
	// ClearEntries deletes conntrack entries for connections of the given IP family,
	// filtered by the given filters.
	ClearEntries(ipFamily uint8, filters ...netlink.CustomConntrackFilter) error
}

Interface for dealing with conntrack

func New ¶

func New() Interface

Source Files ¶

cleanup.go conntrack.go doc.go fake.go filter.go