xgress_edge

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 10, 2024 License: Apache-2.0 Imports: 51 Imported by: 0

Documentation

Index

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

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, env env.RouterEnv, stateManager state.Manager) *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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL