forwarder

Documentation

Index

• type Destination
• type Faulter
  • func NewFaulter(interval time.Duration, closeNotify chan struct{}) *Faulter
  • func (self *Faulter) SetCtrl(ch channel.Channel)
• type Forwarder
  • func NewForwarder(metricsRegistry metrics.UsageRegistry, faulter *Faulter, scanner *Scanner, ...) *Forwarder
  • func (forwarder *Forwarder) Debug() string
  • func (forwarder *Forwarder) EndCircuit(circuitId string)
  • func (forwarder *Forwarder) ForwardAcknowledgement(srcAddr xgress.Address, acknowledgement *xgress.Acknowledgement) error
  • func (forwarder *Forwarder) ForwardControl(srcAddr xgress.Address, control *xgress.Control) error
  • func (forwarder *Forwarder) ForwardPayload(srcAddr xgress.Address, payload *xgress.Payload) error
  • func (forwarder *Forwarder) HasDestination(address xgress.Address) bool
  • func (forwarder *Forwarder) MetricsRegistry() metrics.UsageRegistry
  • func (forwarder *Forwarder) RegisterDestination(circuitId string, address xgress.Address, destination Destination)
  • func (forwarder *Forwarder) RegisterLink(link xlink.Xlink) error
  • func (forwarder *Forwarder) ReportForwardingFault(circuitId string)
  • func (forwarder *Forwarder) Route(route *ctrl_pb.Route)
  • func (forwarder *Forwarder) TraceController() trace.Controller
  • func (forwarder *Forwarder) UnregisterDestinations(circuitId string)
  • func (forwarder *Forwarder) UnregisterLink(link xlink.Xlink)
  • func (forwarder *Forwarder) Unroute(circuitId string, now bool)
• type Options
  • func DefaultOptions() *Options
  • func LoadOptions(src map[interface{}]interface{}) (*Options, error)
• type Scanner
  • func NewScanner(options *Options, closeNotify <-chan struct{}) *Scanner
  • func (self *Scanner) SetCtrl(ch channel.Channel)
• type WorkerPoolOptions
• type XgressDestination

Types

type Destination

type Destination interface {
	SendPayload(payload *xgress.Payload) error
	SendAcknowledgement(acknowledgement *xgress.Acknowledgement) error
	SendControl(control *xgress.Control) error
}

type Faulter

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

func NewFaulter

func NewFaulter(interval time.Duration, closeNotify chan struct{}) *Faulter

func (*Faulter) SetCtrl

func (self *Faulter) SetCtrl(ch channel.Channel)

type Forwarder

type Forwarder struct {
	Options     *Options
	CloseNotify <-chan struct{}
	// contains filtered or unexported fields
}

func NewForwarder

func NewForwarder(metricsRegistry metrics.UsageRegistry, faulter *Faulter, scanner *Scanner, options *Options, closeNotify <-chan struct{}) *Forwarder

func (*Forwarder) Debug

func (forwarder *Forwarder) Debug() string

func (*Forwarder) EndCircuit

func (forwarder *Forwarder) EndCircuit(circuitId string)

func (*Forwarder) ForwardAcknowledgement

func (forwarder *Forwarder) ForwardAcknowledgement(srcAddr xgress.Address, acknowledgement *xgress.Acknowledgement) error

func (*Forwarder) ForwardControl

func (forwarder *Forwarder) ForwardControl(srcAddr xgress.Address, control *xgress.Control) error

func (*Forwarder) ForwardPayload

func (forwarder *Forwarder) ForwardPayload(srcAddr xgress.Address, payload *xgress.Payload) error

func (*Forwarder) HasDestination

func (forwarder *Forwarder) HasDestination(address xgress.Address) bool

func (*Forwarder) MetricsRegistry

func (forwarder *Forwarder) MetricsRegistry() metrics.UsageRegistry

func (*Forwarder) RegisterDestination

func (forwarder *Forwarder) RegisterDestination(circuitId string, address xgress.Address, destination Destination)

func (*Forwarder) RegisterLink

func (forwarder *Forwarder) RegisterLink(link xlink.Xlink) error

func (*Forwarder) ReportForwardingFault

func (forwarder *Forwarder) ReportForwardingFault(circuitId string)

func (*Forwarder) Route

func (forwarder *Forwarder) Route(route *ctrl_pb.Route)

func (*Forwarder) TraceController

func (forwarder *Forwarder) TraceController() trace.Controller

func (*Forwarder) UnregisterDestinations

func (forwarder *Forwarder) UnregisterDestinations(circuitId string)

func (*Forwarder) UnregisterLink

func (forwarder *Forwarder) UnregisterLink(link xlink.Xlink)

func (*Forwarder) Unroute

func (forwarder *Forwarder) Unroute(circuitId string, now bool)

type Options

type Options struct {
	LatencyProbeInterval     time.Duration
	LatencyProbeTimeout      time.Duration
	XgressCloseCheckInterval time.Duration
	XgressDialDwellTime      time.Duration
	FaultTxInterval          time.Duration
	IdleTxInterval           time.Duration
	IdleCircuitTimeout       time.Duration
	XgressDial               WorkerPoolOptions
	LinkDial                 WorkerPoolOptions
}

func DefaultOptions

func DefaultOptions() *Options

func LoadOptions

func LoadOptions(src map[interface{}]interface{}) (*Options, error)

type Scanner

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

func NewScanner

func NewScanner(options *Options, closeNotify <-chan struct{}) *Scanner

func (*Scanner) SetCtrl

func (self *Scanner) SetCtrl(ch channel.Channel)

type WorkerPoolOptions

type WorkerPoolOptions struct {
	QueueLength uint16
	WorkerCount uint16
}

type XgressDestination

type XgressDestination interface {
	Destination
	Unrouted()
	Start()
	IsTerminator() bool
	Label() string
	GetTimeOfLastRxFromLink() int64
}