xgress_edge

package

v1.1.0 Latest Latest Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 51 Imported by: 0

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/ziti

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, env env.RouterEnv, stateManager state.Manager) *Factory
type MsgQueue
type Options
- func (options *Options) ToLoggableString() string

Constants ¶

View Source

const (
	TerminatorStateEstablishing terminatorState = 1
	TerminatorStateEstablished  terminatorState = 2
	TerminatorStateDeleting     terminatorState = 3
)

View Source

const DefaultTimeoutDuration = 35 * time.Second

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

Source Files ¶

View all Source files

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