tunnel

Documentation

Index

• Constants
• Variables
• func AddStrRule(key string, value string)
• func CloseRuleMatchCon(rule C.Rule)
• func DeleteStrRule(key string)
• func DnsPreCache(domain string, ip string, remote net.Addr, ttl uint32)
• func GetnatPC(key string) C.PacketConn
• func LoadRule(rules []C.Rule) []C.Rule
• func LoadStrRule() []C.Rule
• func Providers() map[string]provider.ProxyProvider
• func Proxies() map[string]C.Proxy
• func Rules() []C.Rule
• func SetMode(m TunnelMode)
• func TCPIn() chan<- C.ConnContext
• func TrimArr(arr []string) (r []string)
• func UDPIn() chan<- *inbound.PacketAdapter
• func UpdateProxies(newProxies map[string]C.Proxy, newProviders map[string]provider.ProxyProvider)
• func UpdateRules(newRules []C.Rule)
• type IdleTimeoutConn
• type ReadOnlyReader
• 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
• type WriteOnlyWriter

Constants

const MapStringRule = "map-string-rule"

const MapDomainRule = "map-domain-rule" const MapIPRule = "map-domain-rule"

Variables

var (
	//Cm *concurrent_map.ConcurrentMap
	//Cm     = CMAP.New()
	//Cm = CC.New(CC.Configure().MaxSize(1024 * 128).ItemsToPrune(500).Buckets(1024 * 128 / 64))
	//Dm = CC.New(CC.Configure().MaxSize(1024 * 128).ItemsToPrune(500).Buckets(1024 * 128 / 64))
	Cm, _ = ristretto.NewCache(&ristretto.Config{
		NumCounters: 1e7,
		MaxCost:     1 << 28,
		BufferItems: 64,
	})
	Dm, _ = ristretto.NewCache(&ristretto.Config{
		NumCounters: 1e7,
		MaxCost:     1 << 28,
		BufferItems: 64,
	})
)

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

Functions

func AddStrRule

func AddStrRule(key string, value string)

func CloseRuleMatchCon

func CloseRuleMatchCon(rule C.Rule)

func DeleteStrRule

func DeleteStrRule(key string)

func DnsPreCache

func DnsPreCache(domain string, ip string, remote net.Addr, ttl uint32)

func GetnatPC

func GetnatPC(key string) C.PacketConn

func LoadRule

func LoadRule(rules []C.Rule) []C.Rule

func LoadStrRule

func LoadStrRule() []C.Rule

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 TCPIn

func TCPIn() chan<- C.ConnContext

TCPIn return fan-in queue

func TrimArr

func TrimArr(arr []string) (r []string)

func UDPIn

func UDPIn() chan<- *inbound.PacketAdapter

UDPIn return fan-in udp queue

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 IdleTimeoutConn

type IdleTimeoutConn struct {
	Conn    net.Conn
	Timeout time.Duration
}

type ReadOnlyReader

type ReadOnlyReader struct {
	io.Reader
}

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

type WriteOnlyWriter

type WriteOnlyWriter struct {
	io.Writer
}