types

package
v1.16.7 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	IPv4InternalAddress = tables.TestIPv4InternalAddress.AsSlice()
	IPv4NodePortAddress = tables.TestIPv4NodePortAddress.AsSlice()

	IPv6InternalAddress = tables.TestIPv6InternalAddress.AsSlice()
	IPv6NodePortAddress = tables.TestIPv6NodePortAddress.AsSlice()
)

Functions

func NewIPv4OnlyNodeAddressing added in v1.16.0 

func NewIPv4OnlyNodeAddressing() types.NodeAddressing

NewIPv4OnlyNodeAddressing returns a new fake node addressing where IPv6 is disabled

func NewIPv6OnlyNodeAddressing added in v1.16.0 

func NewIPv6OnlyNodeAddressing() types.NodeAddressing

NewIPv6OnlyNodeAddressing returns a new fake node addressing where IPv4 is disabled

func NewNodeAddressing added in v1.16.0 

func NewNodeAddressing() types.NodeAddressing

NewNodeAddressing returns a new fake node addressing

Types

type BandwidthManager added in v1.16.0 

type BandwidthManager struct{}

func (*BandwidthManager) BBREnabled added in v1.16.0 

func (fbm *BandwidthManager) BBREnabled() bool

func (*BandwidthManager) DeleteBandwidthLimit added in v1.16.0 

func (fbm *BandwidthManager) DeleteBandwidthLimit(endpointID uint16)

func (*BandwidthManager) DeleteEndpointBandwidthLimit added in v1.16.0 

func (fbm *BandwidthManager) DeleteEndpointBandwidthLimit(epID uint16) error

func (*BandwidthManager) Enabled added in v1.16.0 

func (fbm *BandwidthManager) Enabled() bool

func (*BandwidthManager) ResetQueues added in v1.16.0 

func (fbm *BandwidthManager) ResetQueues() bool

func (*BandwidthManager) UpdateBandwidthLimit added in v1.16.0 

func (fbm *BandwidthManager) UpdateBandwidthLimit(endpointID uint16, bytesPerSecond uint64)

type BigTCPUserConfig 

type BigTCPUserConfig struct {
	// EnableIPv6BIGTCP enables IPv6 BIG TCP (larger GSO/GRO limits) for the node including pods.
	EnableIPv6BIGTCP bool

	// EnableIPv4BIGTCP enables IPv4 BIG TCP (larger GSO/GRO limits) for the node including pods.
	EnableIPv4BIGTCP bool
}

BigTCPUserConfig are the configuration flags that the user can modify.

func (BigTCPUserConfig) IsIPv4Enabled 

func (def BigTCPUserConfig) IsIPv4Enabled() bool

func (BigTCPUserConfig) IsIPv6Enabled 

func (def BigTCPUserConfig) IsIPv6Enabled() bool

type FakeDatapath added in v1.16.0 

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

func NewDatapath added in v1.16.0 

func NewDatapath() *FakeDatapath

NewDatapath returns a new fake datapath

func NewDatapathWithNodeAddressing added in v1.16.0 

func NewDatapathWithNodeAddressing(na datapath.NodeAddressing) *FakeDatapath

func (*FakeDatapath) BandwidthManager added in v1.16.0 

func (f *FakeDatapath) BandwidthManager() datapath.BandwidthManager

func (*FakeDatapath) FakeNode added in v1.16.0 

func (f *FakeDatapath) FakeNode() *FakeNodeHandler

func (*FakeDatapath) GetProxyPorts added in v1.16.0 

func (m *FakeDatapath) GetProxyPorts() map[string]uint16

func (*FakeDatapath) InstallNoTrackRules added in v1.16.0 

func (m *FakeDatapath) InstallNoTrackRules(ip netip.Addr, port uint16)

func (*FakeDatapath) InstallProxyRules added in v1.16.0 

func (f *FakeDatapath) InstallProxyRules(uint16, string)

func (*FakeDatapath) LBMap added in v1.16.0 

func (f *FakeDatapath) LBMap() datapath.LBMap

func (*FakeDatapath) LBMockMap added in v1.16.0 

func (f *FakeDatapath) LBMockMap() *mockmaps.LBMockMap

func (*FakeDatapath) Loader added in v1.16.0 

func (f *FakeDatapath) Loader() datapath.Loader

func (*FakeDatapath) LocalNodeAddressing added in v1.16.0 

func (f *FakeDatapath) LocalNodeAddressing() datapath.NodeAddressing

LocalNodeAddressing returns a fake node addressing implementation of the local node

func (*FakeDatapath) Node added in v1.16.0 

func (f *FakeDatapath) Node() datapath.NodeHandler

