tunnel

Documentation

Index

• Variables
• func Add(req C.ServerAdapter)
• func AddPacket(packet *inbound.PacketAdapter)
• func Providers() map[string]provider.ProxyProvider
• func Proxies() map[string]C.Proxy
• func Rules() []C.Rule
• func SetMode(m TunnelMode)
• func SetResolver(r *dns.Resolver)
• func UpdateProxies(newProxies map[string]C.Proxy, newProviders map[string]provider.ProxyProvider)
• func UpdateRules(newRules []C.Rule)
• type Manager
  • func (m *Manager) Download() chan<- int64
  • func (m *Manager) Join(c tracker)
  • func (m *Manager) Leave(c tracker)
  • func (m *Manager) Now() (up int64, down int64)
  • func (m *Manager) ResetStatistic()
  • func (m *Manager) Snapshot() *Snapshot
  • func (m *Manager) Upload() chan<- int64
• type Snapshot
• type TrafficTrack
  • func (tt *TrafficTrack) Read(b []byte) (int, error)
  • func (tt *TrafficTrack) Write(b []byte) (int, error)
• type TunnelMode
  • func Mode() TunnelMode
  • func (m TunnelMode) MarshalJSON() ([]byte, error)
  • func (m TunnelMode) MarshalYAML() (interface{}, error)
  • func (m TunnelMode) String() string
  • func (m *TunnelMode) UnmarshalJSON(data []byte) error
  • func (m *TunnelMode) UnmarshalYAML(unmarshal func(interface{}) error) error

Variables

var (
	// ModeMapping is a mapping for Mode enum
	ModeMapping = map[string]TunnelMode{
		Global.String(): Global,
		Rule.String():   Rule,
		Direct.String(): Direct,
	}
)

Functions

func Add

func Add(req C.ServerAdapter)

Add request to queue

func AddPacket

func AddPacket(packet *inbound.PacketAdapter)

AddPacket add udp Packet to queue

func Providers

func Providers() map[string]provider.ProxyProvider

Providers return all compatible providers

func Proxies

func Proxies() map[string]C.Proxy

Proxies return all proxies

func Rules

func Rules() []C.Rule

Rules return all rules

func SetMode

func SetMode(m TunnelMode)

SetMode change the mode of tunnel

func SetResolver

func SetResolver(r *dns.Resolver)

SetResolver set custom dns resolver for enhanced mode

func UpdateProxies

func UpdateProxies(newProxies map[string]C.Proxy, newProviders map[string]provider.ProxyProvider)

UpdateProxies handle update proxies

func UpdateRules

func UpdateRules(newRules []C.Rule)

UpdateRules handle update rules

Types

type Manager

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

var DefaultManager *Manager

func (*Manager) Download

func (m *Manager) Download() chan<- int64

func (*Manager) Join

func (m *Manager) Join(c tracker)

func (*Manager) Leave

func (m *Manager) Leave(c tracker)

func (*Manager) Now

func (m *Manager) Now() (up int64, down int64)

func (*Manager) ResetStatistic

func (m *Manager) ResetStatistic()

func (*Manager) Snapshot

func (m *Manager) Snapshot() *Snapshot

func (*Manager) Upload

func (m *Manager) Upload() chan<- int64

type Snapshot

type Snapshot struct {
	DownloadTotal int64     `json:"downloadTotal"`
	UploadTotal   int64     `json:"uploadTotal"`
	Connections   []tracker `json:"connections"`
}

type TrafficTrack

type TrafficTrack struct {
	net.Conn
	// contains filtered or unexported fields
}

TrafficTrack record traffic of net.Conn

func (*TrafficTrack) Read

func (tt *TrafficTrack) Read(b []byte) (int, error)

func (*TrafficTrack) Write

func (tt *TrafficTrack) Write(b []byte) (int, error)

type TunnelMode

type TunnelMode int

const (
	Global TunnelMode = iota
	Rule
	Direct
)

func Mode

func Mode() TunnelMode

Mode return current mode

func (TunnelMode) MarshalJSON

func (m TunnelMode) MarshalJSON() ([]byte, error)

MarshalJSON serialize Mode

func (TunnelMode) MarshalYAML

func (m TunnelMode) MarshalYAML() (interface{}, error)

MarshalYAML serialize TunnelMode with yaml

func (TunnelMode) String

func (m TunnelMode) String() string

func (*TunnelMode) UnmarshalJSON

func (m *TunnelMode) UnmarshalJSON(data []byte) error

UnmarshalJSON unserialize Mode

func (*TunnelMode) UnmarshalYAML

func (m *TunnelMode) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML unserialize Mode with yaml