package conntrack

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

Index ¶

• func CleanStaleEntries(ct Interface, ipFamily v1.IPFamily, svcPortMap proxy.ServicePortMap, endpointsMap proxy.EndpointsMap)
• 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. List existing conntrack entries and calculate the desired conntrack state based on the current Services and Endpoints.

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

Source Files ¶

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