connect

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 19, 2022 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server added in v1.2.1 

type Server interface {
	events.EventInterface

	Open() error
	Close() error
	GetTunnel(id int64) Tunnel
	Running() bool
}

Server 通道

func NewServer added in v1.2.1 

func NewServer(server *model.Server) (Server, error)

NewServer 创建通道

type ServerTCP added in v1.2.1 

type ServerTCP struct {
	events.EventEmitter
	// contains filtered or unexported fields
}

ServerTCP TCP服务器

func (*ServerTCP) Close added in v1.2.1 

func (server *ServerTCP) Close() (err error)

Close 关闭

func (*ServerTCP) GetTunnel added in v1.2.1 

func (server *ServerTCP) GetTunnel(id int64) Tunnel

GetTunnel 获取连接

func (*ServerTCP) Open added in v1.2.1 

func (server *ServerTCP) Open() error

Open 打开

func (*ServerTCP) Running added in v1.2.1 

func (server *ServerTCP) Running() bool

type ServerTcpTunnel added in v1.2.1 

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

ServerTcpTunnel 网络连接

func (*ServerTcpTunnel) Ask added in v1.2.1 

func (l *ServerTcpTunnel) Ask(cmd []byte, timeout time.Duration) ([]byte, error)

func (*ServerTcpTunnel) Close added in v1.2.1 

func (l *ServerTcpTunnel) Close() error

Close 关闭

func (*ServerTcpTunnel) First added in v1.2.1 

func (l *ServerTcpTunnel) First() bool

func (*ServerTcpTunnel) Model added in v1.2.1 

func (l *ServerTcpTunnel) Model() *model.Tunnel

func (*ServerTcpTunnel) Open added in v1.2.1 

func (l *ServerTcpTunnel) Open() error

func (*ServerTcpTunnel) Pipe added in v1.2.1 

func (l *ServerTcpTunnel) Pipe(pipe io.ReadWriteCloser)

func (*ServerTcpTunnel) Running added in v1.2.1 

func (l *ServerTcpTunnel) Running() bool

func (*ServerTcpTunnel) Write added in v1.2.1 

func (l *ServerTcpTunnel) Write(data []byte) error

Write 写

type ServerUDP added in v1.2.1 

type ServerUDP struct {
	events.EventEmitter
	// contains filtered or unexported fields
}

ServerUDP UDP服务器

func (*ServerUDP) Close added in v1.2.1 

func (server *ServerUDP) Close() (err error)

Close 关闭

func (*ServerUDP) GetTunnel added in v1.2.1 

func (server *ServerUDP) GetTunnel(id int64) Tunnel

GetTunnel 获取链接

func (*ServerUDP) Open added in v1.2.1 

func (server *ServerUDP) Open() error

Open 打开

func (*ServerUDP) Running added in v1.2.1 

func (server *ServerUDP) Running() bool

type ServerUdpTunnel added in v1.2.1 

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

ServerUdpTunnel UDP链接

func (*ServerUdpTunnel) Ask added in v1.2.1 

func (l *ServerUdpTunnel) Ask(cmd []byte, timeout time.Duration) ([]byte, error)

func (*ServerUdpTunnel) Close added in v1.2.1 

func (l *ServerUdpTunnel) Close() error

func (*ServerUdpTunnel) First added in v1.2.1 

func (l *ServerUdpTunnel) First() bool

func (*ServerUdpTunnel) Model added in v1.2.1 

func (l *ServerUdpTunnel) Model() *model.Tunnel

func (*ServerUdpTunnel) Open added in v1.2.1 

func (l *ServerUdpTunnel) Open() error

func (*ServerUdpTunnel) Pipe added in v1.2.1 

func (l *ServerUdpTunnel) Pipe(pipe io.ReadWriteCloser)

func (*ServerUdpTunnel) Running added in v1.2.1 

func (l *ServerUdpTunnel) Running() bool

func (*ServerUdpTunnel) Write added in v1.2.1 

func (l *ServerUdpTunnel) Write(data []byte) error

Write 写

type Tunnel 

type Tunnel interface {
	events.EventInterface

	Model() *model.Tunnel

	Write(data []byte) error

	Open() error

	Close() error

	Running() bool

	First() bool

	//Pipe 透传
	Pipe(pipe io.ReadWriteCloser)

	//Ask 发送指令，接收数据
	Ask(cmd []byte, timeout time.Duration) ([]byte, error)
}

Tunnel 通道

func NewTunnel 

func NewTunnel(tunnel *model.Tunnel) (Tunnel, error)

NewTunnel 创建通道

type TunnelClient added in v1.2.1 

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

TunnelClient 网络链接

func (*TunnelClient) Ask added in v1.2.1 

func (l *TunnelClient) Ask(cmd []byte, timeout time.Duration) ([]byte, error)

func (*TunnelClient) Close added in v1.2.1 

func (client *TunnelClient) Close() error

Close 关闭

func (*TunnelClient) First added in v1.2.1 

func (l *TunnelClient) First() bool

func (*TunnelClient) Model added in v1.2.1 

func (l *TunnelClient) Model() *model.Tunnel

func (*TunnelClient) Open added in v1.2.1 

func (client *TunnelClient) Open() error

Open 打开

func (*TunnelClient) Pipe added in v1.2.1 

func (l *TunnelClient) Pipe(pipe io.ReadWriteCloser)

func (*TunnelClient) Retry added in v1.2.2 

func (client *TunnelClient) Retry()

func (*TunnelClient) Running added in v1.2.1 

func (l *TunnelClient) Running() bool

func (*TunnelClient) Write added in v1.2.1 

func (l *TunnelClient) Write(data []byte) error

Write 写

type TunnelSerial added in v1.2.1 

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

TunnelSerial 串口

func (*TunnelSerial) Ask added in v1.2.1 

func (l *TunnelSerial) Ask(cmd []byte, timeout time.Duration) ([]byte, error)

func (*TunnelSerial) Close added in v1.2.1 

func (l *TunnelSerial) Close() error

Close 关闭

func (*TunnelSerial) First added in v1.2.1 

func (l *TunnelSerial) First() bool

func (*TunnelSerial) Model added in v1.2.1 

func (l *TunnelSerial) Model() *model.Tunnel

func (*TunnelSerial) Open added in v1.2.1 

func (s *TunnelSerial) Open() error

Open 打开

func (*TunnelSerial) Pipe added in v1.2.1 

func (l *TunnelSerial) Pipe(pipe io.ReadWriteCloser)

func (*TunnelSerial) Retry added in v1.2.2 

func (s *TunnelSerial) Retry()

func (*TunnelSerial) Running added in v1.2.1 

func (l *TunnelSerial) Running() bool

func (*TunnelSerial) Write added in v1.2.1 

func (l *TunnelSerial) Write(data []byte) error

Write 写

type TunnelTcpServer added in v1.2.1 

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

TunnelTcpServer TCP服务器

func (*TunnelTcpServer) Ask added in v1.2.1 

func (l *TunnelTcpServer) Ask(cmd []byte, timeout time.Duration) ([]byte, error)

func (*TunnelTcpServer) Close added in v1.2.1 

func (server *TunnelTcpServer) Close() error

Close 关闭

func (*TunnelTcpServer) First added in v1.2.1 

func (l *TunnelTcpServer) First() bool

func (*TunnelTcpServer) Model added in v1.2.1 

func (l *TunnelTcpServer) Model() *model.Tunnel

func (*TunnelTcpServer) Open added in v1.2.1 

func (server *TunnelTcpServer) Open() error

Open 打开

func (*TunnelTcpServer) Pipe added in v1.2.1 

func (l *TunnelTcpServer) Pipe(pipe io.ReadWriteCloser)

func (*TunnelTcpServer) Running added in v1.2.1 

func (l *TunnelTcpServer) Running() bool

func (*TunnelTcpServer) Write added in v1.2.1 

func (l *TunnelTcpServer) Write(data []byte) error

Write 写

type TunnelUdpServer added in v1.2.1 

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

TunnelUdpServer UDP服务器

func (*TunnelUdpServer) Ask added in v1.2.1 

func (server *TunnelUdpServer) Ask(cmd []byte, timeout time.Duration) ([]byte, error)

func (*TunnelUdpServer) Close added in v1.2.1 

func (server *TunnelUdpServer) Close() (err error)

Close 关闭

func (*TunnelUdpServer) First added in v1.2.1 

func (l *TunnelUdpServer) First() bool

func (*TunnelUdpServer) Model added in v1.2.1 

func (l *TunnelUdpServer) Model() *model.Tunnel

func (*TunnelUdpServer) Open added in v1.2.1 

func (server *TunnelUdpServer) Open() error

Open 打开

func (*TunnelUdpServer) Pipe added in v1.2.1 

func (server *TunnelUdpServer) Pipe(pipe io.ReadWriteCloser)

func (*TunnelUdpServer) Running added in v1.2.1 

func (l *TunnelUdpServer) Running() bool

func (*TunnelUdpServer) Write added in v1.2.1 

func (server *TunnelUdpServer) Write(data []byte) error

Write 写

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.