table

package
v0.0.0-...-65c99c8 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2016 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	INCLUDE singleAsPathMatchMode = iota
	LEFT_MOST
	ORIGIN
	ONLY
)
View Source 
const (
	ADD opType = iota
	REMOVE
	REPLACE
)
View Source 
const (
	ASPATH_REGEXP_MAGIC = "(^|[,{}() ]|$)"
)
View Source 
const (
	DEFAULT_LOCAL_PREF = 100
)
View Source 
const (
	GLOBAL_RIB_NAME = "global"
)

Variables

View Source 
var CommunityOptionNameMap = map[config.BgpSetCommunityOptionType]string{
	config.BGP_SET_COMMUNITY_OPTION_TYPE_ADD:     "add",
	config.BGP_SET_COMMUNITY_OPTION_TYPE_REMOVE:  "remove",
	config.BGP_SET_COMMUNITY_OPTION_TYPE_REPLACE: "replace",
}
View Source 
var CommunityOptionValueMap = map[string]config.BgpSetCommunityOptionType{
	CommunityOptionNameMap[config.BGP_SET_COMMUNITY_OPTION_TYPE_ADD]:     config.BGP_SET_COMMUNITY_OPTION_TYPE_ADD,
	CommunityOptionNameMap[config.BGP_SET_COMMUNITY_OPTION_TYPE_REMOVE]:  config.BGP_SET_COMMUNITY_OPTION_TYPE_REMOVE,
	CommunityOptionNameMap[config.BGP_SET_COMMUNITY_OPTION_TYPE_REPLACE]: config.BGP_SET_COMMUNITY_OPTION_TYPE_REPLACE,
}
View Source 
var SelectionOptions config.RouteSelectionOptionsConfig
View Source 
var UseMultiplePaths config.UseMultiplePathsConfig

Functions

func CanImportToVrf 

func CanImportToVrf(v *Vrf, path *Path) bool

func CidrToRadixkey 

func CidrToRadixkey(cidr string) string

func CreateUpdateMsgFromPaths 

func CreateUpdateMsgFromPaths(pathList []*Path) []*bgp.BGPMessage

func IpToRadixkey 

func IpToRadixkey(b []byte, max uint8) string

func NewSingleAsPathMatch 

func NewSingleAsPathMatch(arg string) *singleAsPathMatch

func ParseCommunity 

func ParseCommunity(arg string) (uint32, error)

func ParseCommunityRegexp 

func ParseCommunityRegexp(arg string) (*regexp.Regexp, error)

func ParseExtCommunity 

func ParseExtCommunity(arg string) (bgp.ExtendedCommunityInterface, error)

func ParseExtCommunityRegexp 

func ParseExtCommunityRegexp(arg string) (bgp.ExtendedCommunityAttrSubType, *regexp.Regexp, error)

func PoliciesToString 

func PoliciesToString(ps []*api.Policy) []string

func RegexpRemoveCommunities 

func RegexpRemoveCommunities(path *Path, exps []*regexp.Regexp)

func RegexpRemoveExtCommunities 

func RegexpRemoveExtCommunities(path *Path, exps []*regexp.Regexp, subtypes []bgp.ExtendedCommunityAttrSubType)

func UpdatePathAttrs2ByteAs 

func UpdatePathAttrs2ByteAs(msg *bgp.BGPUpdate) error

func UpdatePathAttrs4ByteAs 

func UpdatePathAttrs4ByteAs(msg *bgp.BGPUpdate) error

Types

type Action 

type Action interface {
	Type() ActionType
	Apply(*Path, *PolicyOptions) *Path
}

type ActionType 

type ActionType int
const (
	ACTION_ROUTING ActionType = iota
	ACTION_COMMUNITY
	ACTION_EXT_COMMUNITY
	ACTION_MED
	ACTION_AS_PATH_PREPEND
	ACTION_NEXTHOP
	ACTION_LOCAL_PREF
)

type AdjRib 

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

func NewAdjRib 

func NewAdjRib(id string, rfList []bgp.RouteFamily) *AdjRib

func (*AdjRib) Accepted 

func (adj *AdjRib) Accepted(rfList []bgp.RouteFamily) int

func (*AdjRib) Count 

func (adj *AdjRib) Count(rfList []bgp.RouteFamily) int

func (*AdjRib) Drop 

func (adj *AdjRib) Drop(rfList []bgp.RouteFamily)

func (*AdjRib) DropStale 

func (adj *AdjRib) DropStale(rfList []bgp.RouteFamily) []*Path

func (*AdjRib) Exists 

func (adj *AdjRib) Exists(path *Path) bool

func (*AdjRib) PathList 

func (adj *AdjRib) PathList(rfList []bgp.RouteFamily, accepted bool) []*Path

func (*AdjRib) RefreshAcceptedNumber 

func (adj *AdjRib) RefreshAcceptedNumber(rfList []bgp.RouteFamily)

func (*AdjRib) StaleAll 

func (adj *AdjRib) StaleAll(rfList []bgp.RouteFamily)

func (*AdjRib) Update 

func (adj *AdjRib) Update(pathList []*Path)

type AsPathCondition 

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

func NewAsPathCondition 

func NewAsPathCondition(c config.MatchAsPathSet, m map[string]DefinedSet) (*AsPathCondition, error)

func NewAsPathConditionFromApiStruct 

func NewAsPathConditionFromApiStruct(a *api.MatchSet, m map[string]DefinedSet) (*AsPathCondition, error)

func (*AsPathCondition) Evaluate 

func (c *AsPathCondition) Evaluate(path *Path, _ *PolicyOptions) bool

func (*AsPathCondition) Option 

func (c *AsPathCondition) Option() MatchOption

func (*AsPathCondition) Set 

func (c *AsPathCondition) Set() DefinedSet

func (*AsPathCondition) ToApiStruct 

func (c *AsPathCondition) ToApiStruct() *api.MatchSet

func (*AsPathCondition) Type 

func (c *AsPathCondition) Type() ConditionType

type AsPathLengthCondition 

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

func NewAsPathLengthCondition 

func NewAsPathLengthCondition(c config.AsPathLength) (*AsPathLengthCondition, error)

func NewAsPathLengthConditionFromApiStruct 

func NewAsPathLengthConditionFromApiStruct(a *api.AsPathLength) (*AsPathLengthCondition, error)

func (*AsPathLengthCondition) Evaluate 

func (c *AsPathLengthCondition) Evaluate(path *Path, _ *PolicyOptions) bool

compare AS_PATH length in the message's AS_PATH attribute with the one in condition.

func (*AsPathLengthCondition) Set 

func (c *AsPathLengthCondition) Set() DefinedSet

func (*AsPathLengthCondition) ToApiStruct 

func (c *AsPathLengthCondition) ToApiStruct() *api.AsPathLength

func (*AsPathLengthCondition) Type 

func (c *AsPathLengthCondition) Type() ConditionType

type AsPathPrependAction 

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

func NewAsPathPrependAction 

func NewAsPathPrependAction(action config.SetAsPathPrepend) (*AsPathPrependAction, error)

NewAsPathPrependAction creates AsPathPrependAction object. If ASN cannot be parsed, nil will be returned.

func NewAsPathPrependActionFromApiStruct 

func NewAsPathPrependActionFromApiStruct(a *api.AsPrependAction) (*AsPathPrependAction, error)

func (*AsPathPrependAction) Apply 

func (a *AsPathPrependAction) Apply(path *Path, _ *PolicyOptions) *Path

func (*AsPathPrependAction) ToApiStruct 

func (a *AsPathPrependAction) ToApiStruct() *api.AsPrependAction

func (*AsPathPrependAction) Type 

func (a *AsPathPrependAction) Type() ActionType

type AsPathSet 

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

func NewAsPathSet 

func NewAsPathSet(c config.AsPathSet) (*AsPathSet, error)

func NewAsPathSetFromApiStruct 

func NewAsPathSetFromApiStruct(a *api.DefinedSet) (*AsPathSet, error)

func (*AsPathSet) Append 

func (lhs *AsPathSet) Append(arg DefinedSet) error

func (*AsPathSet) Name 

func (s *AsPathSet) Name() string

func (*AsPathSet) Remove 

func (lhs *AsPathSet) Remove(arg DefinedSet) error

func (*AsPathSet) Replace 

func (lhs *AsPathSet) Replace(arg DefinedSet) error

func (*AsPathSet) ToApiStruct 

func (s *AsPathSet) ToApiStruct() *api.DefinedSet

func (*AsPathSet) Type 

func (s *AsPathSet) Type() DefinedType

type Assignment 

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

type AttributeComparison 

type AttributeComparison int
const (
	// "== comparison"
	ATTRIBUTE_EQ AttributeComparison = iota
	// ">= comparison"
	ATTRIBUTE_GE
	// "<= comparison"
	ATTRIBUTE_LE
)

type BestPathReason 

type BestPathReason string
const (
	BPR_UNKNOWN            BestPathReason = "Unknown"
	BPR_ONLY_PATH          BestPathReason = "Only Path"
	BPR_REACHABLE_NEXT_HOP BestPathReason = "Reachable Next Hop"
	BPR_HIGHEST_WEIGHT     BestPathReason = "Highest Weight"
	BPR_LOCAL_PREF         BestPathReason = "Local Pref"
	BPR_LOCAL_ORIGIN       BestPathReason = "Local Origin"
	BPR_ASPATH             BestPathReason = "AS Path"
	BPR_ORIGIN             BestPathReason = "Origin"
	BPR_MED                BestPathReason = "MED"
	BPR_ASN                BestPathReason = "ASN"
	BPR_IGP_COST           BestPathReason = "IGP Cost"
	BPR_ROUTER_ID          BestPathReason = "Router ID"
	BPR_OLDER              BestPathReason = "Older"
)

type Bitmap 

type Bitmap []uint64

func NewBitmap 

func NewBitmap(size int) Bitmap

func (Bitmap) Flag 

func (b Bitmap) Flag(i uint)

func (Bitmap) GetFlag 

func (b Bitmap) GetFlag(i uint) bool

func (Bitmap) Unflag 

func (b Bitmap) Unflag(i uint)

type CommunityAction 

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

func NewCommunityAction 

func NewCommunityAction(c config.SetCommunity) (*CommunityAction, error)

func NewCommunityActionFromApiStruct 

func NewCommunityActionFromApiStruct(a *api.CommunityAction) (*CommunityAction, error)

func (*CommunityAction) Apply 

func (a *CommunityAction) Apply(path *Path, _ *PolicyOptions) *Path

func (*CommunityAction) ToApiStruct 

func (a *CommunityAction) ToApiStruct() *api.CommunityAction

func (*CommunityAction) Type 

func (a *CommunityAction) Type() ActionType

type CommunityCondition 

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

func NewCommunityCondition 

func NewCommunityCondition(c config.MatchCommunitySet, m map[string]DefinedSet) (*CommunityCondition, error)

func NewCommunityConditionFromApiStruct 

func NewCommunityConditionFromApiStruct(a *api.MatchSet, m map[string]DefinedSet) (*CommunityCondition, error)

func (*CommunityCondition) Evaluate 

func (c *CommunityCondition) Evaluate(path *Path, _ *PolicyOptions) bool

func (*CommunityCondition) Option 

func (c *CommunityCondition) Option() MatchOption

func (*CommunityCondition) Set 

func (c *CommunityCondition) Set() DefinedSet

func (*CommunityCondition) ToApiStruct 

func (c *CommunityCondition) ToApiStruct() *api.MatchSet

func (*CommunityCondition) Type 

func (c *CommunityCondition) Type() ConditionType

type CommunitySet 

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

func NewCommunitySet 

func NewCommunitySet(c config.CommunitySet) (*CommunitySet, error)

func NewCommunitySetFromApiStruct 

func NewCommunitySetFromApiStruct(a *api.DefinedSet) (*CommunitySet, error)

func (*CommunitySet) Append 

func (lhs *CommunitySet) Append(arg DefinedSet) error

func (*CommunitySet) Name 

func (s *CommunitySet) Name() string

func (*CommunitySet) Remove 

func (lhs *CommunitySet) Remove(arg DefinedSet) error

func (*CommunitySet) Replace 

func (lhs *CommunitySet) Replace(arg DefinedSet) error

func (*CommunitySet) ToApiStruct 

func (s *CommunitySet) ToApiStruct() *api.DefinedSet

func (*CommunitySet) Type 

func (s *CommunitySet) Type() DefinedType

type Condition 

type Condition interface {
	Type() ConditionType
	Evaluate(*Path, *PolicyOptions) bool
	Set() DefinedSet
}

type ConditionType 

type ConditionType int
const (
	CONDITION_PREFIX ConditionType = iota
	CONDITION_NEIGHBOR
	CONDITION_AS_PATH
	CONDITION_COMMUNITY
	CONDITION_EXT_COMMUNITY
	CONDITION_AS_PATH_LENGTH
	CONDITION_RPKI
)

type DefinedSet 

type DefinedSet interface {
	Type() DefinedType
	Name() string
	ToApiStruct() *api.DefinedSet
	Append(DefinedSet) error
	Remove(DefinedSet) error
	Replace(DefinedSet) error
}

func NewDefinedSetFromApiStruct 

func NewDefinedSetFromApiStruct(a *api.DefinedSet) (DefinedSet, error)

type DefinedSetMap 

type DefinedSetMap map[DefinedType]map[string]DefinedSet

type DefinedType 

type DefinedType int
const (
	DEFINED_TYPE_PREFIX DefinedType = iota
	DEFINED_TYPE_NEIGHBOR
	DEFINED_TYPE_TAG
	DEFINED_TYPE_AS_PATH
	DEFINED_TYPE_COMMUNITY
	DEFINED_TYPE_EXT_COMMUNITY
)

type Destination 

type Destination struct {
	RadixKey string
	// contains filtered or unexported fields
}

func NewDestination 

func NewDestination(nlri bgp.AddrPrefixInterface) *Destination

func (*Destination) Calculate 

func (dest *Destination) Calculate(ids []string) (map[string]*Path, []*Path, []*Path)

Calculates best-path among known paths for this destination.

Modifies destination's state related to stored paths. Removes withdrawn paths from known paths. Also, adds new paths to known paths.

func (*Destination) Family 

func (dd *Destination) Family() bgp.RouteFamily

func (*Destination) GetAllKnownPathList 

func (dd *Destination) GetAllKnownPathList() []*Path

func (*Destination) GetBestPath 

func (dd *Destination) GetBestPath(id string) *Path

func (*Destination) GetKnownPathList 

func (dd *Destination) GetKnownPathList(id string) []*Path

func (*Destination) GetNlri 

func (dd *Destination) GetNlri() bgp.AddrPrefixInterface

func (*Destination) String 

func (dest *Destination) String() string

func (*Destination) ToApiStruct 

func (dd *Destination) ToApiStruct(id string) *api.Destination

type ExtCommunityAction 

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

func NewExtCommunityAction 

func NewExtCommunityAction(c config.SetExtCommunity) (*ExtCommunityAction, error)

func NewExtCommunityActionFromApiStruct 

