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) (int, error)
  • func (fake *FakeInterface) ListEntries(_ uint8) ([]*netlink.ConntrackFlow, error)
• type Interface
  • func New() Interface

Functions

func CleanStaleEntries

func CleanStaleEntries(ct Interface, ipFamily v1.IPFamily,
	svcPortMap proxy.ServicePortMap, endpointsMap proxy.EndpointsMap)

CleanStaleEntries scans conntrack table and removes any entries for a service that do not correspond to a serving endpoint.

Types

type FakeInterface

type FakeInterface struct {
	// contains filtered or unexported fields
}

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) (int, error)

ClearEntries is part of Interface

func (*FakeInterface) ListEntries

func (fake *FakeInterface) ListEntries(_ uint8) ([]*netlink.ConntrackFlow, error)

ListEntries is part of Interface

type Interface

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

Interface for dealing with conntrack

func New

func New() Interface