gonslib

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AFToEtherType ¶ 

func AFToEtherType(family int) uint16

AFToEtherType returns ether-type of family.

func AddPortsToVlan ¶ added in v0.4.0 

func AddPortsToVlan(unit int, allBmp *opennsl.PBmp, untagBmp *opennsl.PBmp, vid opennsl.Vlan, strictlyUntagged bool) error

func ClearNativeVlan ¶ added in v0.4.0 

func ClearNativeVlan(unit int, vid opennsl.Vlan, pbmp *opennsl.PBmp, strictlyUntagged bool)

func CreateVlan ¶ added in v0.4.0 

func CreateVlan(unit int, vid opennsl.Vlan) error

func DelPortsFromVlan ¶ added in v0.4.0 

func DelPortsFromVlan(unit int, allBmp *opennsl.PBmp, untagBmp *opennsl.PBmp, vid opennsl.Vlan, strictlyUntagged bool)

func DeleteL2Addrs ¶ added in v0.4.0 

func DeleteL2Addrs(unit int, vid opennsl.Vlan)

func DestroyVlan ¶ added in v0.4.0 

func DestroyVlan(unit int, vid opennsl.Vlan)

func DestroyVlanIfEmpty ¶ added in v0.4.0 

func DestroyVlanIfEmpty(unit int, vid opennsl.Vlan)

func DriverExit ¶ 

func DriverExit()

DriverExit terminates opennsl driver.

func DriverInfo ¶ 

func DriverInfo(unit int)

func DriverInit ¶ 

func DriverInit(unit int, cfg *ONSLConfig) error

DriverInit initialize opennsl driver.

func EtherTypeToLen ¶ 

func EtherTypeToLen(etherType uint16) int

func IPToAF ¶ 

func IPToAF(ip net.IP) int

IPToAF returns address-family of ip.

func IPToEtherType ¶ 

func IPToEtherType(ip net.IP) uint16

IPToEtherType returns ether-type of ip.

func LinkmonServe ¶ 

func LinkmonServe(unit int, linkCh chan<- *LinkInfo, done <-chan struct{})

LinkmonServe monitor link state and notify.

func NewL2addrmonKeyFromL2Addr ¶ added in v0.4.0 

func NewL2addrmonKeyFromL2Addr(l2addr *opennsl.L2Addr) string

func PortBmpGet ¶ 

func PortBmpGet(unit int) (*opennsl.PBmp, error)

PortBmpGet returns port map instance.

func PortDefaultConfig ¶ 

func PortDefaultConfig(unit int) error

PortDefaultConfig setup ports.

func PortDefaultVlanConfig ¶ 

func PortDefaultVlanConfig(unit int) error

PortDefaultVlanConfig registers port to default vlan.

func PortInfoGet ¶ 

func PortInfoGet(unit int, port opennsl.Port) (*opennsl.PortInfo, error)

PortInfoGet returns opennsl port info.

func PortStatInit ¶ 

func PortStatInit(unit int) error

PortStatInit initialze opennsl port stats function.

func RxInit ¶ 

func RxInit(unit int) error

RxInit initialize opennsl rx function.

func RxServe ¶ 

func RxServe(unit int, rxCh chan<- *opennsl.Pkt, done <-chan struct{})

RxServe serve receiving packets.

func SetNativeVlan ¶ added in v0.4.0 

func SetNativeVlan(unit int, vid opennsl.Vlan, pbmp *opennsl.PBmp, strictlyUntagged bool) error

func SetPortVlanTranslation ¶ added in v0.4.0 

func SetPortVlanTranslation(unit int, port opennsl.Port, enable int) error

func SimInit ¶ 

func SimInit(unit int)

SimInit initialize simlator mode.

Types ¶

type APIServer ¶ 

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

APIServer is api server.

func NewAPIServer ¶ 

func NewAPIServer(server *Server) *APIServer

NewAPIServer returns new instance.

func (*APIServer) FindL3Iface ¶ 

func (s *APIServer) FindL3Iface(ctxt context.Context, req *api.FindL3IfaceRequest) (*api.FindL3IfaceReply, error)

FindL3Iface process api.FindL3IfaceRequest.

func (*APIServer) GetFieldEntries ¶ 

func (s *APIServer) GetFieldEntries(ctxt context.Context, req *api.GetFieldEntriesRequest) (*api.GetFieldEntriesReply, error)

GetFieldEntries process api.GetFieldEntriesRequest.

func (*APIServer) GetIDMapEntries ¶ 

func (s *APIServer) GetIDMapEntries(ctxt context.Context, req *api.GetIDMapEntriesRequest) (*api.GetIDMapEntriesReply, error)

GetIDMapEntries process api.GetIDMapEntriesRequest.

func (*APIServer) GetL2Addrs ¶ 

func (s *APIServer) GetL2Addrs(ctxt context.Context, req *api.GetL2AddrsRequest) (*api.GetL2AddrsReply, error)

GetL2Addrs process api.GetL2AddrsRequest.

func (*APIServer) GetL2Stations ¶ 

func (s *APIServer) GetL2Stations(ctxt context.Context, req *api.GetL2StationsRequest) (*api.GetL2StationsReply, error)

GetL2Stations process api.GetL2StationsRequest.

func (*APIServer) GetL3Egresses ¶ 

func (s *APIServer) GetL3Egresses(ctxt context.Context, req *api.GetL3EgressesRequest) (*api.GetL3EgressesReply, error)

GetL3Egresses process api.GetL3EgressesRequest.

func (*APIServer) GetL3Hosts ¶ 

func (s *APIServer) GetL3Hosts(ctxt context.Context, req *api.GetL3HostsRequest) (*api.GetL3HostsReply, error)

GetL3Hosts process api.GetL3HostsRequest.

func (*APIServer) GetL3Iface ¶ 

func (s *APIServer) GetL3Iface(ctxt context.Context, req *api.GetL3IfaceRequest) (*api.GetL3IfaceReply, error)

GetL3Iface process api.GetL3IfaceRequest.

func (*APIServer) GetL3Ifaces ¶ 

func (s *APIServer) GetL3Ifaces(ctxt context.Context, req *api.GetL3IfacesRequest) (*api.GetL3IfacesReply, error)

GetL3Ifaces process api.GetL3IfacesRequest.

func (*APIServer) GetL3Routes ¶ 

func (s *APIServer) GetL3Routes(ctxt context.Context, req *api.GetL3RoutesRequest) (*api.GetL3RoutesReply, error)

GetL3Routes process api.GetL3RoutesRequest.

func (*APIServer) GetPortInfos ¶ added in v0.4.0 

func (s *APIServer) GetPortInfos(ctxt context.Context, req *api.GetPortInfosRequest) (*api.GetPortInfosReply, error)

func (*APIServer) GetTunnelInitiators ¶ 

func (s *APIServer) GetTunnelInitiators(ctxt context.Context, req *api.GetTunnelInitiatorsRequest) (*api.GetTunnelInitiatorsReply, error)

GetTunnelInitiators process api.GetTunnelInitiatorsRequest.

func (*APIServer) GetTunnelTerminators ¶ 

func (s *APIServer) GetTunnelTerminators(ctxt context.Context, req *api.GetTunnelTerminatorsRequest) (*api.GetTunnelTerminatorsReply, error)

GetTunnelTerminators process api.GetTunnelTerminatorsRequest.

func (*APIServer) GetVlans ¶ 

func (s *APIServer) GetVlans(ctxt context.Context, req *api.GetVlansRequest) (*api.GetVlansReply, error)

GetVlans process api.GetVlansRequest.

func (*APIServer) Start ¶ 

func (s *APIServer) Start(addr string) error

Start starts sub modules.

type Args ¶ 

type Args struct {
	ConfigFile string
	ConfigType string
	UseSim     bool
	DpName     string
	APIAddr    string
	Daemon     bool
	PidFile    string
	LogFile    string
	Verbose    bool
}

Args is gonsl arguments.

func NewArgs ¶ 

func NewArgs() *Args

NewArgs returns new instance.

func (*Args) Parse ¶ 

func (a *Args) Parse()

Parse parses argument and get.

type BlockBcastConfig ¶ 

type BlockBcastConfig struct {
	Range BlockBcastRangeConfig   `mapstructure:"range"`
	Ports []*BlockBcastPortConfig `mapstructure:"ports"`
}

VlanPortConfig is vlan config that port belongs to.

func (*BlockBcastConfig) Block ¶ 

func (c *BlockBcastConfig) Block() bool

func (*BlockBcastConfig) String ¶ 

func (c *BlockBcastConfig) String() string

type BlockBcastPortConfig ¶ 

type BlockBcastPortConfig struct {
	Port int    `mapstructure:"port"`
	Vid  uint16 `mapstructure:"vid"`
	PVid uint16 `mapstructure:"pvid"`
}

BlockBcastPortConfig is port entry of BlockBcastConfig.

func (*BlockBcastPortConfig) String ¶ 

func (c *BlockBcastPortConfig) String() string

type BlockBcastRangeConfig ¶ 

type BlockBcastRangeConfig struct {
	Min     int    `mapstructure:"min"`
	Max     int    `mapstructure:"max"`
	BaseVID uint16 `mapstructure:"base_vid"`
}

BlockBcastRangeConfig is port entry of BlockBcastConfig.

func (*BlockBcastRangeConfig) Block ¶ 

func (c *BlockBcastRangeConfig) Block() bool

func (*BlockBcastRangeConfig) GetBaseVID ¶ 

func (c *BlockBcastRangeConfig) GetBaseVID() uint16

func (*BlockBcastRangeConfig) String ¶ 

func (c *BlockBcastRangeConfig) String() string

type BrVlan ¶ added in v0.4.0 

type BrVlan struct {
	Vid              opennsl.Vlan
	Pbmp             *opennsl.PBmp
	UntagBmp         *opennsl.PBmp
	StrictlyUntagged bool
}

func NewBrVlan ¶ added in v0.4.0 

func NewBrVlan(unit int, vid opennsl.Vlan) *BrVlan

func (*BrVlan) Create ¶ added in v0.4.0 

func (b *BrVlan) Create(unit int) error

func (*BrVlan) Delete ¶ added in v0.4.0 

func (b *BrVlan) Delete(unit int)

func (*BrVlan) String ¶ added in v0.4.0 

func (b *BrVlan) String() string

type Config ¶ 

type Config struct {
	Dpaths  map[string]*DpConfig `mapstructure:"dpaths"`
	Logging LogConfig            `mapstructure:"logging"`
}

Config is gonsl config file.

func NewConfig ¶ 

func NewConfig() *Config

NewConfig returns new instance.

func (*Config) GetDpConfig ¶ 

func (c *Config) GetDpConfig(name string) (*DpConfig, error)

GetDpConfig returns dp cofig.

func (*Config) ReadFile ¶ 

func (c *Config) ReadFile(args *Args) (*viper.Viper, error)

ReadFile reads config file.

type DpConfig ¶ 

type DpConfig struct {
	DpID       uint64           `mapstructure:"dpid"`
	Addr       string           `mapstructure:"addr"`
	Port       uint16           `mapstructure:"port"`
	Unit       int              `mapstructure:"unit"`
	BlockBcast BlockBcastConfig `mapstructure:"block_bcast"`
	OpenNSL    *ONSLConfig      `mapstructure:"opennsl"`
	L2SW       L2SWConfig       `mapstructure:"l2sw"`
}

DpConfig is part of gonsl config.

func (*DpConfig) GetAddr ¶ 

func (c *DpConfig) GetAddr() string

GetAddr returns address of server.

func (*DpConfig) GetHost ¶ 

func (c *DpConfig) GetHost() string

GetHost returns ipaddr:port

func (*DpConfig) GetL2AgingTimer ¶ added in v0.4.0 

func (c *DpConfig) GetL2AgingTimer() int

GetL2AgingTimer returns l2 aging timer (second).

func (*DpConfig) GetL2NotifyLimit ¶ added in v0.4.0 

func (c *DpConfig) GetL2NotifyLimit() uint32

func (*DpConfig) GetL2SweepTime ¶ added in v0.4.0 

func (c *DpConfig) GetL2SweepTime() time.Duration

GetL2SweepTime returns l2 addr table sweep time.

func (*DpConfig) GetPort ¶ 

func (c *DpConfig) GetPort() uint16

GetPort returns port number of server.

func (*DpConfig) String ¶ 

func (c *DpConfig) String() string

String retuns config information.

type FieldEntry ¶ added in v0.4.0 

type FieldEntry interface {
	// contains filtered or unexported methods
}

FieldEntry is interface of field entry.

type FieldEntryDstIP ¶ added in v0.4.0 

type FieldEntryDstIP struct {
	EthType opennsl.Ethertype
	Dest    *net.IPNet
	InPort  opennsl.Port
}

FieldEntryDstIP is field entry (DstIPv4 or DstIPv6).

func NewFieldEntryDstIP ¶ added in v0.4.0 

func NewFieldEntryDstIP(dest *net.IPNet, inPort opennsl.Port, ethType uint16) *FieldEntryDstIP

NewFieldEntryDstIP returns new FieldEntryDstIP(IPv4 or IPv6)

func NewFieldEntryDstIPv4 ¶ added in v0.4.0 

func NewFieldEntryDstIPv4(dest *net.IPNet, inPort opennsl.Port) *FieldEntryDstIP

NewFieldEntryDstIPv4 returns new FieldEntryDstIP(IPv4)

func NewFieldEntryDstIPv6 ¶ added in v0.4.0 

func NewFieldEntryDstIPv6(dest *net.IPNet, inPort opennsl.Port) *FieldEntryDstIP

NewFieldEntryDstIPv6 returns new FieldEntryDstIP(IPv6)

func (*FieldEntryDstIP) String ¶ added in v0.4.0 

func (e *FieldEntryDstIP) String() string

type FieldEntryEthDst ¶ added in v0.4.0 

type FieldEntryEthDst struct {
	Dest   net.HardwareAddr
	Mask   net.HardwareAddr
	InPort opennsl.Port
}

FieldEntryEthDst is field entry (EthDst).

func NewFieldEntryEthDst ¶ added in v0.4.0 

func NewFieldEntryEthDst(dest, mask net.HardwareAddr, inPort opennsl.Port) *FieldEntryEthDst

NewFieldEntryEthDst returns new FieldEntryEthDst.

func (*FieldEntryEthDst) String ¶ added in v0.4.0 

func (e *FieldEntryEthDst) String() string

String returns string.

type FieldEntryEthType ¶ added in v0.4.0 

type FieldEntryEthType struct {
	EthType uint16
	InPort  opennsl.Port
}

FieldEntryEthType is field entry (EthType).

func NewFieldEntryEthType ¶ added in v0.4.0 

func NewFieldEntryEthType(ethType uint16, inPort opennsl.Port) *FieldEntryEthType

NewFieldEntryEthType returns new FieldEntryEthType.

func (*FieldEntryEthType) String ¶ added in v0.4.0 

func (e *FieldEntryEthType) String() string

type FieldEntryIPProto ¶ added in v0.4.0 

type FieldEntryIPProto struct {
	EthType uint16
	IPProto uint8
	InPort  opennsl.Port
}

FieldEntryIPProto is field entry (IP proto).

func NewFieldEntryIPProto ¶ added in v0.4.0 

func NewFieldEntryIPProto(ipProto uint8, ethType uint16, inPort opennsl.Port) *FieldEntryIPProto

NewFieldEntryIPProto returns new FieldEntryIPProto.

func (*FieldEntryIPProto) String ¶ added in v0.4.0 

func (e *FieldEntryIPProto) String() string

type FieldGroup ¶ 

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

FieldGroup has cos, field_group and entries.

func NewFieldGroup ¶ 

func NewFieldGroup(unit int, cos uint32, pri int, qs ...opennsl.FieldQualify) *FieldGroup

NewFieldGroup returns new instance.

func NewFieldGroupDstIPv4 ¶ 

func NewFieldGroupDstIPv4(unit int) *FieldGroup

NewFieldGroupDstIPv4 returns new FieldGroup for FieldEntryDstIP(v4)

func NewFieldGroupDstIPv6 ¶ 

func NewFieldGroupDstIPv6(unit int) *FieldGroup

NewFieldGroupDstIPv6 returns new FieldGroup for FieldEntryDstIP(v6)

func NewFieldGroupEthDst ¶ 

func NewFieldGroupEthDst(unit int) *FieldGroup

NewFieldGroupEthDst created new FieldGroup for FieldEntryEthDst.

func NewFieldGroupEthType ¶ 

func NewFieldGroupEthType(unit int) *FieldGroup

NewFieldGroupEthType create new FieldGroup for FieldEntryEthType.

func NewFieldGroupIPProto ¶ 

func NewFieldGroupIPProto(unit int) *FieldGroup

NewFieldGroupIPProto created new FieldGroup for FieldEntryIPProto.

func (*FieldGroup) AddEntry ¶ added in v0.4.0 

func (f *FieldGroup) AddEntry(e FieldEntry) error

AddEntry installs field entry.

func (*FieldGroup) DeleteEntry ¶ added in v0.4.0 

func (f *FieldGroup) DeleteEntry(e FieldEntry)

DeleteEntry uninstall field entry.

func (*FieldGroup) GetEntries ¶ 

func (f *FieldGroup) GetEntries() ([]opennsl.FieldEntry, error)

GetEntries get all field entry from H.W.

func (*FieldGroup) GetEntry ¶ added in v0.4.0 

func (f *FieldGroup) GetEntry(e FieldEntry, entry opennsl.FieldEntry) error

GetEntry get field entry form H.W.

type FieldGroups ¶ 

type FieldGroups struct {
	EthDst  *FieldGroup
	EthType *FieldGroup
	DstIPv4 *FieldGroup
	DstIPv6 *FieldGroup
	IPProto *FieldGroup
}

FieldGroups has opennsl field_groups.

func NewFieldGroups ¶ 

func NewFieldGroups(unit int) *FieldGroups

NewFieldGroups returns new instance.

type IDMaps ¶ 

type IDMaps struct {
	L2Stations *L2StationIDMap
	L3Ifaces   *L3IfaceIDMap
	L3Egress   *L3EgressIDMap
	Trunks     *TrunkIDMap
}

IDMaps has sub-maps.

func NewIDMaps ¶ 

func NewIDMaps() *IDMaps

NewIDMaps returns new instance.

type L2SWConfig ¶ added in v0.4.0 

type L2SWConfig struct {
	NotifyLimit uint32 `mapstructure:"notify_limit"`
	SweepSec    uint32 `mapstructure:"sweep_sec"`
	AgingSec    uint32 `mapstructure:"aging_sec"`
}

L2SWConfig is l2sw configurations.

func (*L2SWConfig) String ¶ added in v0.4.0 

func (c *L2SWConfig) String() string

type L2StationIDKey ¶ added in v0.4.0 

type L2StationIDKey uint32

L2StationIDKey is key of L2StationIDMap

func NewL2StationIDKey ¶ added in v0.4.0 

func NewL2StationIDKey(id uint32) L2StationIDKey

NewL2StationIDKey returns new L2StationIDKey

func (L2StationIDKey) String ¶ added in v0.4.0 

func (k L2StationIDKey) String() string

String returns string.

type L2StationIDMap ¶ added in v0.4.0 

type L2StationIDMap struct {
	sync.Map
}

L2StationIDMap has id and l2station id.

func NewL2StationIDMap ¶ added in v0.4.0 

func NewL2StationIDMap() *L2StationIDMap

NewL2StationIDMap returns new L2StationIDMap

func (*L2StationIDMap) Get ¶ added in v0.4.0 

func (m *L2StationIDMap) Get(id uint32) (opennsl.L2StationID, bool)

Get returns L2StationID by id.

func (*L2StationIDMap) Register ¶ added in v0.4.0 

func (m *L2StationIDMap) Register(id uint32, l2stationId opennsl.L2StationID) bool

Register registers id and l3egrId.

func (*L2StationIDMap) Traverse ¶ added in v0.4.0 

func (m *L2StationIDMap) Traverse(f func(L2StationIDKey, opennsl.L2StationID) bool)

Traverse enumerates all entries.

func (*L2StationIDMap) Unregister ¶ added in v0.4.0 

func (m *L2StationIDMap) Unregister(id uint32)

Unregister removes id.

type L2addrmonEntry ¶ added in v0.4.0 

type L2addrmonEntry struct {
	L2Addr *opennsl.L2Addr
	Oper   opennsl.L2CallbackOper
}

func NewL2addrmonEntry ¶ added in v0.4.0 

func NewL2addrmonEntry(src *opennsl.L2Addr, oper opennsl.L2CallbackOper) *L2addrmonEntry

func (*L2addrmonEntry) Key ¶ added in v0.4.0 

func (e *L2addrmonEntry) Key() string

func (*L2addrmonEntry) SetAdd ¶ added in v0.4.0 

func (e *L2addrmonEntry) SetAdd() bool

func (*L2addrmonEntry) SetDel ¶ added in v0.4.0 

func (e *L2addrmonEntry) SetDel() bool

func (*L2addrmonEntry) String ¶ added in v0.4.0 

func (e *L2addrmonEntry) String() string

type L2addrmonTable ¶ added in v0.4.0 

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

func NewL2addrmonTable ¶ added in v0.4.0 

func NewL2addrmonTable(maxEntry uint32) *L2addrmonTable

func (*L2addrmonTable) Add ¶ added in v0.4.0 

func (t *L2addrmonTable) Add(newEntry *L2addrmonEntry)

func (*L2addrmonTable) Del ¶ added in v0.4.0 

func (t *L2addrmonTable) Del(delEntry *L2addrmonEntry)

func (*L2addrmonTable) Put ¶ added in v0.4.0 

func (t *L2addrmonTable) Put(e *L2addrmonEntry)

func (*L2addrmonTable) Reset ¶ added in v0.4.0 

func (t *L2addrmonTable) Reset(force bool) []*L2addrmonEntry

type L3EgressIDKey ¶ added in v0.4.0 

type L3EgressIDKey uint32

L3EgressIDKey is key of L3EgressIDMap

func NewL3EgressIDKey ¶ added in v0.4.0 

func NewL3EgressIDKey(neighId uint32) L3EgressIDKey

NewL3EgressIDKey returns new L3EgressIDKey

func (L3EgressIDKey) String ¶ added in v0.4.0 

func (k L3EgressIDKey) String() string

String returns string.

type L3EgressIDMap ¶ added in v0.4.0 

type L3EgressIDMap struct {
	sync.Map
}

L3EgressIDMap has id(key) and l3-egress-id(value).

func NewL3EgressIDMap ¶ added in v0.4.0 

func NewL3EgressIDMap() *L3EgressIDMap

NewL3EgressIDMap returns new L3EgressIDMap

func (*L3EgressIDMap) Get ¶ added in v0.4.0 

func (m *L3EgressIDMap) Get(id uint32) (opennsl.L3EgressID, bool)

Get returns L3EgressID by id.

func (*L3EgressIDMap) Register ¶ added in v0.4.0 

func (m *L3EgressIDMap) Register(id uint32, l3egrId opennsl.L3EgressID) bool

Register registers id and l3egrId.

func (*L3EgressIDMap) Traverse ¶ added in v0.4.0 

func (m *L3EgressIDMap) Traverse(f func(L3EgressIDKey, opennsl.L3EgressID) bool)

Traverse enumerates all entries.

func (*L3EgressIDMap) Unregister ¶ added in v0.4.0 

func (m *L3EgressIDMap) Unregister(id uint32)

Unregister removes id.

type L3IfaceIDKey ¶ added in v0.4.0 

type L3IfaceIDKey struct {
	Port uint32
	Vid  uint16
}

L3IfaceIDKey is key of L3IfaceIDMap.

func NewL3IfaceIDKey ¶ added in v0.4.0 

func NewL3IfaceIDKey(port uint32, vid uint16) L3IfaceIDKey

NewL3IfaceIDKey returns new L3IfaceIDKey

func (*L3IfaceIDKey) String ¶ added in v0.4.0 

func (k *L3IfaceIDKey) String() string

String returns string.

type L3IfaceIDMap ¶ added in v0.4.0 

type L3IfaceIDMap struct {
	sync.Map
}

L3IfaceIDMap has id/vid(key) and l3-interface-id(value).

func NewL3IfaceIDMap ¶ added in v0.4.0 

func NewL3IfaceIDMap() *L3IfaceIDMap

NewL3IfaceIDMap returns new NewL3IfaceIDMap

func (*L3IfaceIDMap) Get ¶ added in v0.4.0 

func (m *L3IfaceIDMap) Get(port uint32, vid uint16) (opennsl.L3IfaceID, bool)

func (*L3IfaceIDMap) Register ¶ added in v0.4.0 

func (m *L3IfaceIDMap) Register(port uint32, vid uint16, l3ifaceId opennsl.L3IfaceID) bool

Register registers id and l3ifaceId.

func (*L3IfaceIDMap) Traverse ¶ added in v0.4.0 

func (m *L3IfaceIDMap) Traverse(f func(L3IfaceIDKey, opennsl.L3IfaceID) bool)

Traverse enumerates all entries.

func (*L3IfaceIDMap) Unregister ¶ added in v0.4.0 

func (m *L3IfaceIDMap) Unregister(port uint32, vid uint16)

Unregister removes id.

type L3Vlan ¶ added in v0.4.0 

type L3Vlan struct {
	Vlan opennsl.Vlan
	Vid  opennsl.Vlan
	Pbmp *opennsl.PBmp
}

func NewL3Vlan ¶ added in v0.4.0 

func NewL3Vlan(unit int, vid opennsl.Vlan) *L3Vlan

func (*L3Vlan) Create ¶ added in v0.4.0 

func (b *L3Vlan) Create(unit int) error

func (*L3Vlan) Delete ¶ added in v0.4.0 

func (b *L3Vlan) Delete(unit int) error

func (*L3Vlan) String ¶ added in v0.4.0 

func (b *L3Vlan) String() string

type LinkInfo ¶ 

type LinkInfo struct {
	*opennsl.PortInfo
	Port opennsl.Port
}

LinkInfo is opennsl port_info and port_no.

func NewLinkInfo ¶ 

func NewLinkInfo(port opennsl.Port, info *opennsl.PortInfo) *LinkInfo

NewLinkInfo create new instance of LinkInfo.

func (*LinkInfo) PortNo ¶ 

func (l *LinkInfo) PortNo() uint32

PortNo returns port_no.

func (*LinkInfo) PortState ¶ 

func (l *LinkInfo) PortState() uint32

PortState returns port statte.

port is up : fibcapi.FFPORT_STATE_NONE port is down: fibcapi.FFPORT_STATE_LINKDOWN

type LogConfig ¶ 

type LogConfig struct {
	RxDetail bool `mapstructure:"rx_detail"`
	RxDump   bool `mapstructure:"rx_dump"`
}

LogConfig is logging config.

func (*LogConfig) String ¶ 

func (c *LogConfig) String() string

String retuns config information.

type ONSLConfig ¶ 

type ONSLConfig struct {
	Config     string `mapstructure:"cfg_fname"`
	ConfigPost string `mapstructure:"cfg_post_fname"`
	Flags      uint   `mapstructure:"flags"`
	RmConfig   string `mapstructure:"rmcfg_fname"`
	WbConfig   string `mapstructure:"wb_fname"`
}

ONSLConfig is opennsl config file.

type PortStats ¶ 

type PortStats []opennsl.StatVal

PortStats is list of opennsl.StatVal.

func NewPortStats ¶ 

func NewPortStats(names []string) PortStats

NewPortStats creates new instance.

func (PortStats) Get ¶ 

func (p PortStats) Get(unit int, port opennsl.Port) (map[string]uint64, error)

Get gets stats of specified port.

func (PortStats) GetAll ¶ 

func (p PortStats) GetAll(unit int, ports []opennsl.Port) ([]map[string]uint64, error)

GetAll gets Stats of all port.

type Server ¶ 

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

Server is main service of gonsld.

func NewServer ¶ 

func NewServer(dpCfg *DpConfig, logCfg *LogConfig) *Server

NewServer cerates new instance of Server.

func (*Server) DpID ¶ 

func (s *Server) DpID() uint64

func (*Server) FIBCBridgingFlowMod ¶ 

func (s *Server) FIBCBridgingFlowMod(hdr *fibcnet.Header, mod *fibcapi.FlowMod, flow *fibcapi.BridgingFlow)

FIBCBridgingFlowMod process FlowMod (Bridging)

func (*Server) FIBCFFMultipartPortDescRequest ¶ 

func (s *Server) FIBCFFMultipartPortDescRequest(hdr *fibcnet.Header, mp *fibcapi.FFMultipart_Request, pd *fibcapi.FFMultipart_PortDescRequest)

FIBCFFMultipartPortDescRequest process multipart-request(port desc) from fibcd.

func (*Server) FIBCFFMultipartPortRequest ¶ 

func (s *Server) FIBCFFMultipartPortRequest(hdr *fibcnet.Header, mp *fibcapi.FFMultipart_Request, req *fibcapi.FFMultipart_PortRequest)

FIBCFFMultipartPortRequest process multipart-request(port stats) from fibcd.

func (*Server) FIBCFFPacketOut ¶ 

func (s *Server) FIBCFFPacketOut(hdr *fibcnet.Header, pktout *fibcapi.FFPacketOut)

FIBCFFPacketOut process FFPacketOUT message from fibcd.

func (*Server) FIBCFFPortMod ¶ 

func (s *Server) FIBCFFPortMod(hdr *fibcnet.Header, mod *fibcapi.FFPortMod)

