corebgp

package module

Go to main page

Versions in this module

v0

v0.8.3

Jan 23, 2024

Changes in this version

+ type LargeCommunitiesPathAttr []LargeCommunity

+ func (l *LargeCommunitiesPathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type LargeCommunity struct

+ GlobalAdmin uint32

+ LocalData1 uint32

+ LocalData2 uint32

v0.8.2

Dec 26, 2023

v0.8.1

Feb 26, 2023

v0.8.0

Feb 26, 2023

Changes in this version

+ type AddPathPrefix struct

+ ID uint32

+ Prefix netip.Prefix

+ func DecodeMPIPv6AddPathPrefixes(b []byte) ([]AddPathPrefix, error)

+ type AddPathTuple struct

+ AFI uint16

+ Rx bool

+ SAFI uint8

+ Tx bool

+ func DecodeAddPathTuples(b []byte) ([]AddPathTuple, error)

+ func (a *AddPathTuple) Decode(b []byte) error

+ func (a *AddPathTuple) Encode() []byte

type Capability

+ func NewAddPathCapability(tuples []AddPathTuple) Capability

+ func (c Capability) Equal(d Capability) bool

type DecodeFn

+ func NewNLRIAddPathDecodeFn(fn func(t T, a []AddPathPrefix) error) DecodeFn[T]

+ func NewWithdrawnAddPathRoutesDecodeFn(fn func(t T, a []AddPathPrefix) error) DecodeFn[T]

v0.7.0

Feb 7, 2023

Changes in this version

+ const CAP_SOFTWARE_VERSION

+ const DefaultHoldTimeSeconds

+ const NOTIF_SUBCODE_BFD_DOWN

+ func DecodeMPIPv6Prefixes(b []byte) ([]netip.Prefix, error)

+ func DecodeMPReachIPv6NextHops(nh []byte) ([]netip.Addr, error)

+ type ASPathAttr struct

+ ASSequence []uint32

+ ASSet []uint32

+ func (a *ASPathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type AggregatorPathAttr struct

+ AS uint32

+ IP netip.Addr

+ func (a *AggregatorPathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type AtomicAggregatePathAttr bool

+ func (a *AtomicAggregatePathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type AttrDiscardUpdateErr struct

+ Code uint8

+ Notification *Notification

+ func (a *AttrDiscardUpdateErr) AsSessionReset() *Notification

+ func (a *AttrDiscardUpdateErr) Error() string

+ type ClusterListPathAttr []netip.Addr

+ func (c *ClusterListPathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type CommunitiesPathAttr []uint32

+ func (c *CommunitiesPathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type DecodeFn func(t T, b []byte) error

+ func NewNLRIDecodeFn(fn func(t T, r []netip.Prefix) error) DecodeFn[T]

+ func NewWithdrawnRoutesDecodeFn(fn func(t T, r []netip.Prefix) error) DecodeFn[T]

+ type LocalPrefPathAttr uint32

+ func (l *LocalPrefPathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type MEDPathAttr uint32

+ func (m *MEDPathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type MPPathAttrDecodeFn func(t T, flags PathAttrFlags, b []byte) error

+ func NewMPReachNLRIDecodeFn(fn func(t T, afi uint16, safi uint8, nh, nlri []byte) error) MPPathAttrDecodeFn[T]

+ func NewMPUnreachNLRIDecodeFn(fn func(t T, afi uint16, safi uint8, withdrawn []byte) error) MPPathAttrDecodeFn[T]

+ type NextHopPathAttr netip.Addr

+ func (n *NextHopPathAttr) Decode(flags PathAttrFlags, b []byte) error

type Notification

+ func UpdateNotificationFromErr(err error) *Notification

+ func (n *Notification) AsSessionReset() *Notification

+ func (n *Notification) Error() string

+ type OriginPathAttr uint8

+ func (o *OriginPathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type OriginatorIDPathAttr netip.Addr

+ func (o *OriginatorIDPathAttr) Decode(flags PathAttrFlags, b []byte) error

+ type PathAttrFlags uint8

+ func (p PathAttrFlags) ExtendedLen() bool

+ func (p PathAttrFlags) Optional() bool

+ func (p PathAttrFlags) Partial() bool

+ func (p PathAttrFlags) Transitive() bool

+ func (p PathAttrFlags) Validate(forCode uint8, attrData []byte, wantOptional, wantTransitive bool) error

+ type PathAttrsDecodeFn func(t T, code uint8, flags PathAttrFlags, b []byte) error

+ type TreatAsWithdrawUpdateErr struct

+ Code uint8

+ Notification *Notification

+ func (t *TreatAsWithdrawUpdateErr) AsSessionReset() *Notification

+ func (t *TreatAsWithdrawUpdateErr) Error() string

+ type UpdateDecoder struct

+ func NewUpdateDecoder(wrFn DecodeFn[T], paFn PathAttrsDecodeFn[T], nlriFn DecodeFn[T]) *UpdateDecoder[T]

+ func (s *UpdateDecoder[T]) Decode(t T, b []byte) error

+ type UpdateError interface

+ AsSessionReset func() *Notification

v0.6.0

Dec 27, 2022

Changes in this version

type PeerOption

+ func WithHoldTime(seconds uint16) PeerOption

v0.5.0

Dec 24, 2022

Changes in this version

+ const CAP_BFD

+ const SAFI_BGP_MUP

type PeerOption

+ func WithLocalAddress(localAddress netip.Addr) PeerOption

v0.4.0

Dec 18, 2022

v0.3.0

May 22, 2022

Changes in this version

+ const AFI_48_BIT_MAC

+ const AFI_64_BIT_MAC

+ const AFI_802

+ const AFI_APPLETALK

+ const AFI_AS_NUMBER

+ const AFI_BANYAN_VINES

+ const AFI_BBN_1822

+ const AFI_BGP_LS

+ const AFI_BGP_SFC

+ const AFI_DECNET_IV

+ const AFI_DISTINGUISHED_NAME

+ const AFI_DNS

+ const AFI_E163

+ const AFI_E164

+ const AFI_E164_WITH_NSAP_SUBADDR

+ const AFI_EIGRP_COMMON_SERVICE_FAMILY

+ const AFI_EIGRP_IPV4_SERVICE_FAMILY

+ const AFI_EIGRP_IPV6_SERVICE_FAMILY

+ const AFI_F69

+ const AFI_FIBRE_CHANNEL_WWNN

+ const AFI_FIBRE_CHANNEL_WWPN

+ const AFI_GWID

+ const AFI_HDLC

+ const AFI_IPV4

+ const AFI_IPV6

+ const AFI_IPV6_INITIAL_64_BITS

+ const AFI_IPX

+ const AFI_L2VPN_INFO

+ const AFI_LCAF

+ const AFI_MAC_FINAL_24_BITS

+ const AFI_MAC_FINAL_40_BITS

+ const AFI_MPLS_NAMESPACES

+ const AFI_MPLS_TP_LSP_ENDPOINT_ID

+ const AFI_MPLS_TP_PSEUDOWIRE_ENDPOINT_ID

+ const AFI_MPLS_TP_SECTION_ENDPOINT_ID

+ const AFI_MT_IPV4

+ const AFI_MT_IPV6

+ const AFI_NSAP

+ const AFI_OUI

+ const AFI_RBRIDGE_PORT_ID

+ const AFI_ROUTING_POLICY

+ const AFI_TRILL_NICKNAME

+ const AFI_UUID

+ const AFI_X121

+ const AFI_XTP_NATIVE

+ const AFI_XTP_OVER_IPV4

+ const AFI_XTP_OVER_IPV6

+ const CAP_ADD_PATH

+ const CAP_BGPSEC

+ const CAP_DYNAMIC

+ const CAP_ENHANCED_ROUTE_REFRESH

+ const CAP_EXTENDED_MESSSAGE

+ const CAP_EXTENDED_NEXT_HOP_ENCODING

+ const CAP_FOUR_OCTET_AS

+ const CAP_FQDN

+ const CAP_GRACEFUL_RESTART

+ const CAP_LLGR

+ const CAP_MP_EXTENSIONS

+ const CAP_MULTIPLE_LABELS

+ const CAP_MULTISESSION

+ const CAP_OUTBOUND_ROUTE_FILTERING

+ const CAP_ROLE

+ const CAP_ROUTE_REFRESH

+ const CAP_ROUTING_POLICY_DIST

+ const NOTIF_CODE_CEASE

+ const NOTIF_CODE_FSM_ERR

+ const NOTIF_CODE_HOLD_TIMER_EXPIRED

+ const NOTIF_CODE_MESSAGE_HEADER_ERR

+ const NOTIF_CODE_OPEN_MESSAGE_ERR

+ const NOTIF_CODE_ROUTE_REFRESH_MESSAGE_ERR

+ const NOTIF_CODE_UPDATE_MESSAGE_ERR

+ const NOTIF_SUBCODE_ADMIN_RESET

+ const NOTIF_SUBCODE_ADMIN_SHUTDOWN

+ const NOTIF_SUBCODE_ATTR_FLAGS_ERR

+ const NOTIF_SUBCODE_ATTR_LEN_ERR

+ const NOTIF_SUBCODE_BAD_BGP_ID

+ const NOTIF_SUBCODE_BAD_MESSAGE_LEN

+ const NOTIF_SUBCODE_BAD_MESSAGE_TYPE

+ const NOTIF_SUBCODE_BAD_PEER_AS

+ const NOTIF_SUBCODE_CONN_COLLISION_RESOLUTION

+ const NOTIF_SUBCODE_CONN_NOT_SYNCHRONIZED

+ const NOTIF_SUBCODE_CONN_REJECTED

+ const NOTIF_SUBCODE_HARD_RESET

+ const NOTIF_SUBCODE_INVALID_MESSAGE_LEN

+ const NOTIF_SUBCODE_INVALID_NETWORK_FIELD

+ const NOTIF_SUBCODE_INVALID_NEXT_HOP_ATTR

+ const NOTIF_SUBCODE_INVALID_ORIGIN_ATTR

+ const NOTIF_SUBCODE_MALFORMED_AS_PATH

+ const NOTIF_SUBCODE_MALFORMED_ATTR_LIST

+ const NOTIF_SUBCODE_MAX_NUM_OF_PREFIXES_REACHED

+ const NOTIF_SUBCODE_MISSING_WELL_KNOWN_ATTR

+ const NOTIF_SUBCODE_OPTIONAL_ATTR_ERR

+ const NOTIF_SUBCODE_OTHER_CONFIG_CHANGE

+ const NOTIF_SUBCODE_OUT_OF_RESOURCES

+ const NOTIF_SUBCODE_PEER_DECONFIGURED

+ const NOTIF_SUBCODE_ROLE_MISMATCH

+ const NOTIF_SUBCODE_RX_UNEXPECTED_MESSAGE_ESTABLISHED

+ const NOTIF_SUBCODE_RX_UNEXPECTED_MESSAGE_OPENCONFIRM

+ const NOTIF_SUBCODE_RX_UNEXPECTED_MESSAGE_OPENSENT

+ const NOTIF_SUBCODE_UNACCEPTABLE_HOLD_TIME

+ const NOTIF_SUBCODE_UNRECOGNIZED_WELL_KNOWN_ATTR

+ const NOTIF_SUBCODE_UNSUPPORTED_CAPABILITY

+ const NOTIF_SUBCODE_UNSUPPORTED_OPTIONAL_PARAM

+ const NOTIF_SUBCODE_UNSUPPORTED_VERSION_NUM

+ const PATH_ATTR_AGGREGATOR

+ const PATH_ATTR_AIGP

+ const PATH_ATTR_AS4_AGGREGATOR

+ const PATH_ATTR_AS4_PATH

+ const PATH_ATTR_AS_PATH

+ const PATH_ATTR_ATOMIC_AGGREGATE

+ const PATH_ATTR_ATTR_SET

+ const PATH_ATTR_BFD_DISCRIMINATOR

+ const PATH_ATTR_BGPSEC_PATH

+ const PATH_ATTR_BGP_LS

+ const PATH_ATTR_BGP_PREFIX_SID

+ const PATH_ATTR_CLUSTER_LIST

+ const PATH_ATTR_COMMUNITY

+ const PATH_ATTR_EXTENDED_COMMUNITIES

+ const PATH_ATTR_IPV6_ADDR_SPECIFIC_EXTENDED_COMMUNITY

+ const PATH_ATTR_LARGE_COMMUNITY

+ const PATH_ATTR_LOCAL_PREF

+ const PATH_ATTR_MED

+ const PATH_ATTR_MP_REACH_NLRI

+ const PATH_ATTR_MP_UNREACH_NLRI

+ const PATH_ATTR_NEXT_HOP

+ const PATH_ATTR_ORIGIN

+ const PATH_ATTR_ORIGINATOR_ID

+ const PATH_ATTR_OTC

+ const PATH_ATTR_PE_DISTINGUISHER_LABELS

+ const PATH_ATTR_PMSI_TUNNEL

+ const PATH_ATTR_SFP_ATTR

+ const PATH_ATTR_TRAFFIC_ENGINEERING

+ const PATH_ATTR_TUNNEL_ENCAPSULATION

+ const SAFI_BGP_4OVER6

+ const SAFI_BGP_6OVER4

+ const SAFI_BGP_CAR

+ const SAFI_BGP_DPS

+ const SAFI_BGP_EVPNS

+ const SAFI_BGP_LS

+ const SAFI_BGP_LS_SPF

+ const SAFI_BGP_LS_VPN

+ const SAFI_BGP_MDT

+ const SAFI_BGP_SFC

+ const SAFI_BGP_VPN_CAR

+ const SAFI_CLASSFUL_TRANSPORT

+ const SAFI_DISSEMINATION_OF_FLOWSPEC_RULES

+ const SAFI_DYN_PLACEMENT_MULTI_SEGMENT_PW

+ const SAFI_L3VPN_DISSEMINATION_OF_FLOWSPEC_RULES

+ const SAFI_LAYER_1_VPN_AUTO_DISCOVERY_INFO

+ const SAFI_MCAST_TREE

+ const SAFI_MCAST_VPLS

+ const SAFI_MCAST_VPN

+ const SAFI_MPLS

+ const SAFI_MPLS_LABELED_VPN_ADDR

+ const SAFI_MULTICAST

+ const SAFI_MULTICAST_BGP_MPLS_IP_VPNS

+ const SAFI_ROUTE_TARGET_CONSTRAINS

+ const SAFI_ROUTING_POLICY

+ const SAFI_SD_WAN_CAPABILITIES

+ const SAFI_SR_TE_POLICY

+ const SAFI_TUNNEL

+ const SAFI_TUNNELED_TRAFFIC_FLOWSPEC

+ const SAFI_UNICAST

+ const SAFI_VPLS

+ const SAFI_VPN_AUTO_DISCOVERY

type Capability

+ func NewMPExtensionsCapability(afi uint16, safi uint8) Capability

v0.2.1

May 19, 2022

Changes in this version

+ var ErrPeerAlreadyExists = errors.New("peer already exists")

v0.2.0

Mar 15, 2021

Changes in this version

+ const DefaultConnectRetryTime

+ const DefaultPort

+ var ErrPeerNotExist = errors.New("peer does not exist")

+ func SetTCPMD5Signature(fd int, address net.IP, prefixLen uint8, key string) error

type PeerConfig

+ LocalAddress net.IP

+ RemoteAddress net.IP

type PeerOption

+ func WithConnectRetryTime(t time.Duration) PeerOption

+ func WithDialerControl(fn func(network, address string, c syscall.RawConn) error) PeerOption

+ func WithIdleHoldTime(t time.Duration) PeerOption

+ func WithPassive() PeerOption

+ func WithPort(p int) PeerOption

type Server

+ func (s *Server) GetPeer(ip net.IP) (PeerConfig, error)

+ func (s *Server) ListPeers() []PeerConfig

v0.1.0

Jul 3, 2020

Changes in this version

+ const DefaultHoldTime

+ const DefaultIdleHoldTime

+ const NotifCodeCease

+ const NotifCodeFSMErr

+ const NotifCodeHoldTimerExpired

+ const NotifCodeMessageHeaderErr

+ const NotifCodeOpenMessageErr

+ const NotifCodeUpdateMessageErr

+ const NotifSubcodeAttrFlagsError

+ const NotifSubcodeAttrLenError

+ const NotifSubcodeBadBgpID

+ const NotifSubcodeBadLength

+ const NotifSubcodeBadPeerAS

+ const NotifSubcodeBadType

+ const NotifSubcodeConnNotSync

+ const NotifSubcodeInvalidNetworkField

+ const NotifSubcodeInvalidNextHop

+ const NotifSubcodeInvalidOrigin

+ const NotifSubcodeMalformedASPath

+ const NotifSubcodeMalformedAttr

+ const NotifSubcodeMissingWellKnownAttr

+ const NotifSubcodeOptionalAttrError

+ const NotifSubcodeUnacceptableHoldTime

+ const NotifSubcodeUnexpectedMessageEstablished

+ const NotifSubcodeUnexpectedMessageOpenConfirm

+ const NotifSubcodeUnexpectedMessageOpenSent

+ const NotifSubcodeUnrecognizedWellKnownAttr

+ const NotifSubcodeUnsupportedCapability

+ const NotifSubcodeUnsupportedOptionalParam

+ const NotifSubcodeUnsupportedVersionNumber

+ var ErrServerClosed = errors.New("server closed")

+ func SetLogger(l Logger)

+ type Capability struct

+ Code uint8

+ Value []byte

+ type Logger func(...interface{})

+ type Notification struct

+ Code uint8

+ Data []byte

+ Subcode uint8

+ type PeerConfig struct

+ IP net.IP

+ LocalAS uint32

+ RemoteAS uint32

+ type PeerOption interface

+ func IdleHoldTime(t time.Duration) PeerOption

+ func Passive() PeerOption

+ type Plugin interface

+ GetCapabilities func(peer *PeerConfig) []*Capability

+ OnClose func(peer *PeerConfig)

+ OnEstablished func(peer *PeerConfig, writer UpdateMessageWriter) UpdateMessageHandler

+ OnOpenMessage func(peer *PeerConfig, capabilities []*Capability) *Notification

+ type Server struct

+ func NewServer(routerID net.IP) (*Server, error)

+ func (s *Server) AddPeer(config *PeerConfig, plugin Plugin, opts ...PeerOption) error

+ func (s *Server) Close()

+ func (s *Server) DeletePeer(ip net.IP) error

+ func (s *Server) Serve(lis net.Listener) error

+ type UpdateMessageHandler func(peer *PeerConfig, updateMessage []byte) *Notification

+ type UpdateMessageWriter interface

+ WriteUpdate func([]byte) error

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