Documentation ¶
Index ¶
- Variables
- type Channel
- type ChannelRunner
- func (c *ChannelRunner) AddDailer(dailer Dailer) error
- func (c *ChannelRunner) OnClose(con netw.Con)
- func (c *ChannelRunner) OnConn(con netw.Con) bool
- func (c *ChannelRunner) OnDailF(con netw.Cmd) int
- func (c *ChannelRunner) OnDataF(con netw.Cmd) int
- func (c *ChannelRunner) OnRawCloseF(con netw.Cmd) int
- func (c *ChannelRunner) Start()
- func (c *ChannelRunner) Stop()
- func (c *ChannelRunner) String() string
- type ChannelServer
- func (c *ChannelServer) AddForward(forward *Forward) (err error)
- func (c *ChannelServer) AddUriForward(uri string) (err error)
- func (c *ChannelServer) AllForwards() (ns []string, fs map[string]*Channel)
- func (c *ChannelServer) Close()
- func (c *ChannelServer) Dail(raw net.Conn, name string, remote *url.URL) (err error)
- func (c *ChannelServer) OnClose(con netw.Con)
- func (c *ChannelServer) OnConn(con netw.Con) bool
- func (c *ChannelServer) OnDailBackF(con netw.Cmd) int
- func (c *ChannelServer) OnDataF(con netw.Cmd) int
- func (c *ChannelServer) OnHeartbeatF(con netw.Cmd) int
- func (c *ChannelServer) OnLoginF(con netw.Cmd) int
- func (c *ChannelServer) OnRawCloseF(con netw.Cmd) int
- func (c *ChannelServer) ProcWebForward(hs *routing.HTTPSession) routing.HResult
- func (c *ChannelServer) RemoveForward(local string) (err error)
- func (c *ChannelServer) Start() error
- func (c *ChannelServer) String() string
- type CmdDailer
- type CmdStdinWriter
- type CombinedReadWriterCloser
- type Dailer
- type DuplexPiped
- type EchoServer
- type Forward
- type ForwardListener
- type ForwardSorter
- type PipedConn
- func (p *PipedConn) Close() error
- func (p *PipedConn) LocalAddr() net.Addr
- func (p *PipedConn) Network() string
- func (p *PipedConn) Read(b []byte) (n int, err error)
- func (p *PipedConn) RemoteAddr() net.Addr
- func (p *PipedConn) SetDeadline(t time.Time) error
- func (p *PipedConn) SetReadDeadline(t time.Time) error
- func (p *PipedConn) SetWriteDeadline(t time.Time) error
- func (p *PipedConn) String() string
- func (p *PipedConn) Write(b []byte) (n int, err error)
- type TCPDailer
- type WebDailer
- func (web *WebDailer) Accept() (conn net.Conn, err error)
- func (web *WebDailer) Addr() net.Addr
- func (web *WebDailer) Bootstrap() error
- func (web *WebDailer) Close() error
- func (web *WebDailer) Dail(cid uint32, uri string) (raw io.ReadWriteCloser, err error)
- func (web *WebDailer) Matched(uri string) bool
- func (web *WebDailer) Network() string
- func (web *WebDailer) ServeHTTP(resp http.ResponseWriter, req *http.Request)
- func (web *WebDailer) Shutdown() error
- func (web *WebDailer) String() string
- type WebDailerConn
- type WebdavHandler
Constants ¶
This section is empty.
Variables ¶
View Source
var CMD_CTRL_C = []byte{255, 244, 255, 253, 6}
View Source
var ChannelByteClose = []byte{40}
View Source
var ChannelByteDail = []byte{20}
View Source
var ChannelByteData = []byte{30}
View Source
var ChannelByteHeartbeat = []byte{0}
View Source
var ChannelByteLogin = []byte{10}
View Source
var ShowLog int
Functions ¶
This section is empty.
Types ¶
type ChannelRunner ¶
type ChannelRunner struct { R *netw.NConRunner Name string Token string Dailers []Dailer // contains filtered or unexported fields }
func NewChannelRunner ¶
func NewChannelRunner(addr, name, token string) (runner *ChannelRunner)
func (*ChannelRunner) AddDailer ¶
func (c *ChannelRunner) AddDailer(dailer Dailer) error
func (*ChannelRunner) OnClose ¶
func (c *ChannelRunner) OnClose(con netw.Con)
func (*ChannelRunner) OnRawCloseF ¶
func (c *ChannelRunner) OnRawCloseF(con netw.Cmd) int
func (*ChannelRunner) Start ¶
func (c *ChannelRunner) Start()
func (*ChannelRunner) Stop ¶
func (c *ChannelRunner) Stop()
func (*ChannelRunner) String ¶
func (c *ChannelRunner) String() string
type ChannelServer ¶
type ChannelServer struct { L *netw.Listener ACL map[string]string HbDelay int64 WebSuffix string WebAuth string // contains filtered or unexported fields }
func NewChannelServer ¶
func NewChannelServer(port string, n string) (server *ChannelServer)
func (*ChannelServer) AddForward ¶
func (c *ChannelServer) AddForward(forward *Forward) (err error)
func (*ChannelServer) AddUriForward ¶
func (c *ChannelServer) AddUriForward(uri string) (err error)
func (*ChannelServer) AllForwards ¶
func (c *ChannelServer) AllForwards() (ns []string, fs map[string]*Channel)
func (*ChannelServer) Close ¶
func (c *ChannelServer) Close()
func (*ChannelServer) OnClose ¶
func (c *ChannelServer) OnClose(con netw.Con)
func (*ChannelServer) OnDailBackF ¶
func (c *ChannelServer) OnDailBackF(con netw.Cmd) int
func (*ChannelServer) OnHeartbeatF ¶
func (c *ChannelServer) OnHeartbeatF(con netw.Cmd) int
func (*ChannelServer) OnRawCloseF ¶
func (c *ChannelServer) OnRawCloseF(con netw.Cmd) int
func (*ChannelServer) ProcWebForward ¶
func (c *ChannelServer) ProcWebForward(hs *routing.HTTPSession) routing.HResult
func (*ChannelServer) RemoveForward ¶
func (c *ChannelServer) RemoveForward(local string) (err error)
func (*ChannelServer) Start ¶
func (c *ChannelServer) Start() error
func (*ChannelServer) String ¶
func (c *ChannelServer) String() string
type CmdStdinWriter ¶
type CombinedReadWriterCloser ¶
type CombinedReadWriterCloser struct { io.Reader io.Writer Closer func() error // contains filtered or unexported fields }
func (*CombinedReadWriterCloser) Close ¶
func (c *CombinedReadWriterCloser) Close() (err error)
type DuplexPiped ¶
type DuplexPiped struct { UpReader *os.File UpWriter *os.File DownReader *os.File DownWriter *os.File // contains filtered or unexported fields }
func (*DuplexPiped) Close ¶
func (d *DuplexPiped) Close() error
type EchoServer ¶
func NewEchoServer ¶
func NewEchoServer(network, address string) (echo *EchoServer, err error)
func (*EchoServer) Start ¶
func (e *EchoServer) Start()
type ForwardListener ¶
func (*ForwardListener) String ¶
func (f *ForwardListener) String() string
type ForwardSorter ¶
type ForwardSorter []*Forward
func (ForwardSorter) Len ¶
func (f ForwardSorter) Len() int
func (ForwardSorter) Less ¶
func (f ForwardSorter) Less(i, j int) bool
func (ForwardSorter) Swap ¶
func (f ForwardSorter) Swap(i, j int)
type PipedConn ¶
type PipedConn struct {
// contains filtered or unexported fields
}
func CreatePipedConn ¶
func (*PipedConn) RemoteAddr ¶
type TCPDailer ¶
type TCPDailer struct {
// contains filtered or unexported fields
}
func NewTCPDailer ¶
func NewTCPDailer() *TCPDailer
type WebDailer ¶
type WebDailer struct {
// contains filtered or unexported fields
}
func NewWebDailer ¶
func NewWebDailer() (dailer *WebDailer)
type WebDailerConn ¶
func PipeWebDailerConn ¶
func PipeWebDailerConn(cid uint32, uri string) (conn *WebDailerConn, raw io.ReadWriteCloser, err error)
func (*WebDailerConn) LocalAddr ¶
func (w *WebDailerConn) LocalAddr() net.Addr
func (*WebDailerConn) Network ¶
func (w *WebDailerConn) Network() string
func (*WebDailerConn) RemoteAddr ¶
func (w *WebDailerConn) RemoteAddr() net.Addr
func (*WebDailerConn) String ¶
func (w *WebDailerConn) String() string
type WebdavHandler ¶
type WebdavHandler struct {
// contains filtered or unexported fields
}
func NewWebdavHandler ¶
func NewWebdavHandler(dir string) *WebdavHandler
func (*WebdavHandler) ServeHTTP ¶
func (w *WebdavHandler) ServeHTTP(resp http.ResponseWriter, req *http.Request)
Click to show internal directories.
Click to hide internal directories.