iptables

package
v1.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 17, 2016 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source
const KubeMarkMasqChain utiliptables.Chain = "KUBE-MARK-MASQ"

the mark-for-masquerade chain TODO: let kubelet manage this chain. Other component should just assume it exists and use it.

Variables

This section is empty.

Functions

func CanUseIptablesProxier added in v1.2.3

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 added in v1.2.3

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

IptablesVersioner can query the current iptables version.

type KernelCompatTester added in v1.2.3

type KernelCompatTester interface {
	IsCompatible() error
}

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

type LinuxKernelCompatTester added in v1.2.3

type LinuxKernelCompatTester struct{}

func (LinuxKernelCompatTester) IsCompatible added in v1.2.3

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, exec utilexec.Interface, syncPeriod time.Duration, masqueradeAll bool, masqueradeBit int, clusterCIDR 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) OnEndpointsUpdate

func (proxier *Proxier) OnEndpointsUpdate(allEndpoints []api.Endpoints)

OnEndpointsUpdate takes in a slice of updated endpoints.

func (*Proxier) OnServiceUpdate

func (proxier *Proxier) OnServiceUpdate(allServices []api.Service)

OnServiceUpdate tracks the active set of service proxies. They will be synchronized using syncProxyRules()

func (*Proxier) Sync

func (proxier *Proxier) Sync()

Sync is called to immediately synchronize the proxier state to iptables

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL