k1

package
v0.0.0-...-6aff857 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 21, 2018 License: MIT Imports: 22 Imported by: 1

Documentation

Index

Constants

View Source
const (
	NatSessionLifeSeconds   = 600
	NatSessionCheckInterval = 300
)
View Source
const (
	PROXY_POLICY  = "PROXY"
	DIRECT_POLICY = "DIRECT"
	REJECT_POLICY = "REJECT"
)
View Source
const DnsIPPoolMaxSpace = 0x3ffff // 4*65535

Variables

View Source
var MTU = 1500

Functions

func IsExistPatternScheme

func IsExistPatternScheme(scheme string) bool

Types

type ConnData

type ConnData struct {
	Src      string
	Dst      string
	Proxy    string
	Upload   int64
	Download int64
}

statistical data of every connection

type Dns

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

func NewDns

func NewDns(one *One, cfg DnsConfig) (*Dns, error)

func (*Dns) Serve

func (d *Dns) Serve() error

func (*Dns) ServeDNS

func (d *Dns) ServeDNS(w dns.ResponseWriter, r *dns.Msg)

type DnsConfig

type DnsConfig struct {
	DnsPort         uint16   `gcfg:"dns-port"`
	DnsTtl          uint     `gcfg:"dns-ttl"`
	DnsPacketSize   uint16   `gcfg:"dns-packet-size"`
	DnsReadTimeout  uint     `gcfg:"dns-read-timeout"`
	DnsWriteTimeout uint     `gcfg:"dns-write-timeout"`
	Nameserver      []string // backend dns
}

type DnsIPPool

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

func NewDnsIPPool

func NewDnsIPPool(ip net.IP, subnet *net.IPNet) *DnsIPPool

func (*DnsIPPool) Alloc

func (pool *DnsIPPool) Alloc(tips string) net.IP

use tips as a hint to find a stable index

func (*DnsIPPool) Capacity

func (pool *DnsIPPool) Capacity() int

func (*DnsIPPool) Contains

func (pool *DnsIPPool) Contains(ip net.IP) bool

func (*DnsIPPool) Release

func (pool *DnsIPPool) Release(ip net.IP)

type DnsTable

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

func NewDnsTable

func NewDnsTable(ip net.IP, subnet *net.IPNet) *DnsTable

func (*DnsTable) Contains

func (c *DnsTable) Contains(ip net.IP) bool

func (*DnsTable) Get

func (c *DnsTable) Get(domain string) *DomainRecord

func (*DnsTable) GetByIP

func (c *DnsTable) GetByIP(ip net.IP) *DomainRecord

func (*DnsTable) IsNonProxyDomain

func (c *DnsTable) IsNonProxyDomain(domain string) bool

func (*DnsTable) Serve

func (c *DnsTable) Serve() error

func (*DnsTable) Set

func (c *DnsTable) Set(domain string, proxy string) *DomainRecord

func (*DnsTable) SetNonProxyDomain

func (c *DnsTable) SetNonProxyDomain(domain string, ttl uint32)

type DomainKeywordPattern

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

DOMAIN-KEYWORD

func (*DomainKeywordPattern) Match

func (p *DomainKeywordPattern) Match(val interface{}) bool

func (*DomainKeywordPattern) Name

func (p *DomainKeywordPattern) Name() string

func (*DomainKeywordPattern) Policy

func (p *DomainKeywordPattern) Policy() string

func (*DomainKeywordPattern) Proxy

func (p *DomainKeywordPattern) Proxy() string

type DomainPattern

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

DOMAIN

func (*DomainPattern) Match

func (p *DomainPattern) Match(val interface{}) bool

func (*DomainPattern) Name

func (p *DomainPattern) Name() string

func (*DomainPattern) Policy

func (p *DomainPattern) Policy() string

func (*DomainPattern) Proxy

func (p *DomainPattern) Proxy() string

type DomainRecord

type DomainRecord struct {
	Hostname string // hostname
	Proxy    string // proxy

	IP      net.IP // nat ip
	RealIP  net.IP // real ip
	Hits    int
	Expires time.Time
	// contains filtered or unexported fields
}

hijacked domain

func (*DomainRecord) Answer

func (record *DomainRecord) Answer(request *dns.Msg) *dns.Msg

func (*DomainRecord) SetRealIP

func (record *DomainRecord) SetRealIP(msg *dns.Msg)

func (*DomainRecord) Touch

func (record *DomainRecord) Touch()

type DomainSuffixPattern

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

DOMAIN-SUFFIX

func (*DomainSuffixPattern) AddDomain

func (p *DomainSuffixPattern) AddDomain(val string)

func (*DomainSuffixPattern) Match

func (p *DomainSuffixPattern) Match(val interface{}) bool

func (*DomainSuffixPattern) Name

func (p *DomainSuffixPattern) Name() string

func (*DomainSuffixPattern) Policy

func (p *DomainSuffixPattern) Policy() string

func (*DomainSuffixPattern) Proxy

func (p *DomainSuffixPattern) Proxy() string

type GeneralConfig

type GeneralConfig struct {
	Network string // tun network
}

type IPCIDRPattern

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

IP-CIDR

func (*IPCIDRPattern) Match

func (p *IPCIDRPattern) Match(val interface{}) bool

func (*IPCIDRPattern) Name

func (p *IPCIDRPattern) Name() string

func (*IPCIDRPattern) Policy

func (p *IPCIDRPattern) Policy() string

func (*IPCIDRPattern) Proxy

func (p *IPCIDRPattern) Proxy() string

type IPCountryPattern

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

IP-COUNTRY

func (*IPCountryPattern) Match

func (p *IPCountryPattern) Match(val interface{}) bool

func (*IPCountryPattern) Name

func (p *IPCountryPattern) Name() string

func (*IPCountryPattern) Policy

func (p *IPCountryPattern) Policy() string

func (*IPCountryPattern) Proxy

func (p *IPCountryPattern) Proxy() string

type IPRange

type IPRange struct {
	Start uint32
	End   uint32
}

IPRangeArray

type IPRangeArray

type IPRangeArray []IPRange

func (IPRangeArray) Contains

func (a IPRangeArray) Contains(ip uint32) bool

func (IPRangeArray) ContainsIP

func (a IPRangeArray) ContainsIP(ip net.IP) bool

func (IPRangeArray) Len

func (a IPRangeArray) Len() int

func (IPRangeArray) Less

func (a IPRangeArray) Less(i, j int) bool

func (IPRangeArray) Swap

func (a IPRangeArray) Swap(i, j int)

type KoneConfig

type KoneConfig struct {
	General GeneralConfig
	TCP     NatConfig
	UDP     NatConfig
	Dns     DnsConfig
	Route   RouteConfig
	Proxy   map[string]*ProxyConfig
	Pattern map[string]*PatternConfig
	Rule    RuleConfig
	Manager ManagerConfig
}

func ParseConfig

func ParseConfig(filename string) (*KoneConfig, error)

type Manager

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

func NewManager

func NewManager(one *One, cfg ManagerConfig) *Manager

func (*Manager) Serve

func (m *Manager) Serve() error

type ManagerConfig

type ManagerConfig struct {
	Listen string
}

type Nat

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

func NewNat

func NewNat(from, to uint16) *Nat

type NatConfig

type NatConfig struct {
	ListenPort   uint16 `gcfg:"listen-port"`
	NatPortStart uint16 `gcfg:"nat-port-start"`
	NatPortEnd   uint16 `gcfg:"nat-port-end"`
}

type NatSession

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

type NatTable

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

func (*NatTable) Count

func (tbl *NatTable) Count() int

func (*NatTable) Map

func (tbl *NatTable) Map(ip net.IP, port uint16) (uint16, bool)

return: mapped port, is new mapped

func (*NatTable) Unmap

func (tbl *NatTable) Unmap(ip net.IP, port uint16)

type One

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

func FromConfig

func FromConfig(cfg *KoneConfig) (*One, error)

func (*One) Serve

func (one *One) Serve() error

type PacketFilter

type PacketFilter interface {
	Filter(wr io.Writer, p tcpip.IPv4Packet)
}

type PacketFilterFunc

type PacketFilterFunc func(wr io.Writer, p tcpip.IPv4Packet)

func (PacketFilterFunc) Filter

func (f PacketFilterFunc) Filter(wr io.Writer, p tcpip.IPv4Packet)

