proxy

type Create func(p *Proto) Peer

type DialAddr func(point *xnet.Point, addr xnet.Addr) (net.Conn, error)

type Dialer interface {
	Open(t *Tunnel) error
}

type Do func(t *Tunnel) (err error)

type DohClient struct {
	*xnet.Doh
	Latency int
	// contains filtered or unexported fields
}

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

type Filter interface {
	BeforeDial(t *Tunnel, err error) error
	AfterDial(t *Tunnel, err error) error
	BeforeSend(t *Tunnel) error
	AfterSend(t *Tunnel) error
	BeforeReceive(t *Tunnel) error
	AfterReceive(t *Tunnel) error
}

type Peer interface {
	xnet.IDCode
	Dialer
	Filter
	io.Closer
	transport.Handler
	ServiceEventNotifier
	TunnelEventNotifier
	GetProto() *Proto
	Stat() *PointStat
	ClearConn()
}

type PointStat struct {
	Id          string
	Code        string
	Name        string
	Transport   string
	Protocol    string
	ConnCount   int
	StreamCount int
	IsDirect    bool
}

type Proto struct {
	*xnet.Point
	Filter
	Do Do
	DialAddr
	ServiceEventNotifier
	TunnelEventNotifier
	IsDirect bool
	// contains filtered or unexported fields
}

type Protocol struct {
	Name     string
	LocalFn  Create
	RemoteFn Create
}

type ServiceEventNotifier interface {
	OnStart()
	OnStop(err error)
	OnError(err error)
	OnFatal(err error)
	SubServiceEvent(s event.Stream) string
	CancelServiceEvent(id string)
}

type Stat struct {
	ConnCount   int
	StreamCount int
	Points      []*PointStat
}

type Tunnel struct {
	Id           string
	Method       byte
	Addr         xnet.Addr
	Src          net.Conn
	Dst          net.Conn
	SrcPeer      Peer
	DstPeer      Peer
	StartTime    int64
	OpenDuration int64
	Sent         int64
	SentDuration int64
	Received     int64
	RecvDuration int64
	CloseTime    int64
	PassMode     byte
	Connected    bool
	AutoTry      bool
	Multiple     bool
	Error        error
	Closed       bool
	SendDone     bool
	RecvDone     bool
	WriteSrcErr  error
	ReadSrcErr   error
	WriteDstErr  error
	ReadDstErr   error
	TunnelEventNotifier
	// contains filtered or unexported fields
}

type TunnelData map[string]interface{}

type TunnelEvent struct {
	Type      byte
	Id        string
	Bytes     int64
	Duration  int64
	Error     string
	Timestamp int64
}

type TunnelEventNotifier interface {
	OnTunnelOpen(t *Tunnel)
	OnTunnelClose(t *Tunnel)
	OnTunnelSent(t *Tunnel)
	OnTunnelReceived(t *Tunnel)
	SubTunnelEvent(s event.Stream) string
	CancelTunnelEvent(id string)
}

type WriteTimeOutError error