connect

Documentation

Index

• func FromLinker(l *types.Linker) error
• 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 FromLinker

func FromLinker(l *types.Linker) error

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