Documentation
¶
Index ¶
- Variables
- func Serial(mainPort string, peerPort []string, heartbeatInterval int64)
- type SerialHeartBeatManage
- func (s *SerialHeartBeatManage) Marshal(d interface{}) (bytes []byte, err error)
- func (s *SerialHeartBeatManage) OnConnected(id int64, ncs string)
- func (s *SerialHeartBeatManage) OnConnectionLost(id int64, reason error)
- func (s *SerialHeartBeatManage) OnMessage(id int64, data interface{}, writer delegate.ResponseWriter)
- func (s *SerialHeartBeatManage) Run()
- func (s *SerialHeartBeatManage) Unmarshal(bytes []byte) (d interface{}, index int, err error)
- func (s *SerialHeartBeatManage) UnmarshalContinueFlag(unmarshalErr error) bool
Constants ¶
This section is empty.
Variables ¶
Functions ¶
Types ¶
type SerialHeartBeatManage ¶
type SerialHeartBeatManage struct {
// contains filtered or unexported fields
}
func InitSerialHeartManage ¶
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
Click to show internal directories.
Click to hide internal directories.