xgress_edge

package

v0.24.442 Latest Latest Go to latest Published: Dec 8, 2023 License: Apache-2.0 Imports: 40 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/openziti/edge

Links

Open Source Insights

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
type CertExtender
type Factory
- func NewFactory(routerConfig *router.Config, versionProvider versions.VersionProvider, ...) *Factory
type MsgQueue
type Options
- func (options *Options) ToLoggableString() string

Constants ¶

View Source

const DefaultTimeoutDuration = 35 * time.Second

View Source

const (
	WsType = "ws"
)

Variables ¶

This section is empty.

Functions ¶

func NewMsgQueue ¶ added in v0.17.25

func NewMsgQueue(queueDepth int) *baseMsgQ

func NewSizeLimitedMsgQueue ¶ added in v0.17.25

func NewSizeLimitedMsgQueue(size int32) *sizeLimitedMsgQ

Types ¶

type Acceptor ¶ added in v0.21.70

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

func NewAcceptor ¶ added in v0.21.70

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

func (*Acceptor) BindChannel ¶ added in v0.21.70

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

func (*Acceptor) Run ¶ added in v0.21.70

func (self *Acceptor) Run()

type BoundedMsgQueue ¶ added in v0.17.25

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

type CertExpirationChecker ¶ added in v0.19.81

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

func NewCertExpirationChecker ¶ added in v0.19.81

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

func (*CertExpirationChecker) AnyCtrlChannelWithTimeout ¶ added in v0.24.412

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

func (*CertExpirationChecker) CertsUpdated ¶ added in v0.19.81

func (self *CertExpirationChecker) CertsUpdated()

func (*CertExpirationChecker) ExtendEnrollment ¶ added in v0.20.101

func (self *CertExpirationChecker) ExtendEnrollment() error

func (*CertExpirationChecker) IsRequesting ¶ added in v0.21.20

func (self *CertExpirationChecker) IsRequesting() bool

func (*CertExpirationChecker) IsRequestingCompareAndSwap ¶ added in v0.21.20

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

func (*CertExpirationChecker) Run ¶ added in v0.19.81

func (self *CertExpirationChecker) Run() error

func (*CertExpirationChecker) SetIsRequesting ¶ added in v0.21.20

func (self *CertExpirationChecker) SetIsRequesting(value bool)

type CertExtender ¶ added in v0.21.20

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 ¶ added in v0.24.0

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

func (*Factory) GetTraceDecoders ¶ added in v0.19.0

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

func (*Factory) LoadConfig ¶

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

func (*Factory) NotifyOfReconnect ¶ added in v0.19.0

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

func (*Factory) Run ¶

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

type MsgQueue ¶ added in v0.17.25

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 ¶ added in v0.17.48

func (options *Options) ToLoggableString() string

Source Files ¶

View all Source files

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