func NewExtCommunityActionFromApiStruct(a *api.CommunityAction) (*ExtCommunityAction, error)

func (*ExtCommunityAction) Apply 

func (a *ExtCommunityAction) Apply(path *Path, _ *PolicyOptions) *Path

func (*ExtCommunityAction) ToApiStruct 

func (a *ExtCommunityAction) ToApiStruct() *api.CommunityAction

func (*ExtCommunityAction) Type 

func (a *ExtCommunityAction) Type() ActionType

type ExtCommunityCondition 

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

func NewExtCommunityCondition 

func NewExtCommunityCondition(c config.MatchExtCommunitySet, m map[string]DefinedSet) (*ExtCommunityCondition, error)

func NewExtCommunityConditionFromApiStruct 

func NewExtCommunityConditionFromApiStruct(a *api.MatchSet, m map[string]DefinedSet) (*ExtCommunityCondition, error)

func (*ExtCommunityCondition) Evaluate 

func (c *ExtCommunityCondition) Evaluate(path *Path, _ *PolicyOptions) bool

func (*ExtCommunityCondition) Option 

func (c *ExtCommunityCondition) Option() MatchOption

func (*ExtCommunityCondition) Set 

func (c *ExtCommunityCondition) Set() DefinedSet

func (*ExtCommunityCondition) ToApiStruct 

func (c *ExtCommunityCondition) ToApiStruct() *api.MatchSet

func (*ExtCommunityCondition) Type 

func (c *ExtCommunityCondition) Type() ConditionType

type ExtCommunitySet 

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

func NewExtCommunitySet 

func NewExtCommunitySet(c config.ExtCommunitySet) (*ExtCommunitySet, error)

func NewExtCommunitySetFromApiStruct 

func NewExtCommunitySetFromApiStruct(a *api.DefinedSet) (*ExtCommunitySet, error)

func (*ExtCommunitySet) Append 

func (lhs *ExtCommunitySet) Append(arg DefinedSet) error

func (*ExtCommunitySet) Name 

func (s *ExtCommunitySet) Name() string

func (*ExtCommunitySet) Remove 

func (lhs *ExtCommunitySet) Remove(arg DefinedSet) error

func (*ExtCommunitySet) Replace 

func (lhs *ExtCommunitySet) Replace(arg DefinedSet) error

func (*ExtCommunitySet) ToApiStruct 

func (s *ExtCommunitySet) ToApiStruct() *api.DefinedSet

func (*ExtCommunitySet) Type 

func (s *ExtCommunitySet) Type() DefinedType

type FlowSpecComponents 

type FlowSpecComponents []bgp.FlowSpecComponentInterface

func (FlowSpecComponents) Len 

func (c FlowSpecComponents) Len() int

func (FlowSpecComponents) Less 

func (c FlowSpecComponents) Less(i, j int) bool

func (FlowSpecComponents) Swap 

func (c FlowSpecComponents) Swap(i, j int)

type LocalPrefAction 

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

func NewLocalPrefAction 

func NewLocalPrefAction(value uint32) (*LocalPrefAction, error)

func NewLocalPrefActionFromApiStruct 

func NewLocalPrefActionFromApiStruct(a *api.LocalPrefAction) (*LocalPrefAction, error)

func (*LocalPrefAction) Apply 

func (a *LocalPrefAction) Apply(path *Path, _ *PolicyOptions) *Path

func (*LocalPrefAction) ToApiStruct 

func (a *LocalPrefAction) ToApiStruct() *api.LocalPrefAction

func (*LocalPrefAction) Type 

func (a *LocalPrefAction) Type() ActionType

type MatchOption 

type MatchOption int
const (
	MATCH_OPTION_ANY MatchOption = iota
	MATCH_OPTION_ALL
	MATCH_OPTION_INVERT
)

func NewMatchOption 

func NewMatchOption(c interface{}) (MatchOption, error)

func (MatchOption) String 

func (o MatchOption) String() string

type MedAction 

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

func NewMedAction 

func NewMedAction(c config.BgpSetMedType) (*MedAction, error)

func NewMedActionFromApiStruct 

func NewMedActionFromApiStruct(a *api.MedAction) (*MedAction, error)

func (*MedAction) Apply 

func (a *MedAction) Apply(path *Path, _ *PolicyOptions) *Path

func (*MedAction) ToApiStruct 

func (a *MedAction) ToApiStruct() *api.MedAction

func (*MedAction) Type 

func (a *MedAction) Type() ActionType

type MedActionType 

type MedActionType int
const (
	MED_ACTION_MOD MedActionType = iota
	MED_ACTION_REPLACE
)

type NeighborCondition 

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

func NewNeighborCondition 

func NewNeighborCondition(c config.MatchNeighborSet, m map[string]DefinedSet) (*NeighborCondition, error)

func NewNeighborConditionFromApiStruct 

func NewNeighborConditionFromApiStruct(a *api.MatchSet, m map[string]DefinedSet) (*NeighborCondition, error)

func (*NeighborCondition) Evaluate 

func (c *NeighborCondition) Evaluate(path *Path, options *PolicyOptions) bool

compare neighbor ipaddress of this condition and source address of path and, subsequent comparisons are skipped if that matches the conditions. If NeighborList's length is zero, return true.

func (*NeighborCondition) Option 

func (c *NeighborCondition) Option() MatchOption

func (*NeighborCondition) Set 

func (c *NeighborCondition) Set() DefinedSet

func (*NeighborCondition) ToApiStruct 

func (c *NeighborCondition) ToApiStruct() *api.MatchSet

func (*NeighborCondition) Type 

func (c *NeighborCondition) Type() ConditionType

type NeighborSet 

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

func NewNeighborSet 

func NewNeighborSet(c config.NeighborSet) (*NeighborSet, error)

func NewNeighborSetFromApiStruct 

func NewNeighborSetFromApiStruct(a *api.DefinedSet) (*NeighborSet, error)

func (*NeighborSet) Append 

func (lhs *NeighborSet) Append(arg DefinedSet) error

func (*NeighborSet) Name 

func (s *NeighborSet) Name() string

func (*NeighborSet) Remove 

func (lhs *NeighborSet) Remove(arg DefinedSet) error

func (*NeighborSet) Replace 

func (lhs *NeighborSet) Replace(arg DefinedSet) error

func (*NeighborSet) ToApiStruct 

func (s *NeighborSet) ToApiStruct() *api.DefinedSet

func (*NeighborSet) Type 

func (s *NeighborSet) Type() DefinedType

type NexthopAction 

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

func NewNexthopAction 

func NewNexthopAction(c config.BgpNextHopType) (*NexthopAction, error)

func NewNexthopActionFromApiStruct 

func NewNexthopActionFromApiStruct(a *api.NexthopAction) (*NexthopAction, error)

func (*NexthopAction) Apply 

func (a *NexthopAction) Apply(path *Path, options *PolicyOptions) *Path

func (*NexthopAction) ToApiStruct 

func (a *NexthopAction) ToApiStruct() *api.NexthopAction

func (*NexthopAction) Type 

func (a *NexthopAction) Type() ActionType

type Path 

type Path struct {
	IsWithdraw bool
	// contains filtered or unexported fields
}

func NewEOR 

func NewEOR(family bgp.RouteFamily) *Path

func NewPath 

func NewPath(source *PeerInfo, nlri bgp.AddrPrefixInterface, isWithdraw bool, pattrs []bgp.PathAttributeInterface, timestamp time.Time, noImplicitWithdraw bool) *Path

func ProcessMessage 

func ProcessMessage(m *bgp.BGPMessage, peerInfo *PeerInfo, timestamp time.Time) []*Path

func (*Path) Clone 

func (path *Path) Clone(isWithdraw bool) *Path

create new PathAttributes

func (*Path) Compare 

func (lhs *Path) Compare(rhs *Path) int

func (*Path) Equal 

func (lhs *Path) Equal(rhs *Path) bool

func (*Path) Filter 

func (path *Path) Filter(id string, reason PolicyDirection)

func (*Path) Filtered 

func (path *Path) Filtered(id string) PolicyDirection

func (*Path) GetAsList 

func (path *Path) GetAsList() []uint32

func (*Path) GetAsPath 

func (path *Path) GetAsPath() *bgp.PathAttributeAsPath

func (*Path) GetAsPathLen 

func (path *Path) GetAsPathLen() int

GetAsPathLen returns the number of AS_PATH

func (*Path) GetAsSeqList 

func (path *Path) GetAsSeqList() []uint32

func (*Path) GetAsString 

func (path *Path) GetAsString() string

func (*Path) GetClusterList 

func (path *Path) GetClusterList() []net.IP

func (*Path) GetCommunities 

func (path *Path) GetCommunities() []uint32

func (*Path) GetExtCommunities 

func (path *Path) GetExtCommunities() []bgp.ExtendedCommunityInterface

func (*Path) GetLocalPref 

func (path *Path) GetLocalPref() (uint32, error)

func (*Path) GetMed 

func (path *Path) GetMed() (uint32, error)

func (*Path) GetNexthop 

func (path *Path) GetNexthop() net.IP

func (*Path) GetNlri 

func (path *Path) GetNlri() bgp.AddrPrefixInterface

func (*Path) GetOrigin 

func (path *Path) GetOrigin() (uint8, error)

func (*Path) GetOriginatorID 

func (path *Path) GetOriginatorID() net.IP

func (*Path) GetPathAttrs 

func (path *Path) GetPathAttrs() []bgp.PathAttributeInterface

func (*Path) GetRouteFamily 

func (path *Path) GetRouteFamily() bgp.RouteFamily

func (*Path) GetSource 

func (path *Path) GetSource() *PeerInfo

func (*Path) GetSourceAs 

func (path *Path) GetSourceAs() uint32

func (*Path) GetTimestamp 

func (path *Path) GetTimestamp() time.Time

func (*Path) IsEOR 

func (path *Path) IsEOR() bool

func (*Path) IsFromExternal 

func (path *Path) IsFromExternal() bool

func (*Path) IsIBGP 

func (path *Path) IsIBGP() bool

func (*Path) IsLocal 

func (path *Path) IsLocal() bool

func (*Path) IsStale 

func (path *Path) IsStale() bool

func (*Path) MarkStale 

func (path *Path) MarkStale(s bool)

func (*Path) NoImplicitWithdraw 

func (path *Path) NoImplicitWithdraw() bool

func (*Path) OriginInfo 

func (path *Path) OriginInfo() *originInfo

func (*Path) PrependAsn 

func (path *Path) PrependAsn(asn uint32, repeat uint8)

PrependAsn prepends AS number. This function updates the AS_PATH attribute as follows.

  1. if the first path segment of the AS_PATH is of type AS_SEQUENCE, the local system prepends the specified AS num as the last element of the sequence (put it in the left-most position with respect to the position of octets in the protocol message) the specified number of times. If the act of prepending will cause an overflow in the AS_PATH segment (i.e., more than 255 ASes), it SHOULD prepend a new segment of type AS_SEQUENCE and prepend its own AS number to this new segment.

  2. if the first path segment of the AS_PATH is of other than type AS_SEQUENCE, the local system prepends a new path segment of type AS_SEQUENCE to the AS_PATH, including the specified AS number in that segment.

  3. if the AS_PATH is empty, the local system creates a path segment of type AS_SEQUENCE, places the specified AS number into that segment, and places that segment into the AS_PATH.

func (*Path) RemoveCommunities 

func (path *Path) RemoveCommunities(communities []uint32) int

RemoveCommunities removes specific communities. If the length of communites is 0, it does nothing. If all communities are removed, it removes Communities path attribute itself.

func (*Path) RemoveLocalPref 

func (path *Path) RemoveLocalPref()

func (*Path) SetCommunities 

func (path *Path) SetCommunities(communities []uint32, doReplace bool)

SetCommunities adds or replaces communities with new ones. If the length of communities is 0 and doReplace is true, it clears communities.

func (*Path) SetExtCommunities 

func (path *Path) SetExtCommunities(exts []bgp.ExtendedCommunityInterface, doReplace bool)

func (*Path) SetIsFromExternal 

func (path *Path) SetIsFromExternal(y bool)

func (*Path) SetMed 

func (path *Path) SetMed(med int64, doReplace bool) error

SetMed replace, add or subtraction med with new ones.

func (*Path) SetNexthop 

func (path *Path) SetNexthop(nexthop net.IP)

func (*Path) SetUUID 

func (path *Path) SetUUID(uuid []byte)

func (*Path) SetValidation 

func (path *Path) SetValidation(r config.RpkiValidationResultType)

func (*Path) String 

func (path *Path) String() string

return Path's string representation

func (*Path) ToApiStruct 

func (path *Path) ToApiStruct(id string) *api.Path

func (*Path) UUID 

func (path *Path) UUID() []byte

func (*Path) UpdatePathAttrs 

func (path *Path) UpdatePathAttrs(global *config.Global, peer *config.Neighbor)

func (*Path) Validation 

func (path *Path) Validation() config.RpkiValidationResultType

type PathAttrs 

type PathAttrs []bgp.PathAttributeInterface

func (PathAttrs) Len 

func (a PathAttrs) Len() int

func (PathAttrs) Less 

func (a PathAttrs) Less(i, j int) bool

func (PathAttrs) Swap 

func (a PathAttrs) Swap(i, j int)

type PeerInfo 

type PeerInfo struct {
	AS                      uint32
	ID                      net.IP
	LocalAS                 uint32
	LocalID                 net.IP
	Address                 net.IP
	LocalAddress            net.IP
	RouteReflectorClient    bool
	RouteReflectorClusterID net.IP
}

func NewPeerInfo 

func NewPeerInfo(g *config.Global, p *config.Neighbor) *PeerInfo

func (*PeerInfo) Equal 

func (lhs *PeerInfo) Equal(rhs *PeerInfo) bool

func (*PeerInfo) String 

func (i *PeerInfo) String() string

type Policy 

type Policy struct {
	Statements []*Statement
	// contains filtered or unexported fields
}

func NewPolicy 

func NewPolicy(c config.PolicyDefinition, dmap DefinedSetMap) (*Policy, error)

func NewPolicyFromApiStruct 

func NewPolicyFromApiStruct(a *api.Policy, dmap DefinedSetMap) (*Policy, error)

func (*Policy) Add 

func (lhs *Policy) Add(rhs *Policy) error

func (*Policy) Apply 

func (p *Policy) Apply(path *Path, options *PolicyOptions) (RouteType, *Path)

Compare path with a policy's condition in stored order in the policy. If a condition match, then this function stops evaluation and subsequent conditions are skipped.

func (*Policy) FillUp 

func (p *Policy) FillUp(m map[string]*Statement) error

func (*Policy) Name 

func (p *Policy) Name() string

func (*Policy) Remove 

func (lhs *Policy) Remove(rhs *Policy) error

func (*Policy) Replace 

func (lhs *Policy) Replace(rhs *Policy) error

func (*Policy) ToApiStruct 

func (p *Policy) ToApiStruct() *api.Policy

type PolicyDirection 

type PolicyDirection int
const (
	POLICY_DIRECTION_NONE PolicyDirection = iota
	POLICY_DIRECTION_IN
	POLICY_DIRECTION_IMPORT
	POLICY_DIRECTION_EXPORT
)

func (PolicyDirection) String 

func (d PolicyDirection) String() string

type PolicyOptions 

type PolicyOptions struct {
	Info *PeerInfo
}

type Prefix 

type Prefix struct {
	Prefix             *net.IPNet
	AddressFamily      bgp.RouteFamily
	MasklengthRangeMax uint8
	MasklengthRangeMin uint8
}

func NewPrefix 

func NewPrefix(c config.Prefix) (*Prefix, error)

func NewPrefixFromApiStruct 

func NewPrefixFromApiStruct(a *api.Prefix) (*Prefix, error)

func (*Prefix) Equal 

func (lhs *Prefix) Equal(rhs *Prefix) bool

func (*Prefix) Match 

func (p *Prefix) Match(path *Path) bool

func (*Prefix) ToApiStruct 

func (p *Prefix) ToApiStruct() *api.Prefix

type PrefixCondition 

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

func NewPrefixCondition 

func NewPrefixCondition(c config.MatchPrefixSet, m map[string]DefinedSet) (*PrefixCondition, error)

func NewPrefixConditionFromApiStruct 

func NewPrefixConditionFromApiStruct(a *api.MatchSet, m map[string]DefinedSet) (*PrefixCondition, error)

func (*PrefixCondition) Evaluate 

func (c *PrefixCondition) Evaluate(path *Path, _ *PolicyOptions) bool

compare prefixes in this condition and nlri of path and subsequent comparison is skipped if that matches the conditions. If PrefixList's length is zero, return true.

func (*PrefixCondition) Option 

func (c *PrefixCondition) Option() MatchOption

func (*PrefixCondition) Set 

func (c *PrefixCondition) Set() DefinedSet

func (*PrefixCondition) ToApiStruct 

func (c *PrefixCondition) ToApiStruct() *api.MatchSet

func (*PrefixCondition) Type 

func (c *PrefixCondition) Type() ConditionType

type PrefixSet 

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

func NewPrefixSet 

func NewPrefixSet(c config.PrefixSet) (*PrefixSet, error)

func NewPrefixSetFromApiStruct 

func NewPrefixSetFromApiStruct(a *api.DefinedSet) (*PrefixSet, error)

func (*PrefixSet) Append 

func (lhs *PrefixSet) Append(arg DefinedSet) error

func (*PrefixSet) Name 

func (s *PrefixSet) Name() string

func (*PrefixSet) Remove 

func (lhs *PrefixSet) Remove(arg DefinedSet) error

func (*PrefixSet) Replace 

func (lhs *PrefixSet) Replace(arg DefinedSet) error

func (*PrefixSet) ToApiStruct 

func (s *PrefixSet) ToApiStruct() *api.DefinedSet

func (*PrefixSet) Type 

func (s *PrefixSet) Type() DefinedType

type RouteType 

type RouteType int
const (
	ROUTE_TYPE_NONE RouteType = iota
	ROUTE_TYPE_ACCEPT
	ROUTE_TYPE_REJECT
)

func (RouteType) ToApiStruct 

func (t RouteType) ToApiStruct() api.RouteAction

type RoutingAction 

type RoutingAction struct {
	AcceptRoute bool
}

func NewRoutingAction 

func NewRoutingAction(c config.RouteDisposition) (*RoutingAction, error)

func NewRoutingActionFromApiStruct 

func NewRoutingActionFromApiStruct(a api.RouteAction) (*RoutingAction, error)

func (*RoutingAction) Apply 

func (a *RoutingAction) Apply(path *Path, _ *PolicyOptions) *Path

func (*RoutingAction) ToApiStruct 

func (a *RoutingAction) ToApiStruct() api.RouteAction

func (*RoutingAction) Type 

func (a *RoutingAction) Type() ActionType

type RoutingPolicy 

type RoutingPolicy struct {
	DefinedSetMap DefinedSetMap
	PolicyMap     map[string]*Policy
	StatementMap  map[string]*Statement
	AssignmentMap map[string]*Assignment
}

func NewRoutingPolicy 

func NewRoutingPolicy() *RoutingPolicy

func (*RoutingPolicy) ApplyPolicy 

func (r *RoutingPolicy) ApplyPolicy(id string, dir PolicyDirection, before *Path, options *PolicyOptions) *Path

func (*RoutingPolicy) GetAssignmentFromConfig 

func (r *RoutingPolicy) GetAssignmentFromConfig(dir PolicyDirection, a config.ApplyPolicy) ([]*Policy, RouteType, error)

func (*RoutingPolicy) GetDefaultPolicy 

func (r *RoutingPolicy) GetDefaultPolicy(id string, dir PolicyDirection) RouteType

func (*RoutingPolicy) GetPolicy 

func (r *RoutingPolicy) GetPolicy(id string, dir PolicyDirection) []*Policy

func (*RoutingPolicy) InUse 

func (r *RoutingPolicy) InUse(d DefinedSet) bool

func (*RoutingPolicy) Reload 

func (r *RoutingPolicy) Reload(c config.RoutingPolicy) error

func (*RoutingPolicy) SetDefaultPolicy 

func (r *RoutingPolicy) SetDefaultPolicy(id string, dir PolicyDirection, typ RouteType) error

func (*RoutingPolicy) SetPolicy 

func (r *RoutingPolicy) SetPolicy(id string, dir PolicyDirection, policies []*Policy) error

func (*RoutingPolicy) StatementInUse 

func (r *RoutingPolicy) StatementInUse(x *Statement) bool

type RpkiValidationCondition 

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

func NewRpkiValidationCondition 

func NewRpkiValidationCondition(c config.RpkiValidationResultType) (*RpkiValidationCondition, error)

func NewRpkiValidationConditionFromApiStruct 

func NewRpkiValidationConditionFromApiStruct(a int32) (*RpkiValidationCondition, error)

func (*RpkiValidationCondition) Evaluate 

func (c *RpkiValidationCondition) Evaluate(path *Path, _ *PolicyOptions) bool

func (*RpkiValidationCondition) Set 

func (c *RpkiValidationCondition) Set() DefinedSet

func (*RpkiValidationCondition) Type 

func (c *RpkiValidationCondition) Type() ConditionType

type Statement 

type Statement struct {
	Name        string
	Conditions  []Condition
	RouteAction Action
	ModActions  []Action
}

func NewStatement 

func NewStatement(c config.Statement, dmap DefinedSetMap) (*Statement, error)

func NewStatementFromApiStruct 

func NewStatementFromApiStruct(a *api.Statement, dmap DefinedSetMap) (*Statement, error)

func (*Statement) Add 

func (lhs *Statement) Add(rhs *Statement) error

func (*Statement) Apply 

func (s *Statement) Apply(path *Path, options *PolicyOptions) (RouteType, *Path)

func (*Statement) Evaluate 

func (s *Statement) Evaluate(p *Path, options *PolicyOptions) bool

evaluate each condition in the statement according to MatchSetOptions

func (*Statement) Remove 

func (lhs *Statement) Remove(rhs *Statement) error

func (*Statement) Replace 

func (lhs *Statement) Replace(rhs *Statement) error

func (*Statement) ToApiStruct 

func (s *Statement) ToApiStruct() *api.Statement

type Table 

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

func NewTable 

func NewTable(rf bgp.RouteFamily) *Table

func (*Table) Bests 

func (t *Table) Bests(id string) []*Path

func (*Table) DeleteDestByPeer 

func (t *Table) DeleteDestByPeer(peerInfo *PeerInfo) []*Destination

func (*Table) GetDestination 

func (t *Table) GetDestination(key string) *Destination

func (*Table) GetDestinations 

func (t *Table) GetDestinations() map[string]*Destination

func (*Table) GetKnownPathList 

func (t *Table) GetKnownPathList(id string) []*Path

func (*Table) GetRoutefamily 

func (t *Table) GetRoutefamily() bgp.RouteFamily

func (*Table) GetSortedDestinations 

func (t *Table) GetSortedDestinations() []*Destination

type TableManager 

type TableManager struct {
	Tables map[bgp.RouteFamily]*Table
	Vrfs   map[string]*Vrf
	// contains filtered or unexported fields
}

func NewTableManager 

func NewTableManager(rfList []bgp.RouteFamily, minLabel, maxLabel uint32) *TableManager

func (*TableManager) AddVrf 

func (manager *TableManager) AddVrf(name string, rd bgp.RouteDistinguisherInterface, importRt, exportRt []bgp.ExtendedCommunityInterface, info *PeerInfo) ([]*Path, error)

func (*TableManager) DeletePathsByPeer 

func (manager *TableManager) DeletePathsByPeer(ids []string, info *PeerInfo, rf bgp.RouteFamily) (map[string][]*Path, []*Path, [][]*Path)

func (*TableManager) DeleteVrf 

func (manager *TableManager) DeleteVrf(name string) ([]*Path, error)

func (*TableManager) GetBestPathList 

func (manager *TableManager) GetBestPathList(id string, rfList []bgp.RouteFamily) []*Path

func (*TableManager) GetDestination 

func (manager *TableManager) GetDestination(path *Path) *Destination

func (*TableManager) GetNextLabel 

func (manager *TableManager) GetNextLabel(name, nexthop string, isWithdraw bool) (uint32, error)

func (*TableManager) GetPathList 

func (manager *TableManager) GetPathList(id string, rfList []bgp.RouteFamily) []*Path

func (*TableManager) GetRFlist 

func (manager *TableManager) GetRFlist() []bgp.RouteFamily

func (*TableManager) ProcessPaths 

func (manager *TableManager) ProcessPaths(ids []string, pathList []*Path) (map[string][]*Path, []*Path, [][]*Path)

type Vrf 

type Vrf struct {
	Name     string
	Rd       bgp.RouteDistinguisherInterface
	ImportRt []bgp.ExtendedCommunityInterface
	ExportRt []bgp.ExtendedCommunityInterface
	LabelMap map[string]uint32
}

func (*Vrf) ToApiStruct 

func (v *Vrf) ToApiStruct() *api.Vrf

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.