conntrack

Documentation

Index

• func CleanStaleEntries(ct Interface, ipFamily v1.IPFamily, svcPortMap proxy.ServicePortMap, ...)
• 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