xgress_edge

Documentation

Index

• Constants
• func NewMsgQueue(queueDepth int) *baseMsgQ
• func NewSizeLimitedMsgQueue(size int32) *sizeLimitedMsgQ
• type Acceptor
  • func NewAcceptor(listener *listener, uListener channel.UnderlayListener, ...) *Acceptor
  • func (self *Acceptor) BindChannel(binding channel.Binding) error
  • func (self *Acceptor) Run()
• type BoundedMsgQueue
• type CertExpirationChecker
  • func NewCertExpirationChecker(id *identity.TokenId, edgeConfig *edgerouter.Config, ...) *CertExpirationChecker
  • func (self *CertExpirationChecker) AnyCtrlChannelWithTimeout(timeout time.Duration) (channel.Channel, bool)
  • func (self *CertExpirationChecker) CertsUpdated()
  • func (self *CertExpirationChecker) ExtendEnrollment() error
  • func (self *CertExpirationChecker) IsRequesting() bool
  • func (self *CertExpirationChecker) IsRequestingCompareAndSwap(expected bool, value bool) bool
  • func (self *CertExpirationChecker) Run() error
  • func (self *CertExpirationChecker) SetIsRequesting(value bool)
• type CertExtender
• type Factory
  • func NewFactory(routerConfig *router.Config, versionProvider versions.VersionProvider, ...) *Factory
  • func (factory *Factory) BindChannel(binding channel.Binding) error
  • 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) GetNetworkControllers() env.NetworkControllers
  • func (factory *Factory) GetTraceDecoders() []channel.TraceMessageDecoder
  • func (factory *Factory) LoadConfig(configMap map[interface{}]interface{}) error
  • func (factory *Factory) NotifyOfReconnect(ch channel.Channel)
  • func (factory *Factory) Run(env env.RouterEnv) error
• type MsgQueue
• type Options
  • func (options *Options) ToLoggableString() string

Constants

const DefaultTimeoutDuration = 35 * time.Second

const (
	WsType = "ws"
)

Functions

func NewMsgQueue

func NewMsgQueue(queueDepth int) *baseMsgQ

func NewSizeLimitedMsgQueue

func NewSizeLimitedMsgQueue(size int32) *sizeLimitedMsgQ

Types

type Acceptor

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

func NewAcceptor

func NewAcceptor(listener *listener, uListener channel.UnderlayListener, options *channel.Options) *Acceptor

func (*Acceptor) BindChannel

func (self *Acceptor) BindChannel(binding channel.Binding) error

func (*Acceptor) Run

func (self *Acceptor) Run()

type BoundedMsgQueue

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

type CertExpirationChecker

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

func NewCertExpirationChecker

func NewCertExpirationChecker(id *identity.TokenId, edgeConfig *edgerouter.Config, ctrls routerEnv.NetworkControllers, closeNotify <-chan struct{}) *CertExpirationChecker

func (*CertExpirationChecker) AnyCtrlChannelWithTimeout

func (self *CertExpirationChecker) AnyCtrlChannelWithTimeout(timeout time.Duration) (channel.Channel, bool)

func (*CertExpirationChecker) CertsUpdated

func (self *CertExpirationChecker) CertsUpdated()

func (*CertExpirationChecker) ExtendEnrollment

func (self *CertExpirationChecker) ExtendEnrollment() error

func (*CertExpirationChecker) IsRequesting

func (self *CertExpirationChecker) IsRequesting() bool

func (*CertExpirationChecker) IsRequestingCompareAndSwap

func (self *CertExpirationChecker) IsRequestingCompareAndSwap(expected bool, value bool) bool

func (*CertExpirationChecker) Run

func (self *CertExpirationChecker) Run() error

func (*CertExpirationChecker) SetIsRequesting

func (self *CertExpirationChecker) SetIsRequesting(value bool)

type CertExtender

type CertExtender interface {
	ExtendEnrollment() error
	IsRequesting() bool
	IsRequestingCompareAndSwap(bool, bool) bool
	SetIsRequesting(bool)
}

type Factory

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

func NewFactory

func NewFactory(routerConfig *router.Config, versionProvider versions.VersionProvider, stateManager fabric.StateManager, metricsRegistry metrics.Registry) *Factory

NewFactory constructs a new Edge Xgress Factory instance

func (*Factory) BindChannel

func (factory *Factory) BindChannel(binding channel.Binding) error

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) GetNetworkControllers

func (factory *Factory) GetNetworkControllers() env.NetworkControllers

func (*Factory) GetTraceDecoders

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

func (*Factory) LoadConfig

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

func (*Factory) NotifyOfReconnect

func (factory *Factory) NotifyOfReconnect(ch channel.Channel)

func (*Factory) Run

func (factory *Factory) Run(env env.RouterEnv) error

type MsgQueue

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

type Options

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

func (*Options) ToLoggableString

func (options *Options) ToLoggableString() string