outbound

package

v1.2.1 Latest Latest Go to latest Published: Apr 18, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/5vnetwork/vx-core

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type HandlerObserver
type HandlerWithSupport6Info
- func NewHandlerWithSupport6Info(outbound i.Outbound, support6 bool) *HandlerWithSupport6Info
- func (h *HandlerWithSupport6Info) SetSupport6(support6 bool)
- func (h *HandlerWithSupport6Info) Support6() bool
type Manager
- func NewManager() *Manager
type OnHandlerChangedFunc
- func (f OnHandlerChangedFunc) OnHandlerChanged()
type ProxyHandler
- func NewProxyHandler(settings ProxyHandlerSettings) *ProxyHandler
type ProxyHandlerSettings
type RandomPortSelector
- func NewRandomPortSelector(ranges []*net.PortRange) *RandomPortSelector
- func (s *RandomPortSelector) SelectPort() uint16

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrIpv6NotSupported = errors.New("ipv6 not supported")

Functions ¶

This section is empty.

Types ¶

type HandlerObserver ¶

type HandlerObserver interface {
	OnHandlerChanged()
}

type HandlerWithSupport6Info ¶

type HandlerWithSupport6Info struct {
	i.Outbound
	util.IPv6SupportChangeNotifier
	// contains filtered or unexported fields
}

func NewHandlerWithSupport6Info ¶ added in v1.0.7

func NewHandlerWithSupport6Info(outbound i.Outbound, support6 bool) *HandlerWithSupport6Info

func (*HandlerWithSupport6Info) SetSupport6 ¶

func (h *HandlerWithSupport6Info) SetSupport6(support6 bool)

func (*HandlerWithSupport6Info) Support6 ¶

func (h *HandlerWithSupport6Info) Support6() bool

type Manager ¶

type Manager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

holds all outbound handlers. notify its listeners when a change happens.

func NewManager ¶

func NewManager() *Manager

func (*Manager) AddHandlerObserver ¶

func (m *Manager) AddHandlerObserver(o HandlerObserver)

func (*Manager) AddHandlers ¶

func (m *Manager) AddHandlers(handlers ...i.Outbound) error

func (*Manager) Close ¶

func (m *Manager) Close() error

func (*Manager) GetAllHandlers ¶

func (m *Manager) GetAllHandlers() []i.Outbound

func (*Manager) GetHandler ¶

func (m *Manager) GetHandler(tag string) i.Outbound

func (*Manager) RemoveHandlerObserver ¶

func (m *Manager) RemoveHandlerObserver(observer HandlerObserver)

func (*Manager) RemoveHandlers ¶

func (m *Manager) RemoveHandlers(tags []string) error

func (*Manager) ReplaceHandlers ¶

func (m *Manager) ReplaceHandlers(handlers []i.Outbound)

replace all handlers with new ones

func (*Manager) Start ¶

func (m *Manager) Start() error

type OnHandlerChangedFunc ¶

type OnHandlerChangedFunc func()

func (OnHandlerChangedFunc) OnHandlerChanged ¶

func (f OnHandlerChangedFunc) OnHandlerChanged()

type ProxyHandler ¶

type ProxyHandler struct {
	i.Handler
	// contains filtered or unexported fields
}

implement outbound.ProxyHandler and transport.Dialer

func NewProxyHandler ¶

func NewProxyHandler(settings ProxyHandlerSettings) *ProxyHandler

func (*ProxyHandler) Close ¶

func (h *ProxyHandler) Close() error

func (*ProxyHandler) HandleFlow ¶

func (h *ProxyHandler) HandleFlow(ctx context.Context, dst net.Destination, rw buf.ReaderWriter) error

func (*ProxyHandler) HandlePacketConn ¶

func (h *ProxyHandler) HandlePacketConn(ctx context.Context, dst net.Destination,
	rw udp.PacketReaderWriter) error

func (*ProxyHandler) Start ¶

func (h *ProxyHandler) Start() error

func (*ProxyHandler) Tag ¶

func (h *ProxyHandler) Tag() string

type ProxyHandlerSettings ¶

type ProxyHandlerSettings struct {
	Tag       string
	Handler   i.Handler
	Uot       bool
	EnableMux bool
	MuxConfig mux.ClientStrategy
}

type RandomPortSelector ¶

type RandomPortSelector struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRandomPortSelector ¶

func NewRandomPortSelector(ranges []*net.PortRange) *RandomPortSelector

func (*RandomPortSelector) SelectPort ¶

func (s *RandomPortSelector) SelectPort() uint16

randomly select one enabled port from the list

Source Files ¶

View all Source files

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