forwarder

Documentation

Index

• type Destination
• type Forwarder
  • func NewForwarder(metricsRegistry metrics.UsageRegistry, options *Options) *Forwarder
  • func (forwarder *Forwarder) Debug() string
  • func (forwarder *Forwarder) EndSession(sessionId string)
  • func (forwarder *Forwarder) ForwardAcknowledgement(srcAddr xgress.Address, acknowledgement *xgress.Acknowledgement) 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(sessionId string, address xgress.Address, destination Destination)
  • func (forwarder *Forwarder) RegisterLink(link xlink.Xlink)
  • func (forwarder *Forwarder) Route(route *ctrl_pb.Route)
  • func (forwarder *Forwarder) TraceController() trace.Controller
  • func (forwarder *Forwarder) UnregisterDestinations(sessionId string)
  • func (forwarder *Forwarder) UnregisterLink(link xlink.Xlink)
  • func (forwarder *Forwarder) Unroute(sessionId string, now bool)
• type Options
  • func DefaultOptions() *Options
  • func LoadOptions(src map[interface{}]interface{}) (*Options, error)
• type WorkerPoolOptions
• type XgressDestination

Types

type Destination

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

type Forwarder

type Forwarder struct {
	Options *Options
	// contains filtered or unexported fields
}

func NewForwarder

func NewForwarder(metricsRegistry metrics.UsageRegistry, options *Options) *Forwarder

func (*Forwarder) Debug

func (forwarder *Forwarder) Debug() string

func (*Forwarder) EndSession

func (forwarder *Forwarder) EndSession(sessionId string)

func (*Forwarder) ForwardAcknowledgement

func (forwarder *Forwarder) ForwardAcknowledgement(srcAddr xgress.Address, acknowledgement *xgress.Acknowledgement) 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(sessionId string, address xgress.Address, destination Destination)

func (*Forwarder) RegisterLink

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

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(sessionId string)

func (*Forwarder) UnregisterLink

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

func (*Forwarder) Unroute

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

type Options

type Options struct {
	LatencyProbeInterval     time.Duration
	XgressCloseCheckInterval time.Duration
	XgressDial               WorkerPoolOptions
	LinkDial                 WorkerPoolOptions
}

func DefaultOptions

func DefaultOptions() *Options

func LoadOptions

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

type WorkerPoolOptions

type WorkerPoolOptions struct {
	QueueLength uint16
	WorkerCount uint16
}

type XgressDestination

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