kubernetes/cmd/kube-proxy/app/server_linux_test.go

func Test_platformApplyDefaults(t *testing.T) { … }

func Test_getLocalDetectors(t *testing.T) { … }

func makeNodeWithPodCIDRs(cidrs ...string) *v1.Node { … }

func TestConfigChange(t *testing.T) { … }

func Test_waitForPodCIDR(t *testing.T) { … }

func TestGetConntrackMax(t *testing.T) { … }

func TestProxyServer_platformSetup(t *testing.T) { … }

type fakeConntracker …

// SetMax value is calculated based on the number of CPUs by getConntrackMax()
func (fc *fakeConntracker) SetMax(ctx context.Context, max int) error { … }

func (fc *fakeConntracker) SetTCPEstablishedTimeout(ctx context.Context, seconds int) error { … }

func (fc *fakeConntracker) SetTCPCloseWaitTimeout(ctx context.Context, seconds int) error { … }

func (fc *fakeConntracker) SetTCPBeLiberal(ctx context.Context, value int) error { … }

func (fc *fakeConntracker) SetUDPTimeout(ctx context.Context, seconds int) error { … }

func (fc *fakeConntracker) SetUDPStreamTimeout(ctx context.Context, seconds int) error { … }

func TestSetupConntrack(t *testing.T) { … }