internal

package

v0.0.0-...-b4139b0 Latest Latest Go to latest Published: Jul 21, 2023 License: GPL-3.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/zgwit/iot-gateway

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Close()
func Load() error
func LoadClient(m *types.Client) error
func LoadClients() error
func LoadProduct(m *types.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

Constants ¶

This section is empty.

Variables ¶

View Source

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 *types.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 {
	*types.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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL