mrt

Mar 1, 2022

Changes in this version

+ const MRT_COMMON_HEADER_LEN

+ func SplitMrt(data []byte, atEOF bool) (advance int, token []byte, err error)

+ type BGP4MPHeader struct

+ AddressFamily uint16

+ InterfaceIndex uint16

+ LocalAS uint32

+ LocalIpAddress net.IP

+ PeerAS uint32

+ PeerIpAddress net.IP

+ type BGP4MPMessage struct

+ BGPMessage *bgp.BGPMessage

+ BGPMessagePayload []byte

+ func NewBGP4MPMessage(peeras, localas uint32, intfindex uint16, peerip, localip string, isAS4 bool, ...) *BGP4MPMessage

+ func NewBGP4MPMessageAddPath(peeras, localas uint32, intfindex uint16, peerip, localip string, isAS4 bool, ...) *BGP4MPMessage

+ func NewBGP4MPMessageLocal(peeras, localas uint32, intfindex uint16, peerip, localip string, isAS4 bool, ...) *BGP4MPMessage

+ func NewBGP4MPMessageLocalAddPath(peeras, localas uint32, intfindex uint16, peerip, localip string, isAS4 bool, ...) *BGP4MPMessage

+ func (m *BGP4MPMessage) DecodeFromBytes(data []byte) error

+ func (m *BGP4MPMessage) Serialize() ([]byte, error)

+ func (m *BGP4MPMessage) String() string

+ type BGP4MPStateChange struct

+ NewState BGPState

+ OldState BGPState

+ func NewBGP4MPStateChange(peeras, localas uint32, intfindex uint16, peerip, localip string, isAS4 bool, ...) *BGP4MPStateChange

+ func (m *BGP4MPStateChange) DecodeFromBytes(data []byte) error

+ func (m *BGP4MPStateChange) Serialize() ([]byte, error)

+ type BGPState uint16

+ const ACTIVE

+ const CONNECT

+ const ESTABLISHED

+ const IDLE

+ const OPENCONFIRM

+ const OPENSENT

+ type Body interface

+ DecodeFromBytes func([]byte) error

+ Serialize func() ([]byte, error)

+ type GeoPeer struct

+ BgpId net.IP

+ Latitude float32

+ Longitude float32

+ Type uint8

+ func NewGeoPeer(bgpid string, latitude float32, longitude float32) *GeoPeer

+ func (p *GeoPeer) DecodeFromBytes(data []byte) ([]byte, error)

+ func (p *GeoPeer) Serialize() ([]byte, error)

+ func (p *GeoPeer) String() string

+ type GeoPeerTable struct

+ CollectorBgpId net.IP

+ CollectorLatitude float32

+ CollectorLongitude float32

+ Peers []*GeoPeer

+ func NewGeoPeerTable(bgpid string, latitude float32, longitude float32, peers []*GeoPeer) *GeoPeerTable

+ func (t *GeoPeerTable) DecodeFromBytes(data []byte) error

+ func (t *GeoPeerTable) Serialize() ([]byte, error)

+ func (t *GeoPeerTable) String() string

+ type MRTHeader struct

+ Len uint32

+ SubType uint16

+ Timestamp uint32

+ Type MRTType

+ func NewMRTHeader(timestamp uint32, t MRTType, subtype MRTSubTyper, l uint32) (*MRTHeader, error)

+ func (h *MRTHeader) DecodeFromBytes(data []byte) error

+ func (h *MRTHeader) GetTime() time.Time

+ func (h *MRTHeader) Serialize() ([]byte, error)

+ type MRTMessage struct

+ Body Body

+ Header MRTHeader

+ func NewMRTMessage(timestamp uint32, t MRTType, subtype MRTSubTyper, body Body) (*MRTMessage, error)

+ func ParseMRTBody(h *MRTHeader, data []byte) (*MRTMessage, error)

+ func (m *MRTMessage) Serialize() ([]byte, error)

+ type MRTSubTypeBGP4MP uint16

+ const MESSAGE

+ const MESSAGE_ADDPATH

+ const MESSAGE_AS4

+ const MESSAGE_AS4_ADDPATH

+ const MESSAGE_AS4_LOCAL

+ const MESSAGE_AS4_LOCAL_ADDPATH

+ const MESSAGE_LOCAL

+ const MESSAGE_LOCAL_ADDPATH

+ const STATE_CHANGE

+ const STATE_CHANGE_AS4

+ func (t MRTSubTypeBGP4MP) ToUint16() uint16

+ type MRTSubTypeTableDumpv2 uint16

+ const GEO_PEER_TABLE

+ const PEER_INDEX_TABLE

+ const RIB_GENERIC

+ const RIB_GENERIC_ADDPATH

+ const RIB_IPV4_MULTICAST

+ const RIB_IPV4_MULTICAST_ADDPATH

+ const RIB_IPV4_UNICAST

+ const RIB_IPV4_UNICAST_ADDPATH

+ const RIB_IPV6_MULTICAST

+ const RIB_IPV6_MULTICAST_ADDPATH

+ const RIB_IPV6_UNICAST

+ const RIB_IPV6_UNICAST_ADDPATH

+ func (t MRTSubTypeTableDumpv2) ToUint16() uint16

+ type MRTSubTyper interface

+ ToUint16 func() uint16

+ type MRTType uint16

+ const BGP

+ const BGP4MP

+ const BGP4MP_ET

+ const BGP4PLUS

+ const BGP4PLUS01

+ const DIE

+ const IDRP

+ const ISIS

+ const ISIS_ET

+ const I_AM_DEAD

+ const NULL

+ const OSPFv2

+ const OSPFv3

+ const OSPFv3_ET

+ const PEER_DOWN

+ const RIP

+ const RIPNG

+ const START

+ const TABLE_DUMP

+ const TABLE_DUMPv2

+ type Peer struct

+ AS uint32

+ BgpId net.IP

+ IpAddress net.IP

+ Type uint8

+ func NewPeer(bgpid string, ipaddr string, asn uint32, isAS4 bool) *Peer

+ func (p *Peer) DecodeFromBytes(data []byte) ([]byte, error)

+ func (p *Peer) Serialize() ([]byte, error)

+ func (p *Peer) String() string

+ type PeerIndexTable struct

+ CollectorBgpId net.IP

+ Peers []*Peer

+ ViewName string

+ func NewPeerIndexTable(bgpid string, viewname string, peers []*Peer) *PeerIndexTable

+ func (t *PeerIndexTable) DecodeFromBytes(data []byte) error

+ func (t *PeerIndexTable) Serialize() ([]byte, error)

+ func (t *PeerIndexTable) String() string

+ type Rib struct

+ Entries []*RibEntry

+ Prefix bgp.AddrPrefixInterface

+ RouteFamily bgp.RouteFamily

+ SequenceNumber uint32

+ func NewRib(seq uint32, prefix bgp.AddrPrefixInterface, entries []*RibEntry) *Rib

+ func (u *Rib) DecodeFromBytes(data []byte) error

+ func (u *Rib) Serialize() ([]byte, error)

+ func (u *Rib) String() string

+ type RibEntry struct

+ OriginatedTime uint32

+ PathAttributes []bgp.PathAttributeInterface

+ PathIdentifier uint32

+ PeerIndex uint16

+ func NewRibEntry(index uint16, time uint32, pathId uint32, ...) *RibEntry

+ func (e *RibEntry) DecodeFromBytes(data []byte) ([]byte, error)

+ func (e *RibEntry) Serialize() ([]byte, error)

+ func (e *RibEntry) String() string