Node returns a fake handler for node events

func (*FakeDatapath) NodeIDs added in v1.16.0 

func (f *FakeDatapath) NodeIDs() datapath.NodeIDHandler

func (*FakeDatapath) NodeNeighbors added in v1.16.0 

func (f *FakeDatapath) NodeNeighbors() datapath.NodeNeighbors

func (*FakeDatapath) Orchestrator added in v1.16.0 

func (f *FakeDatapath) Orchestrator() datapath.Orchestrator

func (*FakeDatapath) RemoveNoTrackRules added in v1.16.0 

func (m *FakeDatapath) RemoveNoTrackRules(ip netip.Addr, port uint16)

func (*FakeDatapath) SupportsOriginalSourceAddr added in v1.16.0 

func (f *FakeDatapath) SupportsOriginalSourceAddr() bool

func (*FakeDatapath) WireguardAgent added in v1.16.0 

func (f *FakeDatapath) WireguardAgent() datapath.WireguardAgent

func (*FakeDatapath) WriteEndpointConfig added in v1.16.0 

func (f *FakeDatapath) WriteEndpointConfig(io.Writer, *datapath.LocalNodeConfiguration, datapath.EndpointConfiguration) error

WriteEndpointConfig pretends to write the endpoint configuration to a writer.

func (*FakeDatapath) WriteNetdevConfig added in v1.16.0 

func (f *FakeDatapath) WriteNetdevConfig(io.Writer, *option.IntOptions) error

WriteNetdevConfig pretends to write the netdev configuration to a writer.

func (*FakeDatapath) WriteNodeConfig added in v1.16.0 

func (f *FakeDatapath) WriteNodeConfig(io.Writer, *datapath.LocalNodeConfiguration) error

WriteNodeConfig pretends to write the datapath configuration to the writer.

func (*FakeDatapath) WriteTemplateConfig added in v1.16.0 

func (f *FakeDatapath) WriteTemplateConfig(io.Writer, *datapath.LocalNodeConfiguration, datapath.EndpointConfiguration) error

WriteTemplateConfig pretends to write the endpoint configuration to a writer.

type FakeLoader added in v1.16.0 

type FakeLoader struct {
}

Loader is an interface to abstract out loading of datapath programs.

func (*FakeLoader) CallsMapPath added in v1.16.0 

func (f *FakeLoader) CallsMapPath(id uint16) string

func (*FakeLoader) CompileOrLoad added in v1.16.0 

func (f *FakeLoader) CompileOrLoad(ctx context.Context, ep datapath.Endpoint, stats *metrics.SpanStat) error

func (*FakeLoader) CustomCallsMapPath added in v1.16.0 

func (f *FakeLoader) CustomCallsMapPath(id uint16) string

func (*FakeLoader) DetachXDP added in v1.16.0 

func (f *FakeLoader) DetachXDP(ifaceName string, bpffsBase, progName string) error

func (*FakeLoader) EndpointHash added in v1.16.0 

func (f *FakeLoader) EndpointHash(cfg datapath.EndpointConfiguration) (string, error)

func (*FakeLoader) HostDatapathInitialized added in v1.16.0 

func (f *FakeLoader) HostDatapathInitialized() <-chan struct{}

func (*FakeLoader) Reinitialize added in v1.16.0 

func (f *FakeLoader) Reinitialize(ctx context.Context, cfg datapath.LocalNodeConfiguration, tunnelConfig tunnel.Config, iptMgr datapath.IptablesManager, p datapath.Proxy) error

Reinitialize does nothing.

func (*FakeLoader) ReinitializeXDP added in v1.16.0 

func (f *FakeLoader) ReinitializeXDP(ctx context.Context, extraCArgs []string) error

func (*FakeLoader) ReloadDatapath added in v1.16.0 

func (f *FakeLoader) ReloadDatapath(ctx context.Context, ep datapath.Endpoint, stats *metrics.SpanStat) (string, error)

func (*FakeLoader) Unload added in v1.16.0 

func (f *FakeLoader) Unload(ep datapath.Endpoint)

func (*FakeLoader) WriteEndpointConfig added in v1.16.0 

func (f *FakeLoader) WriteEndpointConfig(w io.Writer, e datapath.EndpointConfiguration) error

type FakeNodeHandler added in v1.16.0 

type FakeNodeHandler struct {
	Nodes map[string]nodeTypes.Node
	// contains filtered or unexported fields
}

func NewNodeHandler added in v1.16.0 

func NewNodeHandler() *FakeNodeHandler

NewNodeHandler returns a fake NodeHandler that stores the nodes, but performs no other actions.

