kernel

Documentation

Index

• func AddVIP(vip string) error
• func DeleteVIP(vip string) error
• func GetIndexFromName(name string) (int, error)
• type Bridge
  • func NewBridge(name string) (*Bridge, error)
  • func (b *Bridge) Delete() error
  • func (b *Bridge) LinkInterface(intf networking.Iface) error
  • func (b *Bridge) UnLinkInterface(intf networking.Iface) error
• type FWMarkRoute
  • func NewFWMarkRoute(ip string, fwmark int, tableID int) (*FWMarkRoute, error)
  • func (fwmr *FWMarkRoute) Delete() error
  • func (fwmr *FWMarkRoute) Verify() bool
• type Interface
  • func NewInterface(index int, options ...InterfaceOption) *Interface
  • func (intf *Interface) AddLocalPrefix(prefix string) error
  • func (intf *Interface) Equals(iface networking.Iface) bool
  • func (intf *Interface) GetGatewayPrefixes() []string
  • func (intf *Interface) GetIndex() int
  • func (intf *Interface) GetInterfaceType() networking.InterfaceType
  • func (intf *Interface) GetLocalPrefixes() []string
  • func (intf *Interface) GetName() string
  • func (intf *Interface) GetNeighborPrefixes() []string
  • func (intf *Interface) RemoveLocalPrefix(prefix string) error
  • func (intf *Interface) SetGatewayPrefixes(gateways []string)
  • func (intf *Interface) SetInterfaceType(ifaceType networking.InterfaceType)
  • func (intf *Interface) SetLocalPrefixes(localPrefixes []string)
  • func (intf *Interface) SetNeighborPrefixes(neighborPrefixes []string)
• type InterfaceMonitor
  • func NewInterfaceMonitor() (*InterfaceMonitor, error)
  • func (im *InterfaceMonitor) Close()
  • func (im *InterfaceMonitor) Subscribe(subscriber networking.InterfaceMonitorSubscriber)
  • func (im *InterfaceMonitor) UnSubscribe(subscriber networking.InterfaceMonitorSubscriber)
• type InterfaceOption
  • func WithInterfaceName(name string) InterfaceOption
• type KernelUtils
  • func (ku *KernelUtils) AddVIP(vip string) error
  • func (ku *KernelUtils) DeleteVIP(vip string) error
  • func (ku *KernelUtils) GetIndexFromName(name string) (int, error)
  • func (ku *KernelUtils) GetInterfaceMonitor(ctx context.Context) networking.InterfaceMonitor
  • func (ku *KernelUtils) NewBridge(name string) (networking.Bridge, error)
  • func (ku *KernelUtils) NewFWMarkRoute(ip string, fwmark int, tableID int) (networking.FWMarkRoute, error)
  • func (ku *KernelUtils) NewInterface(index int) networking.Iface
  • func (ku *KernelUtils) NewInterfaceMonitor() (networking.InterfaceMonitor, error)
  • func (ku *KernelUtils) NewSourceBasedRoute(tableID int, prefix string) (networking.SourceBasedRoute, error)
  • func (ku *KernelUtils) WithInterfaceMonitor(parent context.Context, monitor networking.InterfaceMonitor) context.Context
• type NFSetIP
  • func NewNFSetIP(name string, family int, table *nftables.Table) (*NFSetIP, error)
  • func (nfs *NFSetIP) Delete() error
  • func (nfs *NFSetIP) Update(ips []string) error
• type SourceBasedRoute
  • func NewSourceBasedRoute(tableID int, vip string) (*SourceBasedRoute, error)
  • func (sbr *SourceBasedRoute) AddNexthop(nexthop string) error
  • func (sbr *SourceBasedRoute) Delete() error
  • func (sbr *SourceBasedRoute) RemoveNexthop(nexthop string) error

Functions

func AddVIP

func AddVIP(vip string) error

func DeleteVIP

func DeleteVIP(vip string) error

func GetIndexFromName

func GetIndexFromName(name string) (int, error)

GetIndexFromName - Get the index of an interface from its name

Types

type Bridge

type Bridge struct {
	Interface
	// contains filtered or unexported fields
}

func NewBridge

func NewBridge(name string) (*Bridge, error)

func (*Bridge) Delete

func (b *Bridge) Delete() error

func (*Bridge) LinkInterface

func (b *Bridge) LinkInterface(intf networking.Iface) error

LinkInterface set the bridge as master of another interface

func (*Bridge) UnLinkInterface

func (b *Bridge) UnLinkInterface(intf networking.Iface) error

type FWMarkRoute

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

FWMarkRoute -

func NewFWMarkRoute

func NewFWMarkRoute(ip string, fwmark int, tableID int) (*FWMarkRoute, error)

NewFWMarkRoute -

func (*FWMarkRoute) Delete

func (fwmr *FWMarkRoute) Delete() error

Delete -

func (*FWMarkRoute) Verify

func (fwmr *FWMarkRoute) Verify() bool

type Interface

type Interface struct {
	LocalIPs      []string
	NeighborIPs   []string
	Gateways      []string
	InterfaceType networking.InterfaceType
	// contains filtered or unexported fields
}

