internal

Documentation

Index

• Variables
• func Close()
• func Load() error
• func LoadClient(m *types.Client) error
• func LoadClients() error
• func LoadProduct(m *modbus.Product) error
• func LoadProducts() error
• func LoadSerial(m *types.Serial) error
• func LoadSerials() error
• func LoadServer(m *types.Server) error
• func LoadServers() error
• func Offline(pid, id string)
• func Online(pid, id string)
• type Client
  • func GetClient(id string) *Client
  • func NewClient(client *types.Client) *Client
  • func (client *Client) Close() error
  • func (l *Client) Online() bool
  • func (client *Client) Open() error
  • func (l *Client) Pipe(pipe io.ReadWriteCloser)
  • func (l *Client) Read(data []byte) (int, error)
  • func (client *Client) Retry()
  • func (l *Client) Running() bool
  • func (l *Client) Write(data []byte) (int, error)
• type Link
  • func GetLink(id string) *Link
  • func (l *Link) Close() error
  • func (l *Link) Online() bool
  • func (l *Link) Open() error
  • func (l *Link) Pipe(pipe io.ReadWriteCloser)
  • func (l *Link) Read(data []byte) (int, error)
  • func (l *Link) Running() bool
  • func (l *Link) Write(data []byte) (int, error)
• type Product
  • func GetProduct(id string) *Product
• type Serial
  • func GetSerial(id string) *Serial
  • func NewSerial(model *types.Serial) *Serial
  • func (l *Serial) Close() error
  • func (l *Serial) Online() bool
  • func (s *Serial) Open() error
  • func (l *Serial) Pipe(pipe io.ReadWriteCloser)
  • func (l *Serial) Read(data []byte) (int, error)
  • func (s *Serial) Retry()
  • func (l *Serial) Running() bool
  • func (l *Serial) Write(data []byte) (int, error)
• type Server
  • func GetServer(id string) *Server
  • func NewServer(model *types.Server) *Server
  • func (s *Server) Close() (err error)
  • func (s *Server) GetTunnel(id string) connect.Tunnel
  • func (s *Server) Open() error
  • func (s *Server) Running() bool

Variables

var Products lib.Map[Product]

Functions

func Close

func Close()

func Load

func Load() error

func LoadClient

func LoadClient(m *types.Client) error

func LoadClients

func LoadClients() error

func LoadProduct

func LoadProduct(m *modbus.Product) error

func LoadProducts

func LoadProducts() error

func LoadSerial

func LoadSerial(m *types.Serial) error

func LoadSerials

func LoadSerials() error

func LoadServer

func LoadServer(m *types.Server) error

func LoadServers

func LoadServers() error

func Offline

func Offline(pid, id string)

func Online

func Online(pid, id string)

Types

type Client

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

Client 网络链接

func GetClient

func GetClient(id string) *Client

func NewClient

func NewClient(client *types.Client) *Client

func (*Client) Close

func (client *Client) Close() error

Close 关闭

func (*Client) Online

func (l *Client) Online() bool

func (*Client) Open

func (client *Client) Open() error

Open 打开

func (*Client) Pipe

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

func (*Client) Read

func (l *Client) Read(data []byte) (int, error)

Read 读

func (*Client) Retry

func (client *Client) Retry()

func (*Client) Running

func (l *Client) Running() bool

func (*Client) Write

func (l *Client) Write(data []byte) (int, error)

Write 写

type Link

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

Link 网络连接

func GetLink

func GetLink(id string) *Link

func (*Link) Close

func (l *Link) Close() error

Close 关闭

func (*Link) Online

func (l *Link) Online() bool

func (*Link) Open

func (l *Link) Open() error

func (*Link) Pipe

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

func (*Link) Read

func (l *Link) Read(data []byte) (int, error)

Read 读

func (*Link) Running

func (l *Link) Running() bool

func (*Link) Write

func (l *Link) Write(data []byte) (int, error)

Write 写

type Product

type Product struct {
	*modbus.Product
	// contains filtered or unexported fields
}

func GetProduct

func GetProduct(id string) *Product

type Serial

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

Serial 串口

func GetSerial

func GetSerial(id string) *Serial

func NewSerial

func NewSerial(model *types.Serial) *Serial

func (*Serial) Close

func (l *Serial) Close() error

Close 关闭

func (*Serial) Online

func (l *Serial) Online() bool

func (*Serial) Open

func (s *Serial) Open() error

Open 打开

func (*Serial) Pipe

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

func (*Serial) Read

func (l *Serial) Read(data []byte) (int, error)

Read 读

func (*Serial) Retry

func (s *Serial) Retry()

func (*Serial) Running

func (l *Serial) Running() bool

func (*Serial) Write

func (l *Serial) Write(data []byte) (int, error)

Write 写

type Server

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

Server TCP服务器

func GetServer

func GetServer(id string) *Server

func NewServer

func NewServer(model *types.Server) *Server

func (*Server) Close

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

Close 关闭

func (*Server) GetTunnel

func (s *Server) GetTunnel(id string) connect.Tunnel

GetTunnel 获取连接

func (*Server) Open

func (s *Server) Open() error

Open 打开

func (*Server) Running

func (s *Server) Running() bool