ifacemonitor

package

v0.0.0-...-21cfbab Latest Latest Go to latest Published: Apr 10, 2023 License: Apache-2.0, Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dtest11/calico

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func FilterUpdates(ctx context.Context, routeOutC chan<- netlink.RouteUpdate, ...)
func IsInterfacePresent(name string) bool
type AddrStateCallback
type Config
type InSyncCallback
type InterfaceMonitor
- func New(config Config, featureDetector environment.FeatureDetectorIface, ...) *InterfaceMonitor
- func NewWithStubs(config Config, netlinkStub netlinkStub, resyncC <-chan time.Time, ...) *InterfaceMonitor
- func (m *InterfaceMonitor) MonitorInterfaces()
type InterfaceStateCallback
type State
type UpdateFilterOp
- func WithTimeShim(t timeshim.Interface) UpdateFilterOp

Constants ¶

View Source

const FlapDampingDelay = 100 * time.Millisecond

Variables ¶

This section is empty.

Functions ¶

func FilterUpdates ¶

func FilterUpdates(ctx context.Context,
	routeOutC chan<- netlink.RouteUpdate, routeInC <-chan netlink.RouteUpdate,
	linkOutC chan<- netlink.LinkUpdate, linkInC <-chan netlink.LinkUpdate,
	options ...UpdateFilterOp,
)

FilterUpdates filters out updates that occur when IPs are quickly removed and re-added. Some DHCP clients flap the IP during an IP renewal, for example.

Algorithm: * Maintain a queue of link and address updates per interface. * When we see a potential flap (i.e. an IP deletion), defer processing the queue for a while. * If the flap resolves itself (i.e. the IP is added back), suppress the IP deletion.

func IsInterfacePresent ¶

func IsInterfacePresent(name string) bool

Types ¶

type AddrStateCallback ¶

type AddrStateCallback func(ifaceName string, addrs set.Set[string])

type Config ¶

type Config struct {
	// InterfaceExcludes is a list of interface names that we don't want callbacks for.
	InterfaceExcludes []*regexp.Regexp
	// ResyncInterval is the interval at which we rescan all the interfaces.  If <0 rescan is disabled.
	ResyncInterval time.Duration
	NetlinkTimeout time.Duration
}

type InSyncCallback ¶

type InSyncCallback func()

type InterfaceMonitor ¶

type InterfaceMonitor struct {
	Config

	StateCallback  InterfaceStateCallback
	AddrCallback   AddrStateCallback
	InSyncCallback InSyncCallback
	// contains filtered or unexported fields
}

func New ¶

func New(config Config,
	featureDetector environment.FeatureDetectorIface,
	fatalErrCallback func(error),
) *InterfaceMonitor

func NewWithStubs ¶

func NewWithStubs(config Config, netlinkStub netlinkStub, resyncC <-chan time.Time, fatalErrCallback func(error)) *InterfaceMonitor

func (*InterfaceMonitor) MonitorInterfaces ¶

func (m *InterfaceMonitor) MonitorInterfaces()

type InterfaceStateCallback ¶

type InterfaceStateCallback func(ifaceName string, ifaceState State, ifIndex int)

type State ¶

type State string

const (
	StateNotPresent State = ""
	StateUp         State = "up"
	StateDown       State = "down"
)

type UpdateFilterOp ¶

type UpdateFilterOp func(filter *updateFilter)

func WithTimeShim ¶

func WithTimeShim(t timeshim.Interface) UpdateFilterOp

Source Files ¶

View all Source files

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