func (*FakeNodeHandler) AllNodeValidateImplementation added in v1.16.0 

func (n *FakeNodeHandler) AllNodeValidateImplementation()

func (*FakeNodeHandler) DeleteMiscNeighbor added in v1.16.0 

func (n *FakeNodeHandler) DeleteMiscNeighbor(oldNode *nodeTypes.Node)

func (*FakeNodeHandler) DumpNodeIDs added in v1.16.0 

func (n *FakeNodeHandler) DumpNodeIDs() []*models.NodeID

func (*FakeNodeHandler) GetNodeID added in v1.16.0 

func (n *FakeNodeHandler) GetNodeID(_ net.IP) (uint16, bool)

func (*FakeNodeHandler) GetNodeIP added in v1.16.0 

func (n *FakeNodeHandler) GetNodeIP(_ uint16) string

func (*FakeNodeHandler) InsertMiscNeighbor added in v1.16.0 

func (n *FakeNodeHandler) InsertMiscNeighbor(newNode *nodeTypes.Node)

func (*FakeNodeHandler) Name added in v1.16.0 

func (n *FakeNodeHandler) Name() string

func (*FakeNodeHandler) NodeAdd added in v1.16.0 

func (n *FakeNodeHandler) NodeAdd(newNode nodeTypes.Node) error

func (*FakeNodeHandler) NodeCleanNeighbors added in v1.16.0 

func (n *FakeNodeHandler) NodeCleanNeighbors(migrateOnly bool)

func (*FakeNodeHandler) NodeConfigurationChanged added in v1.16.0 

func (n *FakeNodeHandler) NodeConfigurationChanged(config datapath.LocalNodeConfiguration) error

func (*FakeNodeHandler) NodeDelete added in v1.16.0 

func (n *FakeNodeHandler) NodeDelete(node nodeTypes.Node) error

func (*FakeNodeHandler) NodeNeighDiscoveryEnabled added in v1.16.0 

func (n *FakeNodeHandler) NodeNeighDiscoveryEnabled() bool

func (*FakeNodeHandler) NodeNeighborRefresh added in v1.16.0 

func (n *FakeNodeHandler) NodeNeighborRefresh(ctx context.Context, node nodeTypes.Node, refresh bool) error

func (*FakeNodeHandler) NodeUpdate added in v1.16.0 

func (n *FakeNodeHandler) NodeUpdate(oldNode, newNode nodeTypes.Node) error

func (*FakeNodeHandler) NodeValidateImplementation added in v1.16.0 

func (n *FakeNodeHandler) NodeValidateImplementation(node nodeTypes.Node) error

func (*FakeNodeHandler) RestoreNodeIDs added in v1.16.0 

func (n *FakeNodeHandler) RestoreNodeIDs()

type FakeOrchestrator added in v1.16.0 

type FakeOrchestrator struct{}

func (*FakeOrchestrator) Reinitialize added in v1.16.0 

func (f *FakeOrchestrator) Reinitialize(ctx context.Context) error

type GarpConfig 

type GarpConfig struct {
	EnableL2PodAnnouncements bool
}

GarpConfig contains the configuration for the GARP cell.

func (GarpConfig) Enabled 

func (def GarpConfig) Enabled() bool

type IPSet added in v1.16.0 

type IPSet struct{}

func (*IPSet) AddToIPSet added in v1.16.0 

func (f *IPSet) AddToIPSet(_ string, _ ipset.Family, _ ...netip.Addr)

func (*IPSet) NewInitializer added in v1.16.0 

func (f *IPSet) NewInitializer() ipset.Initializer

func (*IPSet) RemoveFromIPSet added in v1.16.0 

func (f *IPSet) RemoveFromIPSet(name string, addrs ...netip.Addr)

type L2PodAnnouncementConfig 

type L2PodAnnouncementConfig interface {
	Enabled() bool
}

type MTU added in v1.16.0 

type MTU struct{}

func (*MTU) GetDeviceMTU added in v1.16.0 

func (*MTU) GetDeviceMTU() int

GetDeviceMTU implements mtu.MTU.

func (*MTU) GetRouteMTU added in v1.16.0 

func (*MTU) GetRouteMTU() int

GetRouteMTU implements mtu.MTU.

func (*MTU) GetRoutePostEncryptMTU added in v1.16.0 

func (*MTU) GetRoutePostEncryptMTU() int

GetRoutePostEncryptMTU implements mtu.MTU.

func (*MTU) IsEnableRouteMTUForCNIChaining added in v1.16.0 

func (*MTU) IsEnableRouteMTUForCNIChaining() bool

Source Files

View all Source files

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.