types

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2026 License: Apache-2.0 Imports: 15 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) DeleteIngressBandwidthLimit added in v1.18.0 

func (fbm *BandwidthManager) DeleteIngressBandwidthLimit(endpointID uint16)

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, prio uint32)

func (*BandwidthManager) UpdateIngressBandwidthLimit added in v1.18.0 

func (fbm *BandwidthManager) UpdateIngressBandwidthLimit(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

	// EnableTunnelBIGTCP enables BIG TCP (larger GSO/GRO limits) in tunneling mode for VXLAN and GENEVE tunnels.
	EnableTunnelBIGTCP 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

func (BigTCPUserConfig) IsTunnelEnabled added in v1.19.0 

func (def BigTCPUserConfig) IsTunnelEnabled() bool

type FakeIptablesManager added in v1.17.0 

type FakeIptablesManager struct {
}

func NewIptablesManager added in v1.17.0 

func NewIptablesManager() *FakeIptablesManager

NewIptablesManager returns a new fake IptablesManager

func (*FakeIptablesManager) AddNoTrackHostPorts added in v1.19.0 

func (m *FakeIptablesManager) AddNoTrackHostPorts(namespace, name string, ports []string)

func (*FakeIptablesManager) GetProxyPorts added in v1.17.0 

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

func (*FakeIptablesManager) InstallNoTrackRules added in v1.17.0 

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

func (*FakeIptablesManager) InstallProxyRules added in v1.17.0 

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

func (*FakeIptablesManager) RemoveNoTrackHostPorts added in v1.19.0 

func (m *FakeIptablesManager) RemoveNoTrackHostPorts(namespace, name string)

func (*FakeIptablesManager) RemoveNoTrackRules added in v1.17.0 

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

func (*FakeIptablesManager) SupportsOriginalSourceAddr added in v1.17.0 

func (f *FakeIptablesManager) SupportsOriginalSourceAddr() bool

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) 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, _ *datapath.LocalNodeConfiguration) (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, lnc *datapath.LocalNodeConfiguration, tunnelConfig tunnel.Config, iptMgr datapath.IptablesManager, p datapath.Proxy, bigtcp datapath.BigTCPConfiguration) error

Reinitialize does nothing.

func (*FakeLoader) ReinitializeHostDev added in v1.17.0 

func (f *FakeLoader) ReinitializeHostDev(ctx context.Context, mtu int) error

func (*FakeLoader) ReloadDatapath added in v1.16.0 

func (f *FakeLoader) ReloadDatapath(ctx context.Context, ep datapath.Endpoint, lnc *datapath.LocalNodeConfiguration, 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, lnc *datapath.LocalNodeConfiguration) 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) 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) 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) NodeDelete added in v1.16.0 

func (n *FakeNodeHandler) NodeDelete(node nodeTypes.Node) 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) DatapathInitialized added in v1.17.3 

func (f *FakeOrchestrator) DatapathInitialized() <-chan struct{}

func (*FakeOrchestrator) EndpointHash added in v1.17.0 

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

func (*FakeOrchestrator) Reinitialize added in v1.16.0 

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

func (*FakeOrchestrator) ReloadDatapath added in v1.17.0 

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

func (*FakeOrchestrator) Unload added in v1.17.0 

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

func (*FakeOrchestrator) WriteEndpointConfig added in v1.17.0 

func (f *FakeOrchestrator) WriteEndpointConfig(w io.Writer, cfg datapath.EndpointConfiguration) error

type GNeighConfig added in v1.19.0 

type GNeighConfig struct {
	EnableL2PodAnnouncements bool
}

GNeighConfig contains the configuration for the GARP cell.

func (GNeighConfig) Enabled added in v1.19.0 

func (def GNeighConfig) 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 IPsecAgent added in v1.19.0 

type IPsecAgent struct {
	EnableIPsec bool
}

func (*IPsecAgent) AuthKeySize added in v1.19.0 

func (*IPsecAgent) AuthKeySize() int

func (*IPsecAgent) DeleteIPsecEndpoint added in v1.19.0 

func (a *IPsecAgent) DeleteIPsecEndpoint(nodeID uint16) error

func (*IPsecAgent) DeleteXFRM added in v1.19.0 

func (a *IPsecAgent) DeleteXFRM(reqID int) error

func (*IPsecAgent) DeleteXfrmPolicyOut added in v1.19.0 

func (a *IPsecAgent) DeleteXfrmPolicyOut(nodeID uint16, dst *net.IPNet) error

func (*IPsecAgent) Enabled added in v1.19.0 

func (a *IPsecAgent) Enabled() bool

func (*IPsecAgent) SPI added in v1.19.0 

func (*IPsecAgent) SPI() uint8

func (*IPsecAgent) StartBackgroundJobs added in v1.19.0 

func (*IPsecAgent) StartBackgroundJobs(types.NodeHandler) error

func (*IPsecAgent) UpsertIPsecEndpoint added in v1.19.0 

func (a *IPsecAgent) UpsertIPsecEndpoint(params *types.IPSecParameters) (uint8, error)

type IPsecConfig added in v1.19.0 

type IPsecConfig struct {
	EnableIPsec                              bool
	EncryptedOverlay                         bool
	UseCiliumInternalIPForIPsec              bool
	DNSProxyInsecureSkipTransparentModeCheck bool
}

func (IPsecConfig) DNSProxyInsecureSkipTransparentModeCheckEnabled added in v1.19.0 

func (c IPsecConfig) DNSProxyInsecureSkipTransparentModeCheckEnabled() bool

func (IPsecConfig) Enabled added in v1.19.0 

func (c IPsecConfig) Enabled() bool

func (IPsecConfig) UseCiliumInternalIP added in v1.19.0 

func (c IPsecConfig) UseCiliumInternalIP() bool

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

func (*MTU) PacketizationLayerPMTUDMode added in v1.19.0 

func (*MTU) PacketizationLayerPMTUDMode() string

type WireguardAgent added in v1.19.0 

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

func NewTestAgent added in v1.19.0 

func NewTestAgent(fwc WireguardConfig) *WireguardAgent

func (*WireguardAgent) Enabled added in v1.19.0 

func (fwa *WireguardAgent) Enabled() bool

func (*WireguardAgent) IfaceBufferMargins added in v1.19.0 

func (fwa *WireguardAgent) IfaceBufferMargins() (uint16, uint16, error)

Fake IfaceBufferMargins will still query the underlying system for the wireguard device. This will fail if not setup by the caller.

func (*WireguardAgent) IfaceIndex added in v1.19.0 

func (fwa *WireguardAgent) IfaceIndex() (uint32, error)

Fake IfaceIndex will still query the underlying system for the wireguard device. This will fail if not setup by the caller.

func (*WireguardAgent) Status added in v1.19.0 

func (fwa *WireguardAgent) Status(withPeers bool) (*models.WireguardStatus, error)

type WireguardConfig added in v1.19.0 

type WireguardConfig struct {
	EnableWireguard bool
}

func (WireguardConfig) Enabled added in v1.19.0 

func (fwc WireguardConfig) Enabled() 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.