xgress_edge_tunnel

Documentation

Index

• Constants
• func ToPtr[T any](in T) *T
• type Factory
  • func NewFactory(env env.RouterEnv, routerConfig *router.Config, stateManager state.Manager) *Factory
  • func (self *Factory) BindChannel(binding channel.Binding) error
  • func (self *Factory) CreateDialer(optionsData xgress.OptionsData) (xgress.Dialer, error)
  • func (self *Factory) CreateListener(optionsData xgress.OptionsData) (xgress.Listener, error)
  • func (self *Factory) DefaultRequestTimeout() time.Duration
  • func (self *Factory) Enabled() bool
  • func (self *Factory) GetTraceDecoders() []channel.TraceMessageDecoder
  • func (self *Factory) LoadConfig(map[interface{}]interface{}) error
  • func (self *Factory) NotifyOfReconnect(channel.Channel)
  • func (self *Factory) Run(env env.RouterEnv) error
• type Options
  • func (options *Options) ToLoggableString() string

Constants

const (
	DefaultMode              = "tproxy"
	DefaultServicePollRate   = 15 * time.Second
	DefaultDnsResolver       = "udp://127.0.0.1:53"
	DefaultDnsServiceIpRange = "100.64.0.1/10"
)

Functions

func ToPtr

func ToPtr[T any](in T) *T

Types

type Factory

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

func NewFactory

func NewFactory(env env.RouterEnv, routerConfig *router.Config, stateManager state.Manager) *Factory

NewFactory constructs a new Edge Xgress Tunnel Factory instance

func (*Factory) BindChannel

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

func (*Factory) CreateDialer

func (self *Factory) CreateDialer(optionsData xgress.OptionsData) (xgress.Dialer, error)

CreateDialer creates a new Edge Xgress dialer

func (*Factory) CreateListener

func (self *Factory) CreateListener(optionsData xgress.OptionsData) (xgress.Listener, error)

CreateListener creates a new Edge Tunnel Xgress listener

func (*Factory) DefaultRequestTimeout

func (self *Factory) DefaultRequestTimeout() time.Duration

func (*Factory) Enabled

func (self *Factory) Enabled() bool

func (*Factory) GetTraceDecoders

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

func (*Factory) LoadConfig

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

func (*Factory) NotifyOfReconnect

func (self *Factory) NotifyOfReconnect(channel.Channel)

func (*Factory) Run

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

type Options

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

func (*Options) ToLoggableString

func (options *Options) ToLoggableString() string