stream

Documentation

Index

• Variables
• func Copy(local, remote io.ReadWriteCloser)
• func NewReadWriter(conn net.Conn) io.ReadWriteCloser
• type Conn
• type Dialer
• type Handler
  • func NewHandler(dialer Dialer) *Handler
  • func (w *Handler) Serve(wan *Wan)
• type PollTaskPool
  • func NewPollTaskPool(parallel, capacity int) *PollTaskPool
  • func (p *PollTaskPool) Add(id uint64, task func())
  • func (p *PollTaskPool) Close()
  • func (p *PollTaskPool) Wait()
• type Signal
  • func NewSignal() *Signal
  • func (s *Signal) Notify(err error)
  • func (s *Signal) Wait(timeout time.Duration) error
• type TaskPool
  • func NewTaskPool(parallel, capacity int) *TaskPool
  • func (p *TaskPool) Add(task func())
  • func (p *TaskPool) Close()
  • func (p *TaskPool) Wait()
• type Wan
  • func NewWan(conn net.Conn, state ws.State) *Wan
  • func (w *Wan) Accept(id string, local net.Addr, config *msg.WspConfig) (io.ReadWriteCloser, error)
  • func (w *Wan) Bridge(req *msg.Data, config *msg.WspConfig, rwan *Wan) error
  • func (w *Wan) DialHTTP(remote *msg.WspConfig) (net.Conn, error)
  • func (w *Wan) DialTCP(local net.Addr, remote *msg.WspConfig) (io.ReadWriteCloser, error)
  • func (w *Wan) HeartBeat(d time.Duration)
  • func (w *Wan) Reply(id string, message error) (err error)

Variables

var ErrConnNotExist = errors.New("connection does not exist")

Functions

func Copy

func Copy(local, remote io.ReadWriteCloser)

func NewReadWriter

func NewReadWriter(conn net.Conn) io.ReadWriteCloser

Types

type Conn

type Conn interface {
	TaskID() uint64
	Rewrite(data *msg.Data) (n int, err error)
	Interrupt() error
	io.Closer
}

type Dialer

type Dialer interface {
	NewConn(data *msg.Data, req *msg.WspRequest) error
}

type Handler

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

func NewHandler

func NewHandler(dialer Dialer) *Handler

func (*Handler) Serve

func (w *Handler) Serve(wan *Wan)

type PollTaskPool

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

func NewPollTaskPool

func NewPollTaskPool(parallel, capacity int) *PollTaskPool

func (*PollTaskPool) Add

func (p *PollTaskPool) Add(id uint64, task func())

func (*PollTaskPool) Close

func (p *PollTaskPool) Close()

func (*PollTaskPool) Wait

func (p *PollTaskPool) Wait()

type Signal

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

func NewSignal

func NewSignal() *Signal

func (*Signal) Notify

func (s *Signal) Notify(err error)

func (*Signal) Wait

func (s *Signal) Wait(timeout time.Duration) error

type TaskPool

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

func NewTaskPool

func NewTaskPool(parallel, capacity int) *TaskPool

func (*TaskPool) Add

func (p *TaskPool) Add(task func())

func (*TaskPool) Close

func (p *TaskPool) Close()

func (*TaskPool) Wait

func (p *TaskPool) Wait()

type Wan

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

func NewWan

func NewWan(conn net.Conn, state ws.State) *Wan

func (*Wan) Accept

func (w *Wan) Accept(id string, local net.Addr, config *msg.WspConfig) (io.ReadWriteCloser, error)

func (*Wan) Bridge

func (w *Wan) Bridge(req *msg.Data, config *msg.WspConfig, rwan *Wan) error

func (*Wan) DialHTTP

func (w *Wan) DialHTTP(remote *msg.WspConfig) (net.Conn, error)

func (*Wan) DialTCP

func (w *Wan) DialTCP(local net.Addr, remote *msg.WspConfig) (io.ReadWriteCloser, error)

func (*Wan) HeartBeat

func (w *Wan) HeartBeat(d time.Duration)

func (*Wan) Reply

func (w *Wan) Reply(id string, message error) (err error)