grpc

Documentation

Index

• type Advertiser
• type Discoverer
  • func (d Discoverer) Gateways(ctx context.Context) ([]control.Gateway, error)
• type IPPrefixServer
  • func (s IPPrefixServer) Prefixes(ctx context.Context, req *gpb.PrefixesRequest) (*gpb.PrefixesResponse, error)
• type PrefixFetcher
  • func (f PrefixFetcher) Prefixes(ctx context.Context, gateway *net.UDPAddr) ([]*net.IPNet, error)
• type ProbeDispatcher
  • func (d *ProbeDispatcher) Listen(ctx context.Context, conn net.PacketConn) error

Types

type Advertiser

type Advertiser interface {
	AdvertiseList(from, to addr.IA) ([]netaddr.IPPrefix, error)
}

Advertiser returns a list of IP prefixes to advertise.

type Discoverer

type Discoverer struct {
	Remote addr.IA
	Dialer grpc.Dialer
	Paths  control.PathMonitorRegistration
}

Discoverer discovers the gateways for a specific remote AS.

func (Discoverer) Gateways

func (d Discoverer) Gateways(ctx context.Context) ([]control.Gateway, error)

type IPPrefixServer

type IPPrefixServer struct {
	// LocalIA is the IA of the local AS.
	LocalIA addr.IA
	// Advertiser is the advertiser used to get the list of prefixes to advertise.
	Advertiser Advertiser
	// PrefixesAdvertised reports the number of IP prefixes advertised. If nil, no  metrics are
	// reported.
	PrefixesAdvertised metrics.Gauge
}

IPPrefixServer serves IP prefix requests.

func (IPPrefixServer) Prefixes

func (s IPPrefixServer) Prefixes(ctx context.Context,
	req *gpb.PrefixesRequest) (*gpb.PrefixesResponse, error)

type PrefixFetcher

type PrefixFetcher struct {
	Remote addr.IA
	Pather control.PathMonitorRegistration
	Dialer grpc.Dialer
}

PrefixFetcher fetches prefixes from a gateway in a specific remote.

func (PrefixFetcher) Prefixes

func (f PrefixFetcher) Prefixes(ctx context.Context, gateway *net.UDPAddr) ([]*net.IPNet, error)

type ProbeDispatcher

type ProbeDispatcher struct {
}

ProbeDispatcher handles incoming gateway protocol messages. Currently, it only supports probe requests, and immediately replies to them.

func (*ProbeDispatcher) Listen

func (d *ProbeDispatcher) Listen(ctx context.Context, conn net.PacketConn) error

Listen handles the received control requests.