Documentation ¶
Index ¶
- Constants
- func NewMsgQueue(queueDepth int) *baseMsgQ
- func NewSizeLimitedMsgQueue(size int32) *sizeLimitedMsgQ
- type Acceptor
- type BoundedMsgQueue
- type 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 (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
Constants ¶
View Source
const ( TerminatorStateEstablishing terminatorState = 1 TerminatorStateEstablished terminatorState = 2 TerminatorStateDeleting terminatorState = 3 )
View Source
const DefaultTimeoutDuration = 35 * time.Second
View Source
const JwtTokenPrefix = "ey"
Variables ¶
This section is empty.
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 ¶
type BoundedMsgQueue ¶
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 Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
func NewFactory ¶
func NewFactory(routerConfig *router.Config, env env.RouterEnv, stateManager state.Manager) *Factory
NewFactory constructs a new Edge Xgress Factory instance
func (*Factory) BindChannel ¶
func (*Factory) CreateDialer ¶
CreateDialer creates a new Edge Xgress dialer
func (*Factory) CreateListener ¶
CreateListener creates a new Edge Xgress listener
func (*Factory) GetNetworkControllers ¶
func (factory *Factory) GetNetworkControllers() env.NetworkControllers
func (*Factory) GetTraceDecoders ¶
func (factory *Factory) GetTraceDecoders() []channel.TraceMessageDecoder
func (*Factory) LoadConfig ¶
func (*Factory) NotifyOfReconnect ¶
func (factory *Factory) NotifyOfReconnect(ch channel.Channel)
Click to show internal directories.
Click to hide internal directories.