network

package
v0.5.12 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2024 License: MPL-2.0 Imports: 70 Imported by: 0

Documentation

Overview

Package network provides controllers which manage network resources.

Package network provides controllers which manage network resources.

Package network provides controllers which manage network resources.

Package network provides controllers which manage network resources.

Package network provides controllers which manage network resources.

Package network provides controllers which manage network resources.

Package network provides controllers which manage network resources.

Package network provides controllers which manage network resources.

Index

Constants

View Source 
const IngressChainName = "ingress"

IngressChainName is the name of the ingress chain.

Variables

This section is empty.

Functions

func SetBondMaster 

func SetBondMaster(link *network.LinkSpecSpec, bond talosconfig.Bond) error

SetBondMaster sets the bond master spec.

func SetBondSlave 

func SetBondSlave(link *network.LinkSpecSpec, bond ordered.Pair[string, int])

SetBondSlave sets the bond slave spec.

func SetBridgeMaster 

func SetBridgeMaster(link *network.LinkSpecSpec, bridge talosconfig.Bridge) error

SetBridgeMaster sets the bridge master spec.

func SetBridgeSlave 

func SetBridgeSlave(link *network.LinkSpecSpec, bridge string)

SetBridgeSlave sets the bridge slave spec.

func SortBonds 

func SortBonds(items []resource.Resource)

SortBonds sort resources in increasing order, except it places slave interfaces right after the bond in proper order.

Types

type AddressConfigController 

type AddressConfigController struct {
	Cmdline      *procfs.Cmdline
	V1Alpha1Mode runtime.Mode
}

AddressConfigController manages network.AddressSpec based on machine configuration, kernel cmdline and some built-in defaults.

func (*AddressConfigController) Inputs 

func (ctrl *AddressConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*AddressConfigController) Name 

func (ctrl *AddressConfigController) Name() string

Name implements controller.Controller interface.

func (*AddressConfigController) Outputs 

func (ctrl *AddressConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*AddressConfigController) Run 

