core

package module
v1.0.5 Latest Latest
Warning

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

 Go to latest Published: May 6, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// CommandExecuteResultCodeSuccess 成功
	CommandExecuteResultCodeSuccess = 0
	// CommandExecuteResultCodeSending 正在执行指令中
	CommandExecuteResultCodeSending = -1
	// CommandExecuteResultCodeTimeout 执行超时
	CommandExecuteResultCodeTimeout = -2
	// CommandExecuteResultCodeSystemError 系统错误
	CommandExecuteResultCodeSystemError = -3
)

Variables

This section is empty.

Functions

func BytesToHexString 

func BytesToHexString(data []byte) string

BytesToHexString 字节数组转16进制字符串

func HexStringToBytes 

func HexStringToBytes(data string) []byte

HexStringToBytes 16进制字符串转字节数组

func NewError 

func NewError(code int, message string) error

NewError 实例化错误

func Ping added in v1.0.4 

func Ping(host string, times int) bool

Ping PING指令，PING通了立即返回, host:IP地址, times: PING次数

Types

type AsynCommandExecutor 

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

AsynCommandExecutor 异步指令执行器

func NewAsynCommandExecutor 

func NewAsynCommandExecutor(stream IStream) *AsynCommandExecutor

NewAsynCommandExecutor 实例化异步指令执行器

func (*AsynCommandExecutor) Close 

func (stream *AsynCommandExecutor) Close() error

Close 关闭

func (*AsynCommandExecutor) ExecCommand 

func (stream *AsynCommandExecutor) ExecCommand(cmd []byte, receiver func(data []byte), timeout int, recount int, dataAssert func(data []byte) bool, eventListener func(err error)) error

ExecCommand 执行指令

func (*AsynCommandExecutor) Open 

func (stream *AsynCommandExecutor) Open() error

Open 打开

func (*AsynCommandExecutor) SetReceiver 

func (stream *AsynCommandExecutor) SetReceiver(receiver func(data []byte))

SetReceiver 设置数据接收器

func (*AsynCommandExecutor) Write 

func (stream *AsynCommandExecutor) Write(data []byte) error

Write 写入数据

type CmdRunner added in v1.0.5 

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

CmdRunner 操作系统指令执行器，支持多条

func NewCmdRunner added in v1.0.5 

func NewCmdRunner(cmd []string, params []string) *CmdRunner

NewCmdRunner 实例化

func (*CmdRunner) RealRun added in v1.0.5 

func (runner *CmdRunner) RealRun(receiver func(int, string, string, error))

RealRun 执行指令，实时输出，执行完之后，函数返回 receiver - 执行指令回调:参数1-指令序号，从0开始，参数2-标准输出，参数3-错误输出，参数4-执行错误

func (*CmdRunner) Run added in v1.0.5 

func (runner *CmdRunner) Run() ([]string, []string, []error)

Run 同步方式执行，只有执行完毕之后才会返回结果 返回参数1-标准输出，返回参数2-标准错误输出，参数3-错误信息

type CommandExecutor 

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

CommandExecutor 同步指令执行器

func NewCommandExecutor 

func NewCommandExecutor(stream IStream) *CommandExecutor

NewCommandExecutor 实例化同步指令执行器

func (*CommandExecutor) Close 

func (stream *CommandExecutor) Close() error

Close 关闭

func (*CommandExecutor) ExecCommand 

func (stream *CommandExecutor) ExecCommand(cmd []byte, timeout int, recount int, dataAssert func(data []byte) bool) ([]byte, error)

ExecCommand 执行指令

func (*CommandExecutor) Open 

func (stream *CommandExecutor) Open() error

Open 打开

func (*CommandExecutor) SetReceiver 

func (stream *CommandExecutor) SetReceiver(receiver func(data []byte))

SetReceiver 设置数据接收器

func (*CommandExecutor) Write 

func (stream *CommandExecutor) Write(data []byte) error

Write 写入数据

type DataGroupStream added in v1.0.5 

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

DataGroupStream 数据帧处理类

func NewDataGroupStream added in v1.0.5 

func NewDataGroupStream(stream IStream, wrap IDataGroupWrapper) *DataGroupStream

NewDataGroupStream 实例化

func (*DataGroupStream) Close added in v1.0.5 

func (s *DataGroupStream) Close() error

Close closes the stream

func (*DataGroupStream) IsOpened added in v1.0.5 

func (s *DataGroupStream) IsOpened() bool

IsOpened 是否打开

func (*DataGroupStream) Open added in v1.0.5 

func (s *DataGroupStream) Open() error

Open opens the stream

func (*DataGroupStream) SetReceiver added in v1.0.5 

func (s *DataGroupStream) SetReceiver(receiver func(data []byte))

SetReceiver 设置数据接收器

func (*DataGroupStream) Write added in v1.0.5 

func (s *DataGroupStream) Write(data []byte) error

Write implements the stream

type IDataGroupWrapper added in v1.0.5 

type IDataGroupWrapper interface {
	GroupData(data []byte, callback func(data []byte))
}

IDataGroupWrapper 数据解包接口，将收到的数据进行完整包处理

type IStream 

type IStream interface {
	Open() error
	Close() error
	Write(data []byte) error
	SetReceiver(receiver func(data []byte))
	IsOpened() bool
}

IStream 输入输出流

type ReaderError 

type ReaderError struct {
	Code    int
	Message string
}

ReaderError 自定义错误

func (*ReaderError) Error 

func (err *ReaderError) Error() string

type SSHClient 

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

SSHClient SSH客户端

func (*SSHClient) Close 

func (c *SSHClient) Close()

Close 关闭

func (*SSHClient) Execute 

func (c *SSHClient) Execute(cmds []string) ([]string, error)

Execute 执行指令

func (*SSHClient) Open 

func (c *SSHClient) Open(address string, username string, password string) error

Open 打开连接

type SerialPortStream 

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

SerialPortStream 串口流操作类

func NewSerialPortStream 

func NewSerialPortStream(name string, baud int) *SerialPortStream

NewSerialPortStream 实例化串口操作类

func (*SerialPortStream) Close 

func (s *SerialPortStream) Close() error

Close 关闭串口

func (*SerialPortStream) IsOpened 

func (s *SerialPortStream) IsOpened() bool

IsOpened 判断是否已打开

func (*SerialPortStream) Open 

func (s *SerialPortStream) Open() error

Open 打开串口

func (*SerialPortStream) SetReceiver 

func (s *SerialPortStream) SetReceiver(receiver func(data []byte))

SetReceiver 设置数据接收器

func (*SerialPortStream) Write 

func (s *SerialPortStream) Write(data []byte) error

Write 写入数据

type SingleCmdRunner added in v1.0.5 

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

SingleCmdRunner 单条指令执行器

func NewSingleCmdRunner added in v1.0.5 

func NewSingleCmdRunner(cmd string, param string) *SingleCmdRunner

NewSingleCmdRunner 实例化单指令执行器。cmd - 指令， param - 参数

func (*SingleCmdRunner) RealRun added in v1.0.5 

func (runner *SingleCmdRunner) RealRun(receiver func(string, string, error)) error

RealRun 执行指令，实时输出,执行完之后，函数返回 receiver - 执行指令回调:参数1-标准输出，参数2-错误输出，参数3-执行错误

func (*SingleCmdRunner) Run added in v1.0.5 

func (runner *SingleCmdRunner) Run() (string, string, error)

Run 执行指令。 返回参数1-标准输出，返回参数2-标准错误输出，参数3-错误信息

type TCPClient added in v1.0.2 

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

TCPClient TCP客户端

func NewTCPClient added in v1.0.2 

func NewTCPClient(raddr string, laddr string, isReconnected bool) *TCPClient

NewTCPClient 实例化TCP客户端, raddr:服务端IP地址及端口(如：192.168.2.12:12001)，laddr:本地端IP地址及端口(如：127.0.0.1:13001)可为空,isReconnected: 是否重连

func (*TCPClient) Close added in v1.0.2 

func (c *TCPClient) Close() error

Close stops the TCP client

func (*TCPClient) IsOpened added in v1.0.2 

func (c *TCPClient) IsOpened() bool

IsOpened 判断是否已打开

func (*TCPClient) Open added in v1.0.2 

func (c *TCPClient) Open() error

Open starts the TCP client

func (*TCPClient) SetReceiver added in v1.0.2 

func (c *TCPClient) SetReceiver(receiver func(data []byte))

SetReceiver set receiver of the TCP client

func (*TCPClient) Write added in v1.0.2 

func (c *TCPClient) Write(data []byte) error

Write 写入数据

type TCPClientStream 

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

TCPClientStream TCP客户端实现

type TCPStream 

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

TCPStream TCP数据写入读取底层实现

func NewTCPStream 

func NewTCPStream(conn *net.TCPConn, eventReporter func(err error)) *TCPStream

NewTCPStream 实例化

func (*TCPStream) Close 

func (t *TCPStream) Close()

Close 关闭

func (*TCPStream) IsOpened 

func (t *TCPStream) IsOpened() bool

IsOpened 判断是否已打开

func (*TCPStream) Open 

func (t *TCPStream) Open() error

Open 打开端口，并开启数据接收线程

func (*TCPStream) SetReceiver 

func (t *TCPStream) SetReceiver(receiver func(data []byte))

SetReceiver 设置数据接收器

func (*TCPStream) Write 

func (t *TCPStream) Write(data []byte) error

Write 写入数据

type UDPStream 

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

UDPStream UDP数据收发流

func NewUDPStream 

func NewUDPStream(address string, laddr string) *UDPStream

NewUDPStream 实例化, address: 对端地址， laddr: 本端地址

func (*UDPStream) Close 

func (stream *UDPStream) Close() error

Close 关闭UDP socket

func (*UDPStream) IsOpened 

func (stream *UDPStream) IsOpened() bool

IsOpened 判断是否已打开

func (*UDPStream) Open 

func (stream *UDPStream) Open() error

Open 打开UDP

func (*UDPStream) SetReceiver 

func (stream *UDPStream) SetReceiver(receiver func(data []byte))

SetReceiver 设置数据监听器

func (*UDPStream) Write 

func (stream *UDPStream) Write(data []byte) error

Write 写入数据

Source Files

View all Source files

Directories

Path Synopsis

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.