topology

package

Go to main page

Versions in this module

v0

v0.7.0

Mar 12, 2022

Changes in this version

+ func Digest(t interface{}) ([]byte, error)

+ type ControlValidator struct

+ ID string

+ func (v *ControlValidator) Validate(new, old *RWTopology) error

+ type DefaultValidator struct

+ func (v *DefaultValidator) Validate(new, old *RWTopology) error

type GatewayInfo

+ ProbeAddr *net.UDPAddr

type LinkType

+ func (l *LinkType) UnmarshalText(data []byte) error

+ func (l LinkType) MarshalText() ([]byte, error)

+ type Loader struct

+ func NewLoader(cfg LoaderCfg) (*Loader, error)

+ func (l *Loader) CA() bool

+ func (l *Loader) ControlServiceAddress(id string) *net.UDPAddr

+ func (l *Loader) ControlServiceAddresses() []*net.UDPAddr

+ func (l *Loader) Core() bool

+ func (l *Loader) Gateways() ([]GatewayInfo, error)

+ func (l *Loader) Get() Topology

+ func (l *Loader) GetUnderlay(svc addr.HostSVC) (*net.UDPAddr, error)

+ func (l *Loader) HandleHTTP(w http.ResponseWriter, r *http.Request)

+ func (l *Loader) HiddenSegmentLookupAddresses() ([]*net.UDPAddr, error)

+ func (l *Loader) HiddenSegmentRegistrationAddresses() ([]*net.UDPAddr, error)

+ func (l *Loader) IA() addr.IA

+ func (l *Loader) InterfaceIDs() []uint16

+ func (l *Loader) InterfaceInfoMap() map[common.IFIDType]IFInfo

+ func (l *Loader) MTU() uint16

+ func (l *Loader) Run(ctx context.Context) error

+ func (l *Loader) Subscribe() *Subscription

+ func (l *Loader) UnderlayNextHop(ifID uint16) *net.UDPAddr

+ type LoaderCfg struct

+ File string

+ Metrics LoaderMetrics

+ Reload <-chan struct{}

+ Validator Validator

+ type LoaderMetrics struct

+ LastUpdate metrics.Gauge

+ ReadErrors metrics.Counter

+ Updates metrics.Counter

+ ValidationErrors metrics.Counter

+ type RouterValidator struct

+ ID string

+ func (v *RouterValidator) Validate(new, old *RWTopology) error

+ type Subscription struct

+ Updates <-chan struct{}

+ func (s *Subscription) Close()

type Topology

+ func FromJSONBytes(raw []byte) (Topology, error)

+ type Validator interface

+ Validate func(new, old *RWTopology) error

v0.6.0

Dec 4, 2020

Changes in this version

+ const Control

+ const Discovery

+ const Gateway

+ const HiddenSegmentLookup

+ const HiddenSegmentRegistration

+ const Router

+ const Unknown

+ var ErrAddressNotFound = serrors.New("address not found")

+ type BFD struct

+ DesiredMinTxInterval time.Duration

+ DetectMult uint8

+ Disable bool

+ RequiredMinRxInterval time.Duration

+ type GatewayInfo struct

+ AllowInterfaces []uint64

+ CtrlAddr *TopoAddr

+ DataAddr *net.UDPAddr

type IFInfo

+ BFD BFD

type RWTopology

+ DS IDAddrMap

+ HiddenSegmentLookup IDAddrMap

+ HiddenSegmentRegistration IDAddrMap

+ func (t *RWTopology) Copy() *RWTopology

+ type ServiceType int

+ func ServiceTypeFromString(s string) ServiceType

+ func (t ServiceType) String() string

type Topology

+ CA func() bool

+ Gateways func() ([]GatewayInfo, error)

+ Multicast func(svc addr.HostSVC) ([]*net.UDPAddr, error)

+ UnderlayAnycast func(svc addr.HostSVC) (*net.UDPAddr, error)

+ UnderlayByName func(svc addr.HostSVC, name string) (*net.UDPAddr, error)

+ UnderlayMulticast func(svc addr.HostSVC) ([]*net.UDPAddr, error)

+ UnderlayNextHop func(ifID common.IFIDType) (*net.UDPAddr, bool)

+ UnderlayNextHop2 func(ifID common.IFIDType) (*net.UDPAddr, bool)

v0.5.0

Mar 30, 2020

Changes in this version

+ const EndhostPort

type BRInfo

+ InternalAddr *net.UDPAddr

type IDAddrMap

+ func (m IDAddrMap) GetByID(id string) *TopoAddr

type IFInfo

+ IA addr.IA

+ ID common.IFIDType

+ Underlay overlay.Type

+ func (i IFInfo) CheckLinks(isCore bool, brName string) error

+ type LinkType int

+ const Child

+ const Core

+ const Parent

+ const Peer

+ const Unset

+ func (lt LinkType) String() string

+ type RWTopology struct

+ Attributes trc.Attributes

+ BR map[string]BRInfo

+ BRNames []string

+ CS IDAddrMap

+ IA addr.IA

+ IFInfoMap IfInfoMap

+ MTU int

+ SIG IDAddrMap

+ TTL time.Duration

+ Timestamp time.Time

+ func NewRWTopology() *RWTopology

+ func RWTopologyFromJSONBytes(b common.RawBytes) (*RWTopology, error)

+ func RWTopologyFromJSONFile(path string) (*RWTopology, error)

+ func RWTopologyFromJSONTopology(raw *jsontopo.Topology) (*RWTopology, error)

+ func (t *RWTopology) Active(now time.Time) bool

+ func (t *RWTopology) Expiry() time.Time

+ func (t *RWTopology) GetAllTopoAddrs(svc proto.ServiceType) ([]TopoAddr, error)

+ func (t *RWTopology) GetTopoAddr(id string, svc proto.ServiceType) (*TopoAddr, error)

type TopoAddr

+ SCIONAddress *net.UDPAddr

+ UnderlayAddress *net.UDPAddr

+ func (a *TopoAddr) UnderlayAddr() *net.UDPAddr

+ type Topology interface

+ Anycast func(svc addr.HostSVC) (*net.TCPAddr, error)

+ BR func(name string) (BRInfo, bool)

+ BRNames func() []string

+ Core func() bool

+ Exists func(svc addr.HostSVC, name string) bool

+ IA func() addr.IA

+ IFInfoMap func() IfInfoMap

+ InterfaceIDs func() []common.IFIDType

+ MTU func() uint16

+ MakeHostInfos func(st proto.ServiceType) []net.UDPAddr

+ OverlayAnycast func(svc addr.HostSVC) (*net.UDPAddr, error)

+ OverlayByName func(svc addr.HostSVC, name string) (*net.UDPAddr, error)

+ OverlayMulticast func(svc addr.HostSVC) ([]*net.UDPAddr, error)

+ OverlayNextHop func(ifID common.IFIDType) (*net.UDPAddr, bool)

+ OverlayNextHop2 func(ifID common.IFIDType) (*net.UDPAddr, bool)

+ PublicAddress func(svc addr.HostSVC, name string) *net.UDPAddr

+ SBRAddress func(name string) *snet.UDPAddr

+ SVCNames func(svc addr.HostSVC) ServiceNames

+ Writable func() *RWTopology

+ func FromJSONFile(path string) (Topology, error)

+ func FromRWTopology(topo *RWTopology) Topology

+ func NewTopology() Topology

v0.4.0

Nov 14, 2019

Changes in this version

+ const ErrConvert

+ const ErrOpen

+ const ErrParse

type BRInfo

+ CtrlAddrs *TopoAddr

+ IFs map[common.IFIDType]*IFInfo

+ InternalAddrs *TopoBRAddr

+ Name string

type IFInfo

+ Id common.IFIDType

+ type IfInfoMap map[common.IFIDType]IFInfo

+ type OverBindAddr struct

+ BindOverlay *overlay.OverlayAddr

+ PublicOverlay *overlay.OverlayAddr

+ func (a *OverBindAddr) String() string

+ func (t *OverBindAddr) BindOrPublicOverlay() *overlay.OverlayAddr

+ func (t1 *OverBindAddr) Equal(t2 *OverBindAddr) bool

+ type Provider interface

+ Get func() *Topo

type RawTopo

+ SIG map[string]*RawSrvInfo

+ TTL uint32

type Topo

+ SIG IDAddrMap

+ SIGNames ServiceNames

+ TTL time.Duration

+ func (t *Topo) Active(now time.Time) bool

+ func (t *Topo) Expiry() time.Time

+ func (t *Topo) GetAnyTopoAddr(svc proto.ServiceType) (*TopoAddr, error)

v0.3.1

Sep 24, 2018

Changes in this version

+ type SVCInfo struct

+ func (svc *SVCInfo) GetAllTopoAddrs() []TopoAddr

+ func (svc *SVCInfo) GetAnyTopoAddr() *TopoAddr

type Topo

+ func (t *Topo) GetAllTopoAddrs(svc proto.ServiceType) ([]TopoAddr, error)

+ func (t *Topo) GetSvcInfo(svc proto.ServiceType) (*SVCInfo, error)

type TopoAddr

+ func TestTopoAddr(v4AppAddr, v6AppAddr *addr.AppAddr, ...) TopoAddr

v0.3.0

Sep 19, 2018

Changes in this version

+ const ErrMismatchBindAddrType

+ const ErrMismatchOverlayAddr

+ const ErrMismatchPubAddrType

+ const ErrUnsupportedAddrType

+ const ErrUnsupportedOverlay

+ type IDAddrMap map[string]TopoAddr

+ func (m IDAddrMap) GetById(id string) *TopoAddr

type IFInfo

+ CtrlAddrs *TopoAddr

+ InternalAddrs *TopoBRAddr

+ func (i IFInfo) Verify(isCore bool, brName string) error

+ type RawAddr struct

+ Addr string

+ func (a RawAddr) String() string

+ type RawAddrMap map[string]*RawPubBindOverlay

+ func (ram RawAddrMap) String() string

+ func (ram RawAddrMap) ToTopoAddr(ot overlay.Type) (t *TopoAddr, err error)

+ type RawAddrOverlay struct

+ Addr string

+ OverlayPort int

+ func (a RawAddrOverlay) String() string

+ type RawBRAddrMap map[string]*RawOverlayBind

+ func (roa RawBRAddrMap) String() string

+ func (roa RawBRAddrMap) ToTopoBRAddr(ot overlay.Type) (t *TopoBRAddr, err error)

type RawBRInfo

+ CtrlAddr RawAddrMap

+ InternalAddrs RawBRAddrMap

type RawBRIntf

+ BindOverlay *RawAddr

+ PublicOverlay *RawAddrOverlay

+ RemoteOverlay *RawAddrOverlay

+ type RawOverlayBind struct

+ BindOverlay *RawAddr

+ PublicOverlay RawAddrOverlay

+ func (b RawOverlayBind) String() string

+ type RawPubBindOverlay struct

+ Bind *RawAddrPort

+ Public RawAddrPortOverlay

+ func (rpbo RawPubBindOverlay) String() string

+ type RawSrvInfo struct

+ Addrs RawAddrMap

+ func (ras RawSrvInfo) String() string

+ type ServiceNames []string

+ func (s ServiceNames) GetRandom() (string, error)

+ type TopoBRAddr struct

+ IPv4 *overBindAddr

+ IPv6 *overBindAddr

+ Overlay overlay.Type

+ func (t *TopoBRAddr) BindOrPublicOverlay(ot overlay.Type) *overlay.OverlayAddr

+ func (t *TopoBRAddr) BindOverlay(ot overlay.Type) *overlay.OverlayAddr

+ func (t *TopoBRAddr) Equal(o *TopoBRAddr) bool

+ func (t *TopoBRAddr) PublicOverlay(ot overlay.Type) *overlay.OverlayAddr

+ func (t *TopoBRAddr) String() string

v0.2.0

Aug 27, 2018

Changes in this version

+ const ErrBindAddrEqPubAddr

type Topo

+ func (t *Topo) GetRandomServer(serviceType proto.ServiceType) (*addr.AppAddr, error)

type TopoAddr

+ func (t *TopoAddr) BindAddr(ot overlay.Type) *addr.AppAddr

+ func (t *TopoAddr) BindOrPublic(ot overlay.Type) *addr.AppAddr

+ func (t *TopoAddr) OverlayAddr(ot overlay.Type) *overlay.OverlayAddr

+ func (t *TopoAddr) PublicAddr(ot overlay.Type) *addr.AppAddr

v0.1.1

Jul 31, 2018

v0.1.0

Jul 19, 2018

Changes in this version

+ const CfgName

+ const ChildLinkName

+ const CoreLinkName

+ const ErrAtLeastOnePub

+ const ErrBindWithoutPubV4

+ const ErrBindWithoutPubV6

+ const ErrExactlyOnePub

+ const ErrInvalidBind

+ const ErrInvalidPub

+ const ErrOverlayPort

+ const ErrTooManyBindV4

+ const ErrTooManyBindV6

+ const ErrTooManyPubV4

+ const ErrTooManyPubV6

+ const ErrorConvert

+ const ErrorOpen

+ const ErrorParse

+ const ParentLinkName

+ const PeerLinkName

+ func LinkTypeFromString(s string) (proto.LinkType, error)

+ func StripBind(rt *RawTopo)

+ func StripServices(rt *RawTopo)

+ type AddrInfo struct

+ IP net.IP

+ L4Port int

+ Overlay overlay.Type

+ OverlayPort int

+ func (a *AddrInfo) Key() string

+ func (a *AddrInfo) Reset()

+ func (a *AddrInfo) String() string

+ type BRInfo struct

+ IFIDs []common.IFIDType

+ type IFInfo struct

+ BRName string

+ Bandwidth int

+ ISD_AS addr.IA

+ InternalAddr *TopoAddr

+ LinkType proto.LinkType

+ Local *TopoAddr

+ MTU int

+ Overlay overlay.Type

+ Remote *AddrInfo

+ RemoteIFID common.IFIDType

+ func (i IFInfo) String() string

+ type RawAddrInfo struct

+ Bind []RawAddrPort

+ Public []RawAddrPortOverlay

+ func (rai RawAddrInfo) String() string

+ func (s *RawAddrInfo) ToTopoAddr(ot overlay.Type) (t *TopoAddr, err error)

+ type RawAddrPort struct

+ Addr string

+ L4Port int

+ func (a RawAddrPort) String() string

+ type RawAddrPortOverlay struct

+ OverlayPort int

+ func (a RawAddrPortOverlay) String() string

+ type RawBRInfo struct

+ Interfaces map[common.IFIDType]RawBRIntf

+ InternalAddr *RawAddrInfo

+ func (b RawBRInfo) String() string

+ type RawBRIntf struct

+ Bandwidth int

+ Bind *RawAddrPort

+ ISD_AS string

+ LinkTo string

+ MTU int

+ Overlay string

+ Public *RawAddrPort

+ Remote *RawAddrPort

+ type RawTopo struct

+ BeaconService map[string]RawAddrInfo

+ BorderRouters map[string]RawBRInfo

+ CertificateService map[string]RawAddrInfo

+ Core bool

+ DiscoveryService map[string]RawAddrInfo

+ ISD_AS string

+ MTU int

+ Overlay string

+ PathService map[string]RawAddrInfo

+ RainsService map[string]RawAddrInfo

+ SibraService map[string]RawAddrInfo

+ Timestamp int64

+ TimestampHuman string

+ ZookeeperService map[int]RawAddrPort

+ func LoadRaw(b common.RawBytes) (*RawTopo, error)

+ func LoadRawFromFile(path string) (*RawTopo, error)

+ type Topo struct

+ BR map[string]BRInfo

+ BRNames []string

+ BS map[string]TopoAddr

+ BSNames []string

+ CS map[string]TopoAddr

+ CSNames []string

+ Core bool

+ DS map[string]TopoAddr

+ DSNames []string

+ IFInfoMap map[common.IFIDType]IFInfo

+ ISD_AS addr.IA

+ MTU int

+ Overlay overlay.Type

+ PS map[string]TopoAddr

+ PSNames []string

+ RS map[string]TopoAddr

+ RSNames []string

+ SB map[string]TopoAddr

+ SBNames []string

+ Timestamp time.Time

+ TimestampHuman string

+ ZK map[int]TopoAddr

+ func Load(b common.RawBytes) (*Topo, error)

+ func LoadFromFile(path string) (*Topo, error)

+ func NewTopo() *Topo

+ func TopoFromRaw(raw *RawTopo) (*Topo, error)

+ func (t *Topo) GetTopoAddr(nodeType string, id string) *TopoAddr

+ type TopoAddr struct

+ IPv4 *topoAddrInt

+ IPv6 *topoAddrInt

+ Overlay overlay.Type

+ func TopoAddrFromRAI(s *RawAddrInfo, ot overlay.Type) (*TopoAddr, error)

+ func (t *TopoAddr) BindAddrInfo(ot overlay.Type) *AddrInfo

+ func (t *TopoAddr) FromRAI(s *RawAddrInfo) error

+ func (t *TopoAddr) PublicAddrInfo(ot overlay.Type) *AddrInfo

+ func (t *TopoAddr) String() string

+ func (t1 *TopoAddr) Equal(t2 *TopoAddr) bool

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