func (*Server) FIBCFlowMod ¶ 

func (s *Server) FIBCFlowMod(hdr *fibcnet.Header, mod *fibcapi.FlowMod)

FIBCFlowMod process any FlowMod.

func (*Server) FIBCGroupMod ¶ 

func (s *Server) FIBCGroupMod(hdr *fibcnet.Header, mod *fibcapi.GroupMod)

FIBCGroupMod process any GroupMod.

func (*Server) FIBCL2InterfaceGroupMod ¶ 

func (s *Server) FIBCL2InterfaceGroupMod(hdr *fibcnet.Header, mod *fibcapi.GroupMod, group *fibcapi.L2InterfaceGroup)

FIBCL2InterfaceGroupMod process GroupMod(L2 Interface)

func (*Server) FIBCL3UnicastGroupMod ¶ 

func (s *Server) FIBCL3UnicastGroupMod(hdr *fibcnet.Header, mod *fibcapi.GroupMod, group *fibcapi.L3UnicastGroup)

FIBCL3UnicastGroupMod process GroupMod(L3 Unicst)

func (*Server) FIBCMPLSFlowMod ¶ 

func (s *Server) FIBCMPLSFlowMod(hdr *fibcnet.Header, mod *fibcapi.FlowMod, flow *fibcapi.MPLSFlow)

FIBCMPLSFlowMod process FlowMod (MPLS)

func (*Server) FIBCMPLSInterfaceGroupMod ¶ 

func (s *Server) FIBCMPLSInterfaceGroupMod(hdr *fibcnet.Header, mod *fibcapi.GroupMod, group *fibcapi.MPLSInterfaceGroup)

FIBCMPLSInterfaceGroupMod process GroupMod(MPLS Interface)

func (*Server) FIBCMPLSLabelL2VpnGroupMod ¶ 

func (s *Server) FIBCMPLSLabelL2VpnGroupMod(hdr *fibcnet.Header, mod *fibcapi.GroupMod, group *fibcapi.MPLSLabelGroup)

FIBCMPLSLabelL2VpnGroupMod process GroupMod(MPLS Label(L2 VPN))

func (*Server) FIBCMPLSLabelL3VpnGroupMod ¶ 

func (s *Server) FIBCMPLSLabelL3VpnGroupMod(hdr *fibcnet.Header, mod *fibcapi.GroupMod, group *fibcapi.MPLSLabelGroup)

FIBCMPLSLabelL3VpnGroupMod process GroupMod(MPLS Label(L3 VPN))

func (*Server) FIBCMPLSLabelSwapGroupMod ¶ 

func (s *Server) FIBCMPLSLabelSwapGroupMod(hdr *fibcnet.Header, mod *fibcapi.GroupMod, group *fibcapi.MPLSLabelGroup)

FIBCMPLSLabelSwapGroupMod process GroupMod(MPLS Label(Swap))

func (*Server) FIBCMPLSLabelTun1GroupMod ¶ 

func (s *Server) FIBCMPLSLabelTun1GroupMod(hdr *fibcnet.Header, mod *fibcapi.GroupMod, group *fibcapi.MPLSLabelGroup)

FIBCMPLSLabelTun1GroupMod process GroupMod(MPLS Label(Tunnel1))

func (*Server) FIBCMPLSLabelTun2GroupMod ¶ 

func (s *Server) FIBCMPLSLabelTun2GroupMod(hdr *fibcnet.Header, mod *fibcapi.GroupMod, group *fibcapi.MPLSLabelGroup)

FIBCMPLSLabelTun2GroupMod process GroupMod(MPLS Label(Tunnel2))

func (*Server) FIBCPolicyACLFlowMod ¶ 

func (s *Server) FIBCPolicyACLFlowMod(hdr *fibcnet.Header, mod *fibcapi.FlowMod, flow *fibcapi.PolicyACLFlow)

FIBCPolicyACLFlowMod process FlowMod(ACL Policy)

func (*Server) FIBCTerminationMacFlowMod ¶ 

func (s *Server) FIBCTerminationMacFlowMod(hdr *fibcnet.Header, mod *fibcapi.FlowMod, flow *fibcapi.TerminationMacFlow)

FIBCTerminationMacFlowMod process FlowMod(Termination MAC)

func (*Server) FIBCUnicastRoutingFlowMod ¶ 

func (s *Server) FIBCUnicastRoutingFlowMod(hdr *fibcnet.Header, mod *fibcapi.FlowMod, flow *fibcapi.UnicastRoutingFlow)

FIBCUnicastRoutingFlowMod process FlowMod(Unicast Routing)

func (*Server) FIBCVLANFlowMod ¶ 

func (s *Server) FIBCVLANFlowMod(hdr *fibcnet.Header, mod *fibcapi.FlowMod, flow *fibcapi.VLANFlow)

FIBCVLANFlowMod process FlowMod(VLAN)

func (*Server) Fields ¶ 

func (s *Server) Fields() *FieldGroups

func (*Server) L2AddrInit ¶ added in v0.4.0 

func (s *Server) L2AddrInit()

func (*Server) L2AddrMonServe ¶ added in v0.4.0 

func (s *Server) L2AddrMonServe(unit int, sweepTime time.Duration, done <-chan struct{})

func (*Server) L2AddrMonStart ¶ added in v0.4.0 

func (s *Server) L2AddrMonStart(done <-chan struct{})

func (*Server) LinkmonStart ¶ 

func (s *Server) LinkmonStart(done <-chan struct{}) <-chan *LinkInfo

LinkmonStart starts link monitor.

func (*Server) LogConfig ¶ 

func (s *Server) LogConfig() *LogConfig

func (*Server) RecvMain ¶ 

func (s *Server) RecvMain()

RecvMain reveives and dispatch messages from fibcd.

func (*Server) RxStart ¶ 

func (s *Server) RxStart(done <-chan struct{}) <-chan *opennsl.Pkt

RxStart starts receiving packets.

func (*Server) Serve ¶ 

func (s *Server) Serve(done <-chan struct{})

Serve is main loop of Service.

func (*Server) Start ¶ 

func (s *Server) Start(done <-chan struct{}) error

Start starts submodules.

func (*Server) Unit ¶ 

func (s *Server) Unit() int

func (*Server) VlanPorts ¶ 

func (s *Server) VlanPorts() *VlanPortTable

type TrunkIDKey ¶ added in v0.4.0 

type TrunkIDKey struct {
	LagId uint32
	Vid   uint16
}

TrunkIDKey is key of TrunkIDMap

func NewTrunkIDKey ¶ added in v0.4.0 

func NewTrunkIDKey(lagId uint32, vid uint16) TrunkIDKey

NewTrunkIDKey returns new TrunkIDKey

func (*TrunkIDKey) String ¶ added in v0.4.0 

func (k *TrunkIDKey) String() string

String returns string

type TrunkIDMap ¶ added in v0.4.0 

type TrunkIDMap struct {
	sync.Map
}

TrunkIDMap has lag-id/vid(key) and trunk-id(value)

func NewTrunkIDMap ¶ added in v0.4.0 

func NewTrunkIDMap() *TrunkIDMap

NewTrunkIDMap returns new TrunkIDMap

func (*TrunkIDMap) Get ¶ added in v0.4.0 

func (m *TrunkIDMap) Get(lagid uint32, vid uint16) (opennsl.Trunk, bool)

Get returns L3IfaceID by id.

func (*TrunkIDMap) Register ¶ added in v0.4.0 

func (m *TrunkIDMap) Register(lagid uint32, vid uint16, trunkId opennsl.Trunk) bool

Register registers id and trunkId.

func (*TrunkIDMap) Traverse ¶ added in v0.4.0 

func (m *TrunkIDMap) Traverse(f func(TrunkIDKey, opennsl.Trunk) bool)

Traverse enumerates all entries.

func (*TrunkIDMap) Unregister ¶ added in v0.4.0 

func (m *TrunkIDMap) Unregister(lagid uint32, vid uint16)

Unregister removes id.

type VlanPortEntry ¶ 

type VlanPortEntry struct {
	Vid opennsl.Vlan
}

func NewVlanPortEntry ¶ 

func NewVlanPortEntry(vid opennsl.Vlan) *VlanPortEntry

func NewVlanPortEntryDefault ¶ 

func NewVlanPortEntryDefault() *VlanPortEntry

type VlanPortKey ¶ 

type VlanPortKey struct {
	Port opennsl.Port
	Vid  opennsl.Vlan
}

func NewVlanPortKey ¶ 

func NewVlanPortKey(port opennsl.Port, vid opennsl.Vlan) *VlanPortKey

func (*VlanPortKey) String ¶ 

func (k *VlanPortKey) String() string

type VlanPortTable ¶ 

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

func NewVlanPortTable ¶ 

func NewVlanPortTable() *VlanPortTable

func NewVlanPortTableFromConfig ¶ 

func NewVlanPortTableFromConfig(config *BlockBcastConfig) *VlanPortTable

func (*VlanPortTable) ConvVID ¶ 

func (t *VlanPortTable) ConvVID(port opennsl.Port, vid opennsl.Vlan) opennsl.Vlan

func (*VlanPortTable) Has ¶ added in v0.4.0 

func (t *VlanPortTable) Has(vid opennsl.Vlan) bool

func (*VlanPortTable) Insert ¶ 

func (t *VlanPortTable) Insert(key *VlanPortKey, entry *VlanPortEntry) bool

func (*VlanPortTable) SetBaseVID ¶ 

func (t *VlanPortTable) SetBaseVID(vid opennsl.Vlan)

func (*VlanPortTable) SetDefaultVID ¶ 

func (t *VlanPortTable) SetDefaultVID(vid opennsl.Vlan)

func (*VlanPortTable) SetMaxPort ¶ 

func (t *VlanPortTable) SetMaxPort(maxPort opennsl.Port)

func (*VlanPortTable) SetMinPort ¶ 

func (t *VlanPortTable) SetMinPort(minPort opennsl.Port)

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.