egress

Documentation

Index

• Constants
• func Init()
• func NewDispatcher(devName string, devIO io.ReadWriteCloser, sess *Session) *egressDispatcher
• func NewWorker(sess *Session, logger log.Logger) *worker
• type RemoteInfo
  • func (r *RemoteInfo) String() string
• type Session
  • func NewSession(dstIA *addr.ISD_AS, sessId mgmt.SessionType, sigMap *siginfo.SigMap, ...) (*Session, error)
  • func (s *Session) Cleanup() error
  • func (s *Session) Healthy() bool
  • func (s *Session) Remote() *RemoteInfo
  • func (s *Session) Start()

Constants

const (
	PktLenSize = 2
	MinSpace   = 16
	SigHdrLen  = 8
	MaxSeq     = (1 << 24) - 1
)

Functions

func Init

func Init()

func NewDispatcher

func NewDispatcher(devName string, devIO io.ReadWriteCloser, sess *Session) *egressDispatcher

func NewWorker

func NewWorker(sess *Session, logger log.Logger) *worker

Types

type RemoteInfo

type RemoteInfo struct {
	Sig *siginfo.Sig
	// contains filtered or unexported fields
}

func (*RemoteInfo) String

func (r *RemoteInfo) String() string

type Session

type Session struct {
	log.Logger
	IA     *addr.ISD_AS
	SessId mgmt.SessionType
	// contains filtered or unexported fields
}

Session contains a pool of paths to the remote AS, metrics about those paths, as well as maintaining the currently favoured path and remote SIG to use.

func NewSession

func NewSession(dstIA *addr.ISD_AS, sessId mgmt.SessionType,
	sigMap *siginfo.SigMap, logger log.Logger) (*Session, error)

func (*Session) Cleanup

func (s *Session) Cleanup() error

func (*Session) Healthy

func (s *Session) Healthy() bool

func (*Session) Remote

func (s *Session) Remote() *RemoteInfo

func (*Session) Start

func (s *Session) Start()