connection

Jul 10, 2023

Changes in this version

type ConnType

+ const ConnTypeSerial

Jun 18, 2023

Changes in this version

+ const SerialNetwork

+ func NewSerialAddr(addr string, rate int, dataBits int, stopBits int, parity string) net.Addr

+ func NewSerialConn(port serial.Port, cfg *serial.Config) net.Conn

+ type SerialAddr struct

+ Address string

+ BaudRate int

+ DataBits int

+ Parity string

+ StopBits int

+ func (r *SerialAddr) Network() string

+ func (r *SerialAddr) String() string

+ type SerialConn struct

+ func (c *SerialConn) LocalAddr() net.Addr

+ func (c *SerialConn) RemoteAddr() net.Addr

+ func (c *SerialConn) SetDeadline(_ time.Time) error

+ func (c *SerialConn) SetReadDeadline(_ time.Time) error

+ func (c *SerialConn) SetWriteDeadline(_ time.Time) error

Jun 17, 2023

Changes in this version

+ const RTUNetwork

+ func NewRTUAddr(addr string, rate int, dataBits int, stopBits int, parity string) net.Addr

+ func NewRTUConn(port serial.Port, cfg *serial.Config) net.Conn

+ type RTUAddr struct

+ Address string

+ BaudRate int

+ DataBits int

+ Parity string

+ StopBits int

+ func (r *RTUAddr) Network() string

+ func (r *RTUAddr) String() string

+ type RTUConn struct

+ func (c *RTUConn) LocalAddr() net.Addr

+ func (c *RTUConn) RemoteAddr() net.Addr

+ func (c *RTUConn) SetDeadline(_ time.Time) error

+ func (c *RTUConn) SetReadDeadline(_ time.Time) error

+ func (c *RTUConn) SetWriteDeadline(_ time.Time) error

Jun 17, 2023

Changes in this version

+ const DefaultGroupName

+ const StatusClosed

+ const StatusPending

+ const StatusPrepare

+ const StatusStart

+ const StatusWorking

+ var DeleteDefaultGroupNotAllow = errors.New("delete default group not allow")

+ var ErrBrokenPipe = errors.New("broken low-level pipe")

+ var ErrCloseClosedGroup = errors.New("close closed group")

+ var ErrCloseClosedSession = errors.New("close closed session")

+ var ErrClosedGroup = errors.New("group closed")

+ type Channel interface

+ Process func(c *Connection, v interface{}) error

+ PushBack func(h Func)

+ PushFront func(h Func)

+ type Config struct

+ LogDebug bool

+ LogPrefix string

+ type ConnType int

+ const ConnTypeTCP

+ const ConnTypeWS

+ type Connection struct

+ func NewConnection(id int64, conn net.Conn, conf Config, packerBuilder packet.PackerBuilder, ...) *Connection

+ func (r *Connection) Close() error

+ func (r *Connection) Conn() (net.Conn, ConnType)

+ func (r *Connection) DieChan() chan struct{}

+ func (r *Connection) ID() int64

+ func (r *Connection) LastMID() uint64

+ func (r *Connection) Send(header, payload interface{}) (err error)

+ func (r *Connection) SendBytes(data []byte) (err error)

+ func (r *Connection) Serve()

+ func (r *Connection) Session() *session.Session

+ func (r *Connection) SetLastMID(mid uint64)

+ func (r *Connection) SetStatus(s int32)

+ func (r *Connection) Status() int32

+ type Func func(c *Connection, v interface{}) error

+ type Group struct

+ func NewGroup(name string) *Group

+ func (g *Group) Add(c *Connection) error

+ func (g *Group) Close() error

+ func (g *Group) Contains(uid string) bool

+ func (g *Group) Count() int

+ func (g *Group) Leave(c *Connection) error

+ func (g *Group) LeaveAll() error

+ func (g *Group) LeaveByUID(uid string) error

+ func (g *Group) Member(uid string) (*Connection, bool)

+ func (g *Group) MemberBySID(id int64) (*Connection, bool)

+ func (g *Group) Members() []*Connection

+ func (g *Group) PeekMembers(fn func(sId int64, c *Connection) bool)

+ type Manager struct

+ func NewManager() *Manager

+ func (m *Manager) FindConn(id int64) (*Connection, bool)

+ func (m *Manager) FindConnByUID(uid string) (*Connection, bool)

+ func (m *Manager) FindGroup(name string) (*Group, bool)

+ func (m *Manager) NewGroup(name string) *Group

+ func (m *Manager) PeekConn(fn func(id int64, c *Connection) bool)

+ func (m *Manager) Remove(c *Connection) error

+ func (m *Manager) RemoveFromGroup(groupName string, c *Connection) error

+ func (m *Manager) Store(groupName string, c *Connection) error

+ type PendingMessage struct

+ type Pipeline interface

+ Inbound func() Channel

+ Outbound func() Channel

+ func NewPipeline() Pipeline

+ type WSConn struct

+ func NewWSConn(conn *websocket.Conn) *WSConn

+ func (c *WSConn) Read(b []byte) (int, error)

+ func (c *WSConn) SetDeadline(t time.Time) error

+ func (c *WSConn) Write(b []byte) (int, error)