mrt

package

v0.1.3 Latest Latest Go to latest Published: May 2, 2019 License: BSD-2-Clause Imports: 13 Imported by: 7

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/CSUNetSec/protoparse

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetASPath(mbs *MrtBufferStack) ([]uint32, error)
func GetCollector(mbs *MrtBufferStack) net.IP
func GetTimestamp(mbs *MrtBufferStack) time.Time
func IsRib(a []byte) (bool, error)
func MrtToBGPCapturev2(data []byte) (*monpb2.BGPCapture, error)
func NewBGP4MPHeaderWrapper(dest *pbbgp.BGP4MPHeader) *bgp4mpHeaderWrapper
func NewBgp4mpHdrBuf(buf []byte, AS4 bool) *bgp4mpHdrBuf
func NewMrtHdrBuf(buf []byte) *mrtHhdrBuf
func NewMrtHeaderWrapper(m *mrtHhdrBuf) *mrtHeaderWrapper
func NewRIBMrtHdrBuf(buf []byte, index pp.PbVal) *mrtHhdrBuf
func SplitMrt(data []byte, atEOF bool) (advance int, token []byte, err error)
type MrtBufferStack
- func ParseHeaders(data []byte, ind bool) (*MrtBufferStack, error)
- func ParseRibHeaders(data []byte, ind protoparse.PbVal) (*MrtBufferStack, error)
- func (mbs *MrtBufferStack) GetRawMessage() []byte
- func (mbs *MrtBufferStack) IsRibStack() bool
type Route
- func GetAdvertisedPrefixes(mbs *MrtBufferStack) ([]Route, error)
- func GetWithdrawnPrefixes(mbs *MrtBufferStack) ([]Route, error)
- func (r Route) String() string

Constants ¶

View Source

const (
	MRT_HEADER_LEN    = 12
	BGP4MP            = 16
	BGP4MP_ET         = 17
	MESSAGE           = 1
	MESSAGE_AS4       = 4
	MESSAGE_LOCAL     = 7
	MESSAGE_AS4_LOCAL = 7
	TABLE_DUMP        = 12
	TABLE_DUMP_V2     = 13
	PEER_INDEX_TABLE  = 1
)

Variables ¶

This section is empty.

Functions ¶

func GetASPath ¶

func GetASPath(mbs *MrtBufferStack) ([]uint32, error)

This will return the full AS path listed on the mbs This does no length checking, so the returned path could be empty, under very weird circumstances

func GetCollector ¶

func GetCollector(mbs *MrtBufferStack) net.IP

This will get the collector IP that received the message from the BGP4MP header

func GetTimestamp ¶

func GetTimestamp(mbs *MrtBufferStack) time.Time

This code just converts the 32 bit timestamp inside an MRT header and converts it to a standard go time.Time

func IsRib ¶

func IsRib(a []byte) (bool, error)

func MrtToBGPCapturev2 ¶

func MrtToBGPCapturev2(data []byte) (*monpb2.BGPCapture, error)

func NewBGP4MPHeaderWrapper ¶

func NewBGP4MPHeaderWrapper(dest *pbbgp.BGP4MPHeader) *bgp4mpHeaderWrapper

func NewBgp4mpHdrBuf ¶

func NewBgp4mpHdrBuf(buf []byte, AS4 bool) *bgp4mpHdrBuf

func NewMrtHdrBuf ¶

func NewMrtHdrBuf(buf []byte) *mrtHhdrBuf

func NewMrtHeaderWrapper ¶

func NewMrtHeaderWrapper(m *mrtHhdrBuf) *mrtHeaderWrapper

func NewRIBMrtHdrBuf ¶

func NewRIBMrtHdrBuf(buf []byte, index pp.PbVal) *mrtHhdrBuf

func SplitMrt ¶

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

Types ¶

type MrtBufferStack ¶

type MrtBufferStack struct {
	MrthBuf   protoparse.PbVal `json:"mrt_header,omitempty"`
	Bgp4mpbuf protoparse.PbVal `json:"bgp4mp_header,omitempty"`
	Bgphbuf   protoparse.PbVal `json:"bgp_header,omitempty"`
	Bgpupbuf  protoparse.PbVal `json:"bgp_update,omitempty"`

	Ribbuf protoparse.PbVal `json:"rib_entry,omitempty"`
}

func ParseHeaders ¶

func ParseHeaders(data []byte, ind bool) (*MrtBufferStack, error)

func ParseRibHeaders ¶

func ParseRibHeaders(data []byte, ind protoparse.PbVal) (*MrtBufferStack, error)

func (*MrtBufferStack) GetRawMessage ¶

func (mbs *MrtBufferStack) GetRawMessage() []byte

func (*MrtBufferStack) IsRibStack ¶

func (mbs *MrtBufferStack) IsRibStack() bool

type Route ¶

type Route struct {
	IP   net.IP
	Mask uint8
}

func GetAdvertisedPrefixes ¶ added in v0.1.3

func GetAdvertisedPrefixes(mbs *MrtBufferStack) ([]Route, error)

This will return a list of prefixes <"IP/mask"> that appear in advertised routes Like getASPath, this does no length checking, and may return an empty array

func GetWithdrawnPrefixes ¶

func GetWithdrawnPrefixes(mbs *MrtBufferStack) ([]Route, error)

This will return a list of prefixes that appear in withdrawn routes

func (Route) String ¶

func (r Route) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL