package iptables

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

Index ¶

• Constants
• func CanUseIPTablesProxier(iptver IPTablesVersioner, kcompat KernelCompatTester) (bool, error)
• func CleanupLeftovers(ipt utiliptables.Interface) (encounteredError bool)
• type IPTablesVersioner
• type KernelCompatTester
• type LinuxKernelCompatTester
• func (lkct LinuxKernelCompatTester) IsCompatible() error
• type Proxier
• func NewProxier(ipt utiliptables.Interface, sysctl utilsysctl.Interface, exec utilexec.Interface, syncPeriod time.Duration, minSyncPeriod time.Duration, masqueradeAll bool, masqueradeBit int, clusterCIDR string, hostname string, nodeIP net.IP, recorder record.EventRecorder, healthzServer healthcheck.HealthzUpdater, nodePortAddresses []string, ) (*Proxier, error)
• func (proxier *Proxier) OnEndpointsAdd(endpoints *v1.Endpoints)
• func (proxier *Proxier) OnEndpointsDelete(endpoints *v1.Endpoints)
• func (proxier *Proxier) OnEndpointsSynced()
• func (proxier *Proxier) OnEndpointsUpdate(oldEndpoints, endpoints *v1.Endpoints)
• func (proxier *Proxier) OnServiceAdd(service *v1.Service)
• func (proxier *Proxier) OnServiceDelete(service *v1.Service)
• func (proxier *Proxier) OnServiceSynced()
• func (proxier *Proxier) OnServiceUpdate(oldService, service *v1.Service)
• func (proxier *Proxier) Sync()
• func (proxier *Proxier) SyncLoop()

Constants ¶

const (

	// the mark-for-masquerade chain
	KubeMarkMasqChain utiliptables.Chain = "KUBE-MARK-MASQ"

	// the mark-for-drop chain
	KubeMarkDropChain utiliptables.Chain = "KUBE-MARK-DROP"
)

Functions ¶

func CanUseIPTablesProxier ¶

func CanUseIPTablesProxier(iptver IPTablesVersioner, kcompat KernelCompatTester) (bool, error)

CanUseIPTablesProxier returns true if we should use the iptables Proxier instead of the "classic" userspace Proxier. This is determined by checking the iptables version and for the existence of kernel features. It may return an error if it fails to get the iptables version without error, in which case it will also return false.

func CleanupLeftovers ¶

func CleanupLeftovers(ipt utiliptables.Interface) (encounteredError bool)

CleanupLeftovers removes all iptables rules and chains created by the Proxier It returns true if an error was encountered. Errors are logged.

Types ¶

type IPTablesVersioner ¶

type IPTablesVersioner interface {
	// returns "X.Y.Z"
	GetVersion() (string, error)
}

IPTablesVersioner can query the current iptables version.

type KernelCompatTester ¶

type KernelCompatTester interface {
	IsCompatible() error
}

KernelCompatTester tests whether the required kernel capabilities are present to run the iptables proxier.

type LinuxKernelCompatTester ¶

type LinuxKernelCompatTester struct{}

func (LinuxKernelCompatTester) IsCompatible ¶

func (lkct LinuxKernelCompatTester) IsCompatible() error

type Proxier ¶

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

Proxier is an iptables based proxy for connections between a localhost:lport and services that provide the actual backends.

func NewProxier ¶

func NewProxier(ipt utiliptables.Interface,
	sysctl utilsysctl.Interface,
	exec utilexec.Interface,
	syncPeriod time.Duration,
	minSyncPeriod time.Duration,
	masqueradeAll bool,
	masqueradeBit int,
	clusterCIDR string,
	hostname string,
	nodeIP net.IP,
	recorder record.EventRecorder,
	healthzServer healthcheck.HealthzUpdater,
	nodePortAddresses []string,
) (*Proxier, error)

NewProxier returns a new Proxier given an iptables Interface instance. Because of the iptables logic, it is assumed that there is only a single Proxier active on a machine. An error will be returned if iptables fails to update or acquire the initial lock. Once a proxier is created, it will keep iptables up to date in the background and will not terminate if a particular iptables call fails.

func (*Proxier) OnEndpointsAdd ¶

func (proxier *Proxier) OnEndpointsAdd(endpoints *v1.Endpoints)

func (*Proxier) OnEndpointsDelete ¶

func (proxier *Proxier) OnEndpointsDelete(endpoints *v1.Endpoints)

func (*Proxier) OnEndpointsSynced ¶

func (proxier *Proxier) OnEndpointsSynced()

func (*Proxier) OnEndpointsUpdate ¶

func (proxier *Proxier) OnEndpointsUpdate(oldEndpoints, endpoints *v1.Endpoints)

func (*Proxier) OnServiceAdd ¶

func (proxier *Proxier) OnServiceAdd(service *v1.Service)

func (*Proxier) OnServiceDelete ¶

func (proxier *Proxier) OnServiceDelete(service *v1.Service)

func (*Proxier) OnServiceSynced ¶

func (proxier *Proxier) OnServiceSynced()

func (*Proxier) OnServiceUpdate ¶

func (proxier *Proxier) OnServiceUpdate(oldService, service *v1.Service)

func (*Proxier) Sync ¶

func (proxier *Proxier) Sync()

Sync is called to synchronize the proxier state to iptables as soon as possible.

func (*Proxier) SyncLoop ¶

func (proxier *Proxier) SyncLoop()

SyncLoop runs periodic work. This is expected to run as a goroutine or as the main loop of the app. It does not return.

Source Files ¶

proxier.go