forwarder

Documentation

Index

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

Types

type Destination

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

type Forwarder

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

func NewForwarder

func NewForwarder(metricsRegistry metrics.Registry) *Forwarder

func (*Forwarder) Debug

func (forwarder *Forwarder) Debug() string

func (*Forwarder) EndSession

func (forwarder *Forwarder) EndSession(sessionId *identity.TokenId)

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.Registry

func (*Forwarder) PayloadBuffer

func (forwarder *Forwarder) PayloadBuffer(sessionId *identity.TokenId, address xgress.Address) *xgress.PayloadBuffer

func (*Forwarder) PayloadBufferController

func (forwarder *Forwarder) PayloadBufferController() *xgress.PayloadBufferController

func (*Forwarder) RegisterDestination

func (forwarder *Forwarder) RegisterDestination(sessionId *identity.TokenId, 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) StartDestinations

func (forwarder *Forwarder) StartDestinations(sessionId *identity.TokenId)

func (*Forwarder) TraceController

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

func (*Forwarder) UnregisterDestinations

func (forwarder *Forwarder) UnregisterDestinations(sessionId *identity.TokenId)

func (*Forwarder) UnregisterLink

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

func (*Forwarder) Unroute

func (forwarder *Forwarder) Unroute(sessionId *identity.TokenId, now bool)

type Options

type Options struct {
	LatencyProbeInterval time.Duration
}

func DefaultOptions

func DefaultOptions() *Options

func LoadOptions

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

type XgressDestination

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