func NewInterface

func NewInterface(index int, options ...InterfaceOption) *Interface

func (*Interface) AddLocalPrefix

func (intf *Interface) AddLocalPrefix(prefix string) error

func (*Interface) Equals

func (intf *Interface) Equals(iface networking.Iface) bool

func (*Interface) GetGatewayPrefixes

func (intf *Interface) GetGatewayPrefixes() []string

func (*Interface) GetIndex

func (intf *Interface) GetIndex() int

func (*Interface) GetInterfaceType

func (intf *Interface) GetInterfaceType() networking.InterfaceType

func (*Interface) GetLocalPrefixes

func (intf *Interface) GetLocalPrefixes() []string

func (*Interface) GetName

func (intf *Interface) GetName() string

func (*Interface) GetNeighborPrefixes

func (intf *Interface) GetNeighborPrefixes() []string

func (*Interface) RemoveLocalPrefix

func (intf *Interface) RemoveLocalPrefix(prefix string) error

func (*Interface) SetGatewayPrefixes

func (intf *Interface) SetGatewayPrefixes(gateways []string)

func (*Interface) SetInterfaceType

func (intf *Interface) SetInterfaceType(ifaceType networking.InterfaceType)

func (*Interface) SetLocalPrefixes

func (intf *Interface) SetLocalPrefixes(localPrefixes []string)

func (*Interface) SetNeighborPrefixes

func (intf *Interface) SetNeighborPrefixes(neighborPrefixes []string)

type InterfaceMonitor

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

func NewInterfaceMonitor

func NewInterfaceMonitor() (*InterfaceMonitor, error)

NewInterfaceMonitor -

func (*InterfaceMonitor) Close

func (im *InterfaceMonitor) Close()

Close -

func (*InterfaceMonitor) Subscribe

func (im *InterfaceMonitor) Subscribe(subscriber networking.InterfaceMonitorSubscriber)

Subscribe -

func (*InterfaceMonitor) UnSubscribe

func (im *InterfaceMonitor) UnSubscribe(subscriber networking.InterfaceMonitorSubscriber)

UnSubscribe -

type InterfaceOption

type InterfaceOption func(o *interfaceOptions)

func WithInterfaceName

func WithInterfaceName(name string) InterfaceOption

type KernelUtils

type KernelUtils struct {
}

func (*KernelUtils) AddVIP

func (ku *KernelUtils) AddVIP(vip string) error

func (*KernelUtils) DeleteVIP

func (ku *KernelUtils) DeleteVIP(vip string) error

func (*KernelUtils) GetIndexFromName

func (ku *KernelUtils) GetIndexFromName(name string) (int, error)

func (*KernelUtils) GetInterfaceMonitor

func (ku *KernelUtils) GetInterfaceMonitor(ctx context.Context) networking.InterfaceMonitor

GetInterfaceMonitor - Returns InterfaceMonitor from Context

func (*KernelUtils) NewBridge

func (ku *KernelUtils) NewBridge(name string) (networking.Bridge, error)

func (*KernelUtils) NewFWMarkRoute

func (ku *KernelUtils) NewFWMarkRoute(ip string, fwmark int, tableID int) (networking.FWMarkRoute, error)

func (*KernelUtils) NewInterface

func (ku *KernelUtils) NewInterface(index int) networking.Iface

func (*KernelUtils) NewInterfaceMonitor

func (ku *KernelUtils) NewInterfaceMonitor() (networking.InterfaceMonitor, error)

func (*KernelUtils) NewSourceBasedRoute

func (ku *KernelUtils) NewSourceBasedRoute(tableID int, prefix string) (networking.SourceBasedRoute, error)

func (*KernelUtils) WithInterfaceMonitor

func (ku *KernelUtils) WithInterfaceMonitor(parent context.Context, monitor networking.InterfaceMonitor) context.Context

WithInterfaceMonitor - Stores InterfaceMonitor in Context

type NFSetIP

type NFSetIP struct {
	*nftables.Set
	// contains filtered or unexported fields
}

NFSetIP is a wrapper for IP type nftables.Set (either IPv4 or IPv6) Supports update of IPs

func NewNFSetIP

func NewNFSetIP(name string, family int, table *nftables.Table) (*NFSetIP, error)

func (*NFSetIP) Delete

func (nfs *NFSetIP) Delete() error

func (*NFSetIP) Update

func (nfs *NFSetIP) Update(ips []string) error

type SourceBasedRoute

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

SourceBasedRoute -

func NewSourceBasedRoute

func NewSourceBasedRoute(tableID int, vip string) (*SourceBasedRoute, error)

NewSourceBasedRoute -

func (*SourceBasedRoute) AddNexthop

func (sbr *SourceBasedRoute) AddNexthop(nexthop string) error

AddNexthop -

func (*SourceBasedRoute) Delete

func (sbr *SourceBasedRoute) Delete() error

func (*SourceBasedRoute) RemoveNexthop

func (sbr *SourceBasedRoute) RemoveNexthop(nexthop string) error

RemoveNexthop -