xgress_edge_tunnel

Documentation

Overview

Copyright NetFoundry, Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

https://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• type Factory
  • func NewFactory(routerConfig *router.Config, stateManager fabric.StateManager) *Factory
  • func (self *Factory) BindChannel(ch channel2.Channel) error
  • func (self *Factory) Channel() channel2.Channel
  • 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() []channel2.TraceMessageDecoder
  • func (self *Factory) LoadConfig(map[interface{}]interface{}) error
  • func (self *Factory) NotifyOfReconnect()
  • func (self *Factory) Run(ctrl channel2.Channel, _ boltz.Db, notifyClose chan struct{}) error
• type Options

Constants

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

Types

type Factory

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

func NewFactory

func NewFactory(routerConfig *router.Config, stateManager fabric.StateManager) *Factory

NewFactory constructs a new Edge Xgress Tunnel Factory instance

func (*Factory) BindChannel

func (self *Factory) BindChannel(ch channel2.Channel) error

func (*Factory) Channel

func (self *Factory) Channel() channel2.Channel

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() []channel2.TraceMessageDecoder

func (*Factory) LoadConfig

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

func (*Factory) NotifyOfReconnect

func (self *Factory) NotifyOfReconnect()

func (*Factory) Run

func (self *Factory) Run(ctrl channel2.Channel, _ boltz.Db, notifyClose chan struct{}) error

type Options

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