type Pattern

type Pattern interface {
	Name() string
	Policy() string
	Proxy() string
	Match(val interface{}) bool
}

func CreatePattern

func CreatePattern(name string, config *PatternConfig) Pattern

func NewDomainKeywordPattern

func NewDomainKeywordPattern(name, policy, proxy string, vals []string) Pattern

func NewDomainPattern

func NewDomainPattern(name, policy, proxy string, vals []string) Pattern

func NewDomainSuffixPattern

func NewDomainSuffixPattern(name, policy, proxy string, vals []string) Pattern

func NewIPCIDRPattern

func NewIPCIDRPattern(name, policy, proxy string, vals []string) Pattern

func NewIPCountryPattern

func NewIPCountryPattern(name, policy, proxy string, vals []string) Pattern

type PatternConfig

type PatternConfig struct {
	Policy string
	Proxy  string
	Scheme string
	V      []string
}

https://manual.nssurge.com/policy.html There are 3 types of policies: PROXY, DIRECT and REJECT

type Proxies

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

func NewProxies

func NewProxies(one *One, config map[string]*ProxyConfig) (*Proxies, error)

func (*Proxies) DefaultDial

func (p *Proxies) DefaultDial(network, addr string) (net.Conn, error)

func (*Proxies) Dial

func (p *Proxies) Dial(network, proxy, addr string) (net.Conn, error)

type ProxyConfig

type ProxyConfig struct {
	Url     string
	Default bool
}

type RouteConfig

type RouteConfig struct {
	V []string
}

type Rule

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

func NewRule

func NewRule(config RuleConfig, patterns map[string]*PatternConfig) *Rule

func (*Rule) DirectDomain

func (rule *Rule) DirectDomain(domain string)

func (*Rule) Proxy

func (rule *Rule) Proxy(val interface{}) (bool, string)

match a proxy for target `val`

func (*Rule) Reject

func (rule *Rule) Reject(val interface{}) bool

type RuleConfig

type RuleConfig struct {
	Pattern []string
	Final   string
}

There are 5 types of rules: DOMAIN, DOMAIN-SUFFIX, DOMAIN-KEYWORD, IP-COUNTRY and IP-CIDR

type TCPRelay

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

func NewTCPRelay

func NewTCPRelay(one *One, cfg NatConfig) *TCPRelay

func (*TCPRelay) Filter

func (r *TCPRelay) Filter(wr io.Writer, ipPacket tcpip.IPv4Packet)

redirect tcp packet to relay

func (*TCPRelay) Serve

func (r *TCPRelay) Serve() error

type TrafficRecord

type TrafficRecord struct {
	Name     string
	Upload   int64
	Download int64
	Touch    time.Time
	Details  map[string]*TrafficRecordDetail
}

type TrafficRecordDetail

type TrafficRecordDetail struct {
	EndPoint string
	Upload   int64
	Download int64
	Touch    time.Time
}

statistical data of every host/website/proxy

type TunDriver

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

func NewTunDriver

func NewTunDriver(ip net.IP, subnet *net.IPNet, filters map[tcpip.IPProtocol]PacketFilter) (*TunDriver, error)

func (*TunDriver) AddRoutes

func (tun *TunDriver) AddRoutes(vals []string)

func (*TunDriver) Serve

func (tun *TunDriver) Serve() error

type UDPRelay

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

func NewUDPRelay

func NewUDPRelay(one *One, cfg NatConfig) *UDPRelay

func (*UDPRelay) Filter

func (r *UDPRelay) Filter(wr io.Writer, ipPacket tcpip.IPv4Packet)

redirect udp packet to relay

func (*UDPRelay) Serve

func (r *UDPRelay) Serve() error

type UDPTunnel

type UDPTunnel struct {
	BndHost string
	BndPort uint16
	// contains filtered or unexported fields
}

func (*UDPTunnel) Pump

func (tunnel *UDPTunnel) Pump() error

func (*UDPTunnel) SetDeadline

func (tunnel *UDPTunnel) SetDeadline(duration time.Duration) error

func (*UDPTunnel) Write

func (tunnel *UDPTunnel) Write(b []byte) (int, error)

Jump to

Keyboard shortcuts

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