connect

Documentation

Index

• func GetLinker(id string) interfaces.Linker
• func LoadLinker(id string) error
• func Startup() error
• func UnloadLinker(id string) error
• type GNetHandler
  • func NewGNetHandlerTcp(link *types.Linker, server *GNetServer) *GNetHandler
  • func (h *GNetHandler) OnBoot(eng gnet.Engine) (action gnet.Action)
  • func (h *GNetHandler) OnClose(c gnet.Conn, err error) (action gnet.Action)
  • func (h *GNetHandler) OnOpen(c gnet.Conn) (out []byte, action gnet.Action)
  • func (h *GNetHandler) OnShutdown(eng gnet.Engine)
  • func (h *GNetHandler) OnTick() (delay time.Duration, action gnet.Action)
  • func (h *GNetHandler) OnTraffic(c gnet.Conn) (action gnet.Action)
• type GNetServer
  • func NewGNetServer(l *types.Linker) *GNetServer
  • func (s *GNetServer) Close() error
  • func (s *GNetServer) Connected() bool
  • func (s *GNetServer) Open() error
  • func (s *GNetServer) Opened() bool
• type Incoming
  • func GetIncoming(id string) *Incoming
  • func (l *Incoming) Close() error
• type Serial
  • func NewSerial(l *types.Linker) *Serial
  • func (s *Serial) Close() (err error)
  • func (s *Serial) Connected() bool
  • func (s *Serial) Open() (err error)
  • func (s *Serial) Opened() bool
• type TcpClient
  • func NewTcpClient(l *types.Linker) *TcpClient
  • func (c *TcpClient) Close() (err error)
  • func (c *TcpClient) Connected() bool
  • func (c *TcpClient) Open() (err error)
  • func (c *TcpClient) Opened() bool
• type TcpServer
  • func NewTcpServer(l *types.Linker) *TcpServer
  • func (c *TcpServer) Close() error
  • func (c *TcpServer) Connected() bool
  • func (c *TcpServer) Open() (err error)
  • func (c *TcpServer) Opened() bool
• type UdpClient
  • func NewUdpClient(l *types.Linker) *UdpClient
  • func (c *UdpClient) Close() (err error)
  • func (c *UdpClient) Connected() bool
  • func (c *UdpClient) Open() (err error)
  • func (c *UdpClient) Opened() bool

Functions

func GetLinker

func GetLinker(id string) interfaces.Linker

func LoadLinker

func LoadLinker(id string) error

func Startup

func Startup() error

func UnloadLinker

func UnloadLinker(id string) error

Types

type GNetHandler

type GNetHandler struct {
	*types.Linker
	*GNetServer
	// contains filtered or unexported fields
}

func NewGNetHandlerTcp

func NewGNetHandlerTcp(link *types.Linker, server *GNetServer) *GNetHandler

func (*GNetHandler) OnBoot

func (h *GNetHandler) OnBoot(eng gnet.Engine) (action gnet.Action)

func (*GNetHandler) OnClose

func (h *GNetHandler) OnClose(c gnet.Conn, err error) (action gnet.Action)

func (*GNetHandler) OnOpen

func (h *GNetHandler) OnOpen(c gnet.Conn) (out []byte, action gnet.Action)

func (*GNetHandler) OnShutdown

func (h *GNetHandler) OnShutdown(eng gnet.Engine)

func (*GNetHandler) OnTick

func (h *GNetHandler) OnTick() (delay time.Duration, action gnet.Action)

func (*GNetHandler) OnTraffic

func (h *GNetHandler) OnTraffic(c gnet.Conn) (action gnet.Action)

type GNetServer

type GNetServer struct {
	*types.Linker
	// contains filtered or unexported fields
}

func NewGNetServer

func NewGNetServer(l *types.Linker) *GNetServer

func (*GNetServer) Close

func (s *GNetServer) Close() error

func (*GNetServer) Connected

func (s *GNetServer) Connected() bool

func (*GNetServer) Open

func (s *GNetServer) Open() error

func (*GNetServer) Opened

func (s *GNetServer) Opened() bool

type Incoming

type Incoming struct {
	*types.Incoming
	// contains filtered or unexported fields
}

func GetIncoming

func GetIncoming(id string) *Incoming

func (*Incoming) Close

func (l *Incoming) Close() error

type Serial

type Serial struct {
	*types.Linker

	serial.Port
	// contains filtered or unexported fields
}

func NewSerial

func NewSerial(l *types.Linker) *Serial

func (*Serial) Close

func (s *Serial) Close() (err error)

func (*Serial) Connected

func (s *Serial) Connected() bool

func (*Serial) Open

func (s *Serial) Open() (err error)

func (*Serial) Opened

func (s *Serial) Opened() bool

type TcpClient

type TcpClient struct {
	*types.Linker

	net.Conn
	// contains filtered or unexported fields
}

func NewTcpClient

func NewTcpClient(l *types.Linker) *TcpClient

func (*TcpClient) Close

func (c *TcpClient) Close() (err error)

func (*TcpClient) Connected

func (c *TcpClient) Connected() bool

func (*TcpClient) Open

func (c *TcpClient) Open() (err error)

func (*TcpClient) Opened

func (c *TcpClient) Opened() bool

type TcpServer

type TcpServer struct {
	*types.Linker

	net.Conn
	// contains filtered or unexported fields
}

func NewTcpServer

func NewTcpServer(l *types.Linker) *TcpServer

func (*TcpServer) Close

func (c *TcpServer) Close() error

func (*TcpServer) Connected

func (c *TcpServer) Connected() bool

func (*TcpServer) Open

func (c *TcpServer) Open() (err error)

func (*TcpServer) Opened

func (c *TcpServer) Opened() bool

type UdpClient

type UdpClient struct {
	*types.Linker

	net.Conn
	// contains filtered or unexported fields
}

func NewUdpClient

func NewUdpClient(l *types.Linker) *UdpClient

func (*UdpClient) Close

func (c *UdpClient) Close() (err error)

func (*UdpClient) Connected

func (c *UdpClient) Connected() bool

func (*UdpClient) Open

func (c *UdpClient) Open() (err error)

func (*UdpClient) Opened

func (c *UdpClient) Opened() bool