udpTunnel

Documentation

Index

• type Config
• type Tunnel
  • func New(config Config) (*Tunnel, error)
  • func (t *Tunnel) Addr() []string
  • func (t *Tunnel) OnClosed(c gnet.Conn, err error) (action gnet.Action)
  • func (t *Tunnel) OnInitComplete(server gnet.Server) (action gnet.Action)
  • func (t *Tunnel) OnOpened(c gnet.Conn) (out []byte, action gnet.Action)
  • func (t *Tunnel) OnShutdown(server gnet.Server)
  • func (t *Tunnel) PreWrite()
  • func (t *Tunnel) React(frame []byte, c gnet.Conn) (out []byte, action gnet.Action)
  • func (t *Tunnel) Run()
  • func (t *Tunnel) Shutdown()
  • func (t *Tunnel) Start()
  • func (t *Tunnel) Tick() (delay time.Duration, action gnet.Action)

Types

type Config

type Config struct {
	ServerID      string
	Concurrency   int
	ListenAddress string
	MaxBodySize   int
	ExternalAddrs []string
}

Config

type Tunnel

type Tunnel struct {
	tunnel.MessageHandler
	// contains filtered or unexported fields
}

Tunnel

func New

func New(config Config) (*Tunnel, error)

func (*Tunnel) Addr

func (t *Tunnel) Addr() []string

func (*Tunnel) OnClosed

func (t *Tunnel) OnClosed(c gnet.Conn, err error) (action gnet.Action)

func (*Tunnel) OnInitComplete

func (t *Tunnel) OnInitComplete(server gnet.Server) (action gnet.Action)

func (*Tunnel) OnOpened

func (t *Tunnel) OnOpened(c gnet.Conn) (out []byte, action gnet.Action)

func (*Tunnel) OnShutdown

func (t *Tunnel) OnShutdown(server gnet.Server)

func (*Tunnel) PreWrite

func (t *Tunnel) PreWrite()

func (*Tunnel) React

func (t *Tunnel) React(frame []byte, c gnet.Conn) (out []byte, action gnet.Action)

func (*Tunnel) Run

func (t *Tunnel) Run()

func (*Tunnel) Shutdown

func (t *Tunnel) Shutdown()

func (*Tunnel) Start

func (t *Tunnel) Start()

func (*Tunnel) Tick

func (t *Tunnel) Tick() (delay time.Duration, action gnet.Action)