serialtest

package
v0.0.0-...-91c7ab2 Latest Latest
Warning

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

Go to latest
Published: Mar 27, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	SerialHeartBeatErrNotSessionContent     = errors.New("session info not found")
	SerialHeartBeatErrSessionContentInValid = errors.New("session discontented")
	SerialHeartBeatErrReadEmpty             = errors.New("serial read empty")
)

Functions

func Serial

func Serial(mainPort string, peerPort []string, heartbeatInterval int64)

Serial eg mainPort "dev/ttyS1" peerPort []string{"dev/ttyS2", "dev/ttyS3"}

Types

type SerialHeartBeatManage

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

func InitSerialHeartManage

func InitSerialHeartManage(ctx context.Context, mainPort string, peerPort []string, heartbeatInterval int64) (*SerialHeartBeatManage, error)

func (*SerialHeartBeatManage) Marshal

func (s *SerialHeartBeatManage) Marshal(d interface{}) (bytes []byte, err error)

func (*SerialHeartBeatManage) OnConnected

func (s *SerialHeartBeatManage) OnConnected(id int64, ncs string)

func (*SerialHeartBeatManage) OnConnectionLost

func (s *SerialHeartBeatManage) OnConnectionLost(id int64, reason error)

func (*SerialHeartBeatManage) OnMessage

func (s *SerialHeartBeatManage) OnMessage(id int64, data interface{}, writer delegate.ResponseWriter)

func (*SerialHeartBeatManage) Run

func (s *SerialHeartBeatManage) Run()

func (*SerialHeartBeatManage) Unmarshal

func (s *SerialHeartBeatManage) Unmarshal(bytes []byte) (d interface{}, index int, err error)

func (*SerialHeartBeatManage) UnmarshalContinueFlag

func (s *SerialHeartBeatManage) UnmarshalContinueFlag(unmarshalErr error) bool

Jump to

Keyboard shortcuts

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