environment

package
v0.0.0-...-21cfbab Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2023 License: Apache-2.0, Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Ubuntu        string = "ubuntu"
	RedHat        string = "rhel"
	DefaultDistro string = "default"
)

Variables

This section is empty.

Functions

func DetectBackend

func DetectBackend(lookPath func(file string) (string, error), newCmd cmdshim.CmdFactory, specifiedBackend string) string

GetIptablesBackend attempts to detect the iptables backend being used where Felix is running. This code is duplicating the detection method found at https://github.com/kubernetes-sigs/iptables-wrappers/blob/master/iptables-wrapper-installer.sh#L107 If there is a specifiedBackend then it is used but if it does not match the detected backend then a warning is logged.

func FindBestBinary

func FindBestBinary(lookPath func(file string) (string, error), ipVersion uint8, backendMode, saveOrRestore string) string

FindBestBinary tries to find an iptables binary for the specific variant (legacy/nftables mode) and returns the name of the binary. Falls back on iptables-restore/iptables-save if the specific variant isn't available. Panics if no binary can be found.

func GetDistFromString

func GetDistFromString(s string) string

func GetDistributionName

func GetDistributionName() string

func GetKernelVersionReader

func GetKernelVersionReader() (io.Reader, error)

Types

type FakeFeatureDetector

type FakeFeatureDetector struct {
	Features
}

func (*FakeFeatureDetector) GetFeatures

func (f *FakeFeatureDetector) GetFeatures() *Features

func (*FakeFeatureDetector) RefreshFeatures

func (f *FakeFeatureDetector) RefreshFeatures()

type FeatureDetector

type FeatureDetector struct {

	// Path to file with kernel version
	GetKernelVersionReader func() (io.Reader, error)
	// Factory for making commands, used by iptables UTs to shim exec.Command().
	NewCmd cmdshim.CmdFactory
	// contains filtered or unexported fields
}

func NewFeatureDetector

func NewFeatureDetector(overrides map[string]string, opts ...Option) *FeatureDetector

func (*FeatureDetector) GetFeatures

func (d *FeatureDetector) GetFeatures() *Features

func (*FeatureDetector) KernelIsAtLeast

func (d *FeatureDetector) KernelIsAtLeast(v string) (bool, error)

KernelIsAtLeast returns whether the predicate is true or not and an error in case it was not able to determine it.

func (*FeatureDetector) RefreshFeatures

func (d *FeatureDetector) RefreshFeatures()

type FeatureDetectorIface

type FeatureDetectorIface interface {
	GetFeatures() *Features
	RefreshFeatures()
}

type Features

type Features struct {
	// SNATFullyRandom is true if --random-fully is supported by the SNAT action.
	SNATFullyRandom bool
	// MASQFullyRandom is true if --random-fully is supported by the MASQUERADE action.
	MASQFullyRandom bool
	// RestoreSupportsLock is true if the iptables-restore command supports taking the xtables lock and the
	// associated -w and -W arguments.
	RestoreSupportsLock bool
	// ChecksumOffloadBroken is true for kernels that have broken checksum offload for packets with SNATted source
	// ports. See https://github.com/dtest11/calico/issues/3145.  On such kernels we disable checksum offload
	// on our VXLAN device.
	ChecksumOffloadBroken bool
	// IPIPDeviceIsL3 represent if ipip tunnels acts like other l3 devices
	IPIPDeviceIsL3 bool
	// KernelSideRouteFiltering is true if the kernel supports filtering netlink route dumps kernel-side.
	// This is much more efficient.
	KernelSideRouteFiltering bool
}

type Option

type Option func(detector *FeatureDetector)

func WithNetlinkOverride

func WithNetlinkOverride(f func() (netlinkshim.Interface, error)) Option

type Version

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

func GetKernelVersion

func GetKernelVersion(reader io.Reader) (*Version, error)

func GetVersionFromString

func GetVersionFromString(s string) (*Version, error)

func MustParseVersion

func MustParseVersion(v string) *Version

func NewVersion

func NewVersion(ver string) (*Version, error)

func (*Version) Compare

func (v *Version) Compare(other *Version) int

func (*Version) String

func (v *Version) String() string

Jump to

Keyboard shortcuts

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