func (ctrl *AddressConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type AddressEventController 

type AddressEventController struct {
	V1Alpha1Events runtime.Publisher
}

AddressEventController reports aggregated enpoints state from hostname statuses and k8s endpoints to the events stream.

func (*AddressEventController) Inputs 

func (ctrl *AddressEventController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*AddressEventController) Name 

func (ctrl *AddressEventController) Name() string

Name implements controller.Controller interface.

func (*AddressEventController) Outputs 

func (ctrl *AddressEventController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*AddressEventController) Run 

func (ctrl *AddressEventController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type AddressMergeController 

type AddressMergeController struct{}

AddressMergeController merges network.AddressSpec in network.ConfigNamespace and produces final network.AddressSpec in network.Namespace.

func (*AddressMergeController) Inputs 

func (ctrl *AddressMergeController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*AddressMergeController) Name 

func (ctrl *AddressMergeController) Name() string

Name implements controller.Controller interface.

func (*AddressMergeController) Outputs 

func (ctrl *AddressMergeController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*AddressMergeController) Run 

func (ctrl *AddressMergeController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type AddressSpecController 

type AddressSpecController struct{}

AddressSpecController applies network.AddressSpec to the actual interfaces.

func (*AddressSpecController) Inputs 

func (ctrl *AddressSpecController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*AddressSpecController) Name 

func (ctrl *AddressSpecController) Name() string

Name implements controller.Controller interface.

func (*AddressSpecController) Outputs 

func (ctrl *AddressSpecController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*AddressSpecController) Run 

func (ctrl *AddressSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type AddressStatusController 

type AddressStatusController struct{}

AddressStatusController manages secrets.Etcd based on configuration.

func (*AddressStatusController) Inputs 

func (ctrl *AddressStatusController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*AddressStatusController) Name 

func (ctrl *AddressStatusController) Name() string

Name implements controller.Controller interface.

func (*AddressStatusController) Outputs 

func (ctrl *AddressStatusController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*AddressStatusController) Run 

func (ctrl *AddressStatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type CmdlineLinkConfig 

type CmdlineLinkConfig struct {
	LinkName string
	Address  netip.Prefix
	Gateway  netip.Addr
	DHCP     bool
}

CmdlineLinkConfig contains parsed cmdline networking settings for a single link.

type CmdlineNetworking 

type CmdlineNetworking struct {
	LinkConfigs      []CmdlineLinkConfig
	Hostname         string
	DNSAddresses     []netip.Addr
	NTPAddresses     []netip.Addr
	IgnoreInterfaces []string
	NetworkLinkSpecs []network.LinkSpecSpec
}

CmdlineNetworking contains parsed cmdline networking settings.

func ParseCmdlineNetwork 

func ParseCmdlineNetwork(cmdline *procfs.Cmdline) (CmdlineNetworking, error)

ParseCmdlineNetwork parses `ip=` and Talos specific kernel cmdline argument producing all the available configuration options.

type DNSResolveCacheController 

type DNSResolveCacheController struct {
	State  state.State
	Logger *zap.Logger
	// contains filtered or unexported fields
}

DNSResolveCacheController starts dns server on both udp and tcp ports based on finalized network configuration.

func (*DNSResolveCacheController) Inputs 

func (ctrl *DNSResolveCacheController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*DNSResolveCacheController) Name 

func (ctrl *DNSResolveCacheController) Name() string

Name implements controller.Controller interface.

func (*DNSResolveCacheController) Outputs 

func (ctrl *DNSResolveCacheController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*DNSResolveCacheController) Run 

func (ctrl *DNSResolveCacheController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type DNSUpstreamController 

type DNSUpstreamController struct{}

DNSUpstreamController is a controller that manages DNS upstreams.

func (*DNSUpstreamController) Inputs 

func (ctrl *DNSUpstreamController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*DNSUpstreamController) Name 

func (ctrl *DNSUpstreamController) Name() string

Name implements controller.Controller interface.

func (*DNSUpstreamController) Outputs 

func (ctrl *DNSUpstreamController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*DNSUpstreamController) Run 

func (ctrl *DNSUpstreamController) Run(ctx context.Context, r controller.Runtime, l *zap.Logger) error

Run implements controller.Controller interface.

type DeviceConfigController 

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

DeviceConfigController manages network.DeviceConfig based on configuration.

func (*DeviceConfigController) Inputs 

func (ctrl *DeviceConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*DeviceConfigController) Name 

func (ctrl *DeviceConfigController) Name() string

Name implements controller.Controller interface.

func (*DeviceConfigController) Outputs 

func (ctrl *DeviceConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*DeviceConfigController) Run 

func (ctrl *DeviceConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type EtcFileController 

type EtcFileController struct {
	PodResolvConfPath string
	V1Alpha1Mode      runtime.Mode
}

EtcFileController creates /etc/hostname and /etc/resolv.conf files based on finalized network configuration.

func (*EtcFileController) Inputs 

func (ctrl *EtcFileController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*EtcFileController) Name 

func (ctrl *EtcFileController) Name() string

Name implements controller.Controller interface.

func (*EtcFileController) Outputs 

func (ctrl *EtcFileController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*EtcFileController) Run 

func (ctrl *EtcFileController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type HardwareAddrController 

type HardwareAddrController struct{}

HardwareAddrController manages secrets.Etcd based on configuration.

func (*HardwareAddrController) Inputs 

func (ctrl *HardwareAddrController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*HardwareAddrController) Name 

func (ctrl *HardwareAddrController) Name() string

Name implements controller.Controller interface.

func (*HardwareAddrController) Outputs 

func (ctrl *HardwareAddrController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*HardwareAddrController) Run 

func (ctrl *HardwareAddrController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type HostDNSConfigController 

type HostDNSConfigController struct {
	Cmdline *procfs.Cmdline
}

HostDNSConfigController manages network.HostDNSConfig based on machine configuration.

func (*HostDNSConfigController) Inputs 

func (ctrl *HostDNSConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*HostDNSConfigController) Name 

func (ctrl *HostDNSConfigController) Name() string

Name implements controller.Controller interface.

func (*HostDNSConfigController) Outputs 

func (ctrl *HostDNSConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*HostDNSConfigController) Run 

func (ctrl *HostDNSConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type HostnameConfigController 

type HostnameConfigController struct {
	Cmdline *procfs.Cmdline
}

HostnameConfigController manages network.HostnameSpec based on machine configuration, kernel cmdline.

func (*HostnameConfigController) Inputs 

func (ctrl *HostnameConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*HostnameConfigController) Name 

func (ctrl *HostnameConfigController) Name() string

Name implements controller.Controller interface.

func (*HostnameConfigController) Outputs 

func (ctrl *HostnameConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*HostnameConfigController) Run 

func (ctrl *HostnameConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type HostnameMergeController 

type HostnameMergeController struct{}

HostnameMergeController merges network.HostnameSpec in network.ConfigNamespace and produces final network.HostnameSpec in network.Namespace.

func (*HostnameMergeController) Inputs 

func (ctrl *HostnameMergeController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*HostnameMergeController) Name 

func (ctrl *HostnameMergeController) Name() string

Name implements controller.Controller interface.

func (*HostnameMergeController) Outputs 

func (ctrl *HostnameMergeController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*HostnameMergeController) Run 

func (ctrl *HostnameMergeController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type HostnameSpecController 

type HostnameSpecController struct {
	V1Alpha1Mode v1alpha1runtime.Mode
}

HostnameSpecController applies network.HostnameSpec to the actual interfaces.

func (*HostnameSpecController) Inputs 

func (ctrl *HostnameSpecController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*HostnameSpecController) Name 

func (ctrl *HostnameSpecController) Name() string

Name implements controller.Controller interface.

func (*HostnameSpecController) Outputs 

func (ctrl *HostnameSpecController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*HostnameSpecController) Run 

func (ctrl *HostnameSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type LinkConfigController 

type LinkConfigController struct {
	Cmdline *procfs.Cmdline
}

LinkConfigController manages network.LinkSpec based on machine configuration, kernel cmdline.

func (*LinkConfigController) Inputs 

func (ctrl *LinkConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*LinkConfigController) Name 

func (ctrl *LinkConfigController) Name() string

Name implements controller.Controller interface.

func (*LinkConfigController) Outputs 

func (ctrl *LinkConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*LinkConfigController) Run 

func (ctrl *LinkConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type LinkMergeController 

type LinkMergeController struct{}

LinkMergeController merges network.LinkSpec in network.ConfigNamespace and produces final network.LinkSpec in network.Namespace.

func (*LinkMergeController) Inputs 

func (ctrl *LinkMergeController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*LinkMergeController) Name 

func (ctrl *LinkMergeController) Name() string

Name implements controller.Controller interface.

func (*LinkMergeController) Outputs 

func (ctrl *LinkMergeController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*LinkMergeController) Run 

func (ctrl *LinkMergeController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type LinkSpecController 

type LinkSpecController struct{}

LinkSpecController applies network.LinkSpec to the actual interfaces.

func (*LinkSpecController) Inputs 

func (ctrl *LinkSpecController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*LinkSpecController) Name 

func (ctrl *LinkSpecController) Name() string

Name implements controller.Controller interface.

func (*LinkSpecController) Outputs 

func (ctrl *LinkSpecController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*LinkSpecController) Run 

func (ctrl *LinkSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type LinkStatusController 

type LinkStatusController struct{}

LinkStatusController manages secrets.Etcd based on configuration.

func (*LinkStatusController) Inputs 

func (ctrl *LinkStatusController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*LinkStatusController) Name 

func (ctrl *LinkStatusController) Name() string

Name implements controller.Controller interface.

func (*LinkStatusController) Outputs 

func (ctrl *LinkStatusController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*LinkStatusController) Run 

func (ctrl *LinkStatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type NfTablesChainConfigController 

type NfTablesChainConfigController struct{}

NfTablesChainConfigController generates nftables rules based on machine configuration.

func (*NfTablesChainConfigController) Inputs 

func (ctrl *NfTablesChainConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*NfTablesChainConfigController) Name 

func (ctrl *NfTablesChainConfigController) Name() string

Name implements controller.Controller interface.

func (*NfTablesChainConfigController) Outputs 

func (ctrl *NfTablesChainConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*NfTablesChainConfigController) Run 

func (ctrl *NfTablesChainConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) (err error)

Run implements controller.Controller interface.

type NfTablesChainController 

type NfTablesChainController struct {
	TableName string
}

NfTablesChainController applies network.NfTablesChain to the Linux nftables interface.

func (*NfTablesChainController) Inputs 

func (ctrl *NfTablesChainController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*NfTablesChainController) Name 

func (ctrl *NfTablesChainController) Name() string

Name implements controller.Controller interface.

func (*NfTablesChainController) Outputs 

func (ctrl *NfTablesChainController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*NfTablesChainController) Run 

func (ctrl *NfTablesChainController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type NodeAddressController 

type NodeAddressController struct{}

NodeAddressController manages secrets.Etcd based on configuration.

func (*NodeAddressController) Inputs 

func (ctrl *NodeAddressController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*NodeAddressController) Name 

func (ctrl *NodeAddressController) Name() string

Name implements controller.Controller interface.

func (*NodeAddressController) Outputs 

func (ctrl *NodeAddressController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*NodeAddressController) Run 

func (ctrl *NodeAddressController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type OperatorConfigController 

type OperatorConfigController struct {
	Cmdline *procfs.Cmdline
}

OperatorConfigController manages network.OperatorSpec based on machine configuration, kernel cmdline.

func (*OperatorConfigController) Inputs 

func (ctrl *OperatorConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*OperatorConfigController) Name 

func (ctrl *OperatorConfigController) Name() string

Name implements controller.Controller interface.

func (*OperatorConfigController) Outputs 

func (ctrl *OperatorConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*OperatorConfigController) Run 

func (ctrl *OperatorConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type OperatorFactory 

type OperatorFactory func(*zap.Logger, *network.OperatorSpecSpec) operator.Operator

OperatorFactory creates operator based on the spec.

type OperatorMergeController 

type OperatorMergeController struct{}

OperatorMergeController merges network.OperatorSpec in network.ConfigNamespace and produces final network.OperatorSpec in network.Namespace.

func (*OperatorMergeController) Inputs 

func (ctrl *OperatorMergeController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*OperatorMergeController) Name 

func (ctrl *OperatorMergeController) Name() string

Name implements controller.Controller interface.

func (*OperatorMergeController) Outputs 

func (ctrl *OperatorMergeController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*OperatorMergeController) Run 

func (ctrl *OperatorMergeController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type OperatorSpecController 

type OperatorSpecController struct {
	V1alpha1Platform v1alpha1runtime.Platform
	State            state.State

	// Factory can be overridden for unit-testing.
	Factory OperatorFactory
	// contains filtered or unexported fields
}

OperatorSpecController applies network.OperatorSpec to the actual interfaces.

func (*OperatorSpecController) Inputs 

func (ctrl *OperatorSpecController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*OperatorSpecController) Name 

func (ctrl *OperatorSpecController) Name() string

Name implements controller.Controller interface.

func (*OperatorSpecController) Outputs 

func (ctrl *OperatorSpecController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*OperatorSpecController) Run 

func (ctrl *OperatorSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type OperatorVIPConfigController 

type OperatorVIPConfigController struct {
	Cmdline *procfs.Cmdline
}

OperatorVIPConfigController manages network.OperatorSpec for virtual IPs based on machine configuration.

func (*OperatorVIPConfigController) Inputs 

func (ctrl *OperatorVIPConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*OperatorVIPConfigController) Name 

func (ctrl *OperatorVIPConfigController) Name() string

Name implements controller.Controller interface.

func (*OperatorVIPConfigController) Outputs 

func (ctrl *OperatorVIPConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*OperatorVIPConfigController) Run 

func (ctrl *OperatorVIPConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type PlatformConfigController 

type PlatformConfigController struct {
	V1alpha1Platform v1alpha1runtime.Platform
	PlatformState    state.State
	StatePath        string
}

PlatformConfigController manages updates hostnames and addressstatuses based on platform information.

func (*PlatformConfigController) Inputs 

func (ctrl *PlatformConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*PlatformConfigController) Name 

func (ctrl *PlatformConfigController) Name() string

Name implements controller.Controller interface.

func (*PlatformConfigController) Outputs 

func (ctrl *PlatformConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*PlatformConfigController) Run 

func (ctrl *PlatformConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type ProbeController 

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

ProbeController runs network probes configured with ProbeSpecs and outputs ProbeStatuses.

func (*ProbeController) Inputs 

func (ctrl *ProbeController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*ProbeController) Name 

func (ctrl *ProbeController) Name() string

Name implements controller.Controller interface.

func (*ProbeController) Outputs 

func (ctrl *ProbeController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*ProbeController) Run 

func (ctrl *ProbeController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type ResolverConfigController 

type ResolverConfigController struct {
	Cmdline *procfs.Cmdline
}

ResolverConfigController manages network.ResolverSpec based on machine configuration, kernel cmdline.

func (*ResolverConfigController) Inputs 

func (ctrl *ResolverConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*ResolverConfigController) Name 

func (ctrl *ResolverConfigController) Name() string

Name implements controller.Controller interface.

func (*ResolverConfigController) Outputs 

func (ctrl *ResolverConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*ResolverConfigController) Run 

func (ctrl *ResolverConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type ResolverMergeController 

type ResolverMergeController struct{}

ResolverMergeController merges network.ResolverSpec in network.ConfigNamespace and produces final network.ResolverSpec in network.Namespace.

func (*ResolverMergeController) Inputs 

func (ctrl *ResolverMergeController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*ResolverMergeController) Name 

func (ctrl *ResolverMergeController) Name() string

Name implements controller.Controller interface.

func (*ResolverMergeController) Outputs 

func (ctrl *ResolverMergeController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*ResolverMergeController) Run 

func (ctrl *ResolverMergeController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type ResolverSpecController 

type ResolverSpecController struct{}

ResolverSpecController applies network.ResolverSpec to the actual interfaces.

func (*ResolverSpecController) Inputs 

func (ctrl *ResolverSpecController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*ResolverSpecController) Name 

func (ctrl *ResolverSpecController) Name() string

Name implements controller.Controller interface.

func (*ResolverSpecController) Outputs 

func (ctrl *ResolverSpecController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*ResolverSpecController) Run 

func (ctrl *ResolverSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type RouteConfigController 

type RouteConfigController struct {
	Cmdline *procfs.Cmdline
}

RouteConfigController manages network.RouteSpec based on machine configuration, kernel cmdline.

func (*RouteConfigController) Inputs 

func (ctrl *RouteConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*RouteConfigController) Name 

func (ctrl *RouteConfigController) Name() string

Name implements controller.Controller interface.

func (*RouteConfigController) Outputs 

func (ctrl *RouteConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*RouteConfigController) Run 

func (ctrl *RouteConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type RouteMergeController 

type RouteMergeController struct{}

RouteMergeController merges network.RouteSpec in network.ConfigNamespace and produces final network.RouteSpec in network.Namespace.

func (*RouteMergeController) Inputs 

func (ctrl *RouteMergeController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*RouteMergeController) Name 

func (ctrl *RouteMergeController) Name() string

Name implements controller.Controller interface.

func (*RouteMergeController) Outputs 

func (ctrl *RouteMergeController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*RouteMergeController) Run 

func (ctrl *RouteMergeController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type RouteSpecController 

type RouteSpecController struct{}

RouteSpecController applies network.RouteSpec to the actual interfaces.

func (*RouteSpecController) Inputs 

func (ctrl *RouteSpecController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*RouteSpecController) Name 

func (ctrl *RouteSpecController) Name() string

Name implements controller.Controller interface.

func (*RouteSpecController) Outputs 

func (ctrl *RouteSpecController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*RouteSpecController) Run 

func (ctrl *RouteSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type RouteStatusController 

type RouteStatusController struct{}

RouteStatusController manages secrets.Etcd based on configuration.

func (*RouteStatusController) Inputs 

func (ctrl *RouteStatusController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*RouteStatusController) Name 

func (ctrl *RouteStatusController) Name() string

Name implements controller.Controller interface.

func (*RouteStatusController) Outputs 

func (ctrl *RouteStatusController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*RouteStatusController) Run 

func (ctrl *RouteStatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type StatusController 

type StatusController struct {
	V1Alpha1Mode runtime.Mode
}

StatusController manages network.Status based on state of other resources.

func (*StatusController) Inputs 

func (ctrl *StatusController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*StatusController) Name 

func (ctrl *StatusController) Name() string

Name implements controller.Controller interface.

func (*StatusController) Outputs 

func (ctrl *StatusController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*StatusController) Run 

func (ctrl *StatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type TimeServerConfigController 

type TimeServerConfigController struct {
	Cmdline *procfs.Cmdline
}

TimeServerConfigController manages network.TimeServerSpec based on machine configuration, kernel cmdline.

func (*TimeServerConfigController) Inputs 

func (ctrl *TimeServerConfigController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*TimeServerConfigController) Name 

func (ctrl *TimeServerConfigController) Name() string

Name implements controller.Controller interface.

func (*TimeServerConfigController) Outputs 

func (ctrl *TimeServerConfigController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*TimeServerConfigController) Run 

func (ctrl *TimeServerConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type TimeServerMergeController 

type TimeServerMergeController struct{}

TimeServerMergeController merges network.TimeServerSpec in network.ConfigNamespace and produces final network.TimeServerSpec in network.Namespace.

func (*TimeServerMergeController) Inputs 

func (ctrl *TimeServerMergeController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*TimeServerMergeController) Name 

func (ctrl *TimeServerMergeController) Name() string

Name implements controller.Controller interface.

func (*TimeServerMergeController) Outputs 

func (ctrl *TimeServerMergeController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*TimeServerMergeController) Run 

func (ctrl *TimeServerMergeController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type TimeServerSpecController 

type TimeServerSpecController struct{}

TimeServerSpecController applies network.TimeServerSpec to the actual interfaces.

func (*TimeServerSpecController) Inputs 

func (ctrl *TimeServerSpecController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*TimeServerSpecController) Name 

func (ctrl *TimeServerSpecController) Name() string

Name implements controller.Controller interface.

func (*TimeServerSpecController) Outputs 

func (ctrl *TimeServerSpecController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*TimeServerSpecController) Run 

func (ctrl *TimeServerSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

Source Files

View all Source files

Directories

Path Synopsis
internal
probe
Package probe contains implementation of the network probe runners.
 Package probe contains implementation of the network probe runners.
Package operator implements network operators.
 Package operator implements network operators.
vip
Package vip contains implementations of specific methods to acquire/release virtual IPs.
 Package vip contains implementations of specific methods to acquire/release virtual IPs.
Package networkutils provides utilities for controllers to interact with network resources.
 Package networkutils provides utilities for controllers to interact with network resources.
Package watch provides netlink watchers via multicast groups.
 Package watch provides netlink watchers via multicast groups.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.