xgress_edge

Documentation

Index

• Constants
• type Accepter
  • func NewAccepter(listener *listener, uListener channel2.UnderlayListener, ...) *Accepter
  • func (accepter *Accepter) Run()
• type Factory
  • func NewFactory() *Factory
  • func (factory *Factory) BindChannel(ch channel2.Channel) error
  • func (factory *Factory) Channel() channel2.Channel
  • func (factory *Factory) CreateDialer(optionsData xgress.OptionsData) (xgress.Dialer, error)
  • func (factory *Factory) CreateListener(optionsData xgress.OptionsData) (xgress.Listener, error)
  • func (factory *Factory) Enabled() bool
  • func (factory *Factory) LoadConfig(configMap map[interface{}]interface{}) error
  • func (factory *Factory) Run(ctrl channel2.Channel, _ boltz.Db, done chan struct{}) error
• type Options

Constants

const (
	DefaultMaxOutOfOrderMsgs = 1000
)

Types

type Accepter

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

func NewAccepter

func NewAccepter(listener *listener, uListener channel2.UnderlayListener, options *channel2.Options) *Accepter

func (*Accepter) Run

func (accepter *Accepter) Run()

type Factory

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

func NewFactory

func NewFactory() *Factory

NewFactory constructs a new Edge Xgress Factory instance

func (*Factory) BindChannel

func (factory *Factory) BindChannel(ch channel2.Channel) error

func (*Factory) Channel

func (factory *Factory) Channel() channel2.Channel

func (*Factory) CreateDialer

func (factory *Factory) CreateDialer(optionsData xgress.OptionsData) (xgress.Dialer, error)

CreateDialer creates a new Edge Xgress dialer

func (*Factory) CreateListener

func (factory *Factory) CreateListener(optionsData xgress.OptionsData) (xgress.Listener, error)

CreateListener creates a new Edge Xgress listener

func (*Factory) Enabled

func (factory *Factory) Enabled() bool

func (*Factory) LoadConfig

func (factory *Factory) LoadConfig(configMap map[interface{}]interface{}) error

func (*Factory) Run

func (factory *Factory) Run(ctrl channel2.Channel, _ boltz.Db, done chan struct{}) error

type Options

type Options struct {
	xgress.Options
	MaxOutOfOrderMsgs uint32
	// contains filtered or unexported fields
}