segfetcher

package

Go to main page

Versions in this module

v0

v0.7.0

Mar 12, 2022

Changes in this version

type DefaultRequester

+ MaxRetries int

type Pather

+ IA addr.IA

+ MTU uint16

+ NextHopper interface{ ... }

+ type SegmentsReply struct

+ Peer net.Addr

+ Segments []*seg.Meta

v0.6.0

Dec 4, 2020

Changes in this version

+ var ErrNotReachable = serrors.New("remote not reachable")

+ func NewFetcherMetrics(ns string) metrics.Fetcher

type DefaultRequester

+ MaxTries int

+ RPC RPC

+ TimeoutFactor float64

type Fetcher

+ Metrics metrics.Fetcher

+ func (f *Fetcher) Fetch(ctx context.Context, reqs Requests, refresh bool) (Segments, error)

+ func (f *Fetcher) Request(ctx context.Context, reqs Requests) (Segments, error)

type MultiSegmentSplitter

+ Core bool

+ LocalIA addr.IA

type Pather

+ Splitter Splitter

+ type RPC interface

+ Segments func(ctx context.Context, req Request, dst net.Addr) ([]*seg.Meta, error)

type ReplyOrErr

+ Segments []*seg.Meta

type Request

+ SegType seg.Type

+ func (r Request) Equal(other Request) bool

type Segments

+ func (s Segments) Segs() []*seg.PathSegment

v0.5.0

Mar 30, 2020

Changes in this version

+ var ErrBadDst = errors.New("bad destination AS")

+ var ErrNoPaths = errors.New("no paths found")

type DefaultResolver

+ LocalInfo LocalInfo

type FetcherConfig

+ LocalInfo LocalInfo

+ type LocalInfo interface

+ IsSegLocal func(ctx context.Context, src, dst addr.IA) (bool, error)

+ type MultiSegmentSplitter struct

+ Inspector infra.ASInspector

+ Local addr.IA

+ func (s *MultiSegmentSplitter) Split(ctx context.Context, r Request) (RequestSet, error)

+ type Pather struct

+ Fetcher *Fetcher

+ PathDB pathdb.PathDB

+ RevCache revcache.RevCache

+ TopoProvider topology.Provider

+ func (p *Pather) GetPaths(ctx context.Context, dst addr.IA, refresh bool) ([]*combinator.Path, error)

type RequestSet

+ Fetch bool

v0.4.0

Nov 14, 2019

Changes in this version

+ var ErrInvalidRequest = serrors.New("invalid request")

+ func DeleteNextQueryEntries(ctx context.Context, tx pathdb.Transaction, results query.Results) error

+ func ErrToMetricsLabel(err error) string

+ type DefaultRequester struct

+ API RequestAPI

+ DstProvider DstProvider

+ func (r *DefaultRequester) Request(ctx context.Context, req RequestSet) <-chan ReplyOrErr

+ type DefaultResolver struct

+ DB pathdb.Read

+ IgnoreRevs bool

+ RevCache revcache.RevCache

+ func NewResolver(DB pathdb.Read, revCache revcache.RevCache, ignoreRevs bool) *DefaultResolver

+ func (r *DefaultResolver) Resolve(ctx context.Context, segs Segments, req RequestSet) (Segments, RequestSet, error)

+ type DstProvider interface

+ Dst func(context.Context, Request) (net.Addr, error)

+ type Fetcher struct

+ CryptoLookupAtLocalCS bool

+ NextQueryCleaner NextQueryCleaner

+ PathDB pathdb.PathDB

+ QueryInterval time.Duration

+ ReplyHandler ReplyHandler

+ Requester Requester

+ Resolver Resolver

+ Splitter Splitter

+ Validator Validator

+ func (f *Fetcher) FetchSegs(ctx context.Context, req Request) (Segments, error)

+ type FetcherConfig struct

+ ASInspector infra.ASInspector

+ DstProvider DstProvider

+ LocalIA addr.IA

+ MetricsNamespace string

+ PathDB pathdb.PathDB

+ QueryInterval time.Duration

+ RequestAPI RequestAPI

+ RevCache revcache.RevCache

+ SciondMode bool

+ Splitter Splitter

+ Validator Validator

+ VerificationFactory infra.VerificationFactory

+ func (cfg FetcherConfig) New() *Fetcher

+ type NextQueryCleaner struct

+ PathDB pathdb.PathDB

+ func (c *NextQueryCleaner) ResetQueryCache(ctx context.Context, revInfo *path_mgmt.RevInfo) error

+ type ReplyHandler interface

+ Handle func(ctx context.Context, recs seghandler.Segments, server net.Addr, ...) *seghandler.ProcessedResult

+ type ReplyOrErr struct

+ Err error

+ Peer net.Addr

+ Reply *path_mgmt.SegReply

+ Req Request

+ type Request struct

+ Dst addr.IA

+ Src addr.IA

+ State RequestState

+ func (r Request) EqualAddr(other Request) bool

+ func (r Request) IsZero() bool

+ func (r Request) ToSegReq() *path_mgmt.SegReq

+ type RequestAPI interface

+ GetSegs func(ctx context.Context, msg *path_mgmt.SegReq, a net.Addr, id uint64) (*path_mgmt.SegReply, error)

+ type RequestSet struct

+ Cores Requests

+ Down Request

+ Up Request

+ func (r RequestSet) IsLoaded() bool

+ type RequestState int

+ const Cached

+ const Fetch

+ const Fetched

+ const Loaded

+ const Unresolved

+ type Requester interface

+ Request func(ctx context.Context, req RequestSet) <-chan ReplyOrErr

+ type Requests []Request

+ func (r Requests) AllLoaded() bool

+ func (r Requests) DstIAs() []addr.IA

+ func (r Requests) IsEmpty() bool

+ func (r Requests) SrcIAs() []addr.IA

+ type Resolver interface

+ Resolve func(ctx context.Context, segs Segments, req RequestSet) (Segments, RequestSet, error)

+ type Segments struct

+ Core seg.Segments

+ Down seg.Segments

+ Up seg.Segments

+ func (s *Segments) Add(other Segments)

+ type Splitter interface

+ Split func(ctx context.Context, r Request) (RequestSet, error)

+ type Validator interface

+ Validate func(ctx context.Context, r Request) error

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