xgress_edge

Documentation

Index

• Constants
• func NewMsgQueue(queueDepth int) *baseMsgQ
• func NewSizeLimitedMsgQueue(size int32) *sizeLimitedMsgQ
• type Accepter
  • func NewAccepter(listener *listener, uListener channel2.UnderlayListener, ...) *Accepter
  • func (accepter *Accepter) Run()
• type BoundedMsgQueue
• type Factory
  • func NewFactory(routerConfig *router.Config, versionProvider common.VersionProvider) *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) DefaultRequestTimeout() time.Duration
  • func (factory *Factory) Enabled() bool
  • func (factory *Factory) GetTraceDecoders() []channel2.TraceMessageDecoder
  • func (factory *Factory) LoadConfig(configMap map[interface{}]interface{}) error
  • func (factory *Factory) NotifyOfReconnect()
  • func (factory *Factory) Run(ctrl channel2.Channel, _ boltz.Db, closeNotify chan struct{}) error
• type MsgQueue
• type Options
  • func (options *Options) ToLoggableString() string

Constants

const (
	PayloadFlagsHeader uint8 = 0x10
)

Functions

func NewMsgQueue

func NewMsgQueue(queueDepth int) *baseMsgQ

func NewSizeLimitedMsgQueue

func NewSizeLimitedMsgQueue(size int32) *sizeLimitedMsgQ

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 BoundedMsgQueue

type BoundedMsgQueue interface {
	MsgQueue
	TryPopMax(size int) *channel2.Message
}

type Factory

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

func NewFactory

func NewFactory(routerConfig *router.Config, versionProvider common.VersionProvider) *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) DefaultRequestTimeout

func (factory *Factory) DefaultRequestTimeout() time.Duration

func (*Factory) Enabled

func (factory *Factory) Enabled() bool

func (*Factory) GetTraceDecoders

func (factory *Factory) GetTraceDecoders() []channel2.TraceMessageDecoder

func (*Factory) LoadConfig

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

func (*Factory) NotifyOfReconnect

func (factory *Factory) NotifyOfReconnect()

func (*Factory) Run

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

type MsgQueue

type MsgQueue interface {
	Push(msg *channel2.Message) error
	Pop() *channel2.Message
	Close()
}

type Options

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

func (*Options) ToLoggableString

func (options *Options) ToLoggableString() string