Versions in this module Expand all Collapse all v1 v1.1.0 Mar 19, 2024 Changes in this version + const PacketIdentifierBroadcastMessage + const PacketIdentifierMessage + const PacketIdentifierSyncStatusMsg + const PacketIdentifierTimeSyncMsg + type BroadcastMessage struct + Data []byte + ID []byte + func NewBroadcastMessage() BroadcastMessage + func (x *BroadcastMessage) PacketIdentifier() PacketIdentifier + func (x *BroadcastMessage) Read(viewer *BroadcastMessageViewer, reader *karmem.Reader) + func (x *BroadcastMessage) ReadAsRoot(reader *karmem.Reader) + func (x *BroadcastMessage) Reset() + func (x *BroadcastMessage) Write(writer *karmem.Writer, start uint) (offset uint, err error) + func (x *BroadcastMessage) WriteAsRoot(writer *karmem.Writer) (offset uint, err error) + type BroadcastMessageViewer struct + func NewBroadcastMessageViewer(reader *karmem.Reader, offset uint32) (v *BroadcastMessageViewer) + func (x *BroadcastMessageViewer) Data(reader *karmem.Reader) (v []byte) + func (x *BroadcastMessageViewer) ID(reader *karmem.Reader) (v []byte) + type Message struct + Code StatusCode + Payload []byte + ReceiveAt int64 + Size uint32 + func NewMessage() Message + func (x *Message) PacketIdentifier() PacketIdentifier + func (x *Message) Read(viewer *MessageViewer, reader *karmem.Reader) + func (x *Message) ReadAsRoot(reader *karmem.Reader) + func (x *Message) Reset() + func (x *Message) Write(writer *karmem.Writer, start uint) (offset uint, err error) + func (x *Message) WriteAsRoot(writer *karmem.Writer) (offset uint, err error) + type MessageViewer struct + func NewMessageViewer(reader *karmem.Reader, offset uint32) (v *MessageViewer) + func (x *MessageViewer) Code() (v StatusCode) + func (x *MessageViewer) Payload(reader *karmem.Reader) (v []byte) + func (x *MessageViewer) ReceiveAt() (v int64) + func (x *MessageViewer) Size() (v uint32) + type PacketIdentifier uint64 + type Peer struct + func NewPeer(id peer.ID, s *network.Stream, msgQueue chan *Message) (*Peer, error) + func (p *Peer) Id() peer.ID + func (p *Peer) Run() + func (p *Peer) Send(msgCode StatusCode, payload []byte) + func (p *Peer) Stopped() bool + type StatusCode uint8 + const StatusCodeBlockBodiesMsg + const StatusCodeBlockHeadersMsg + const StatusCodeBufferedBlocksMsg + const StatusCodeGetBlockBodiesMsg + const StatusCodeGetBlockHeadersMsg + const StatusCodeGetBufferedBlocksMsg + const StatusCodeGetNodeDataMsg + const StatusCodeGetReceiptsMsg + const StatusCodeNewBlockHashesMsg + const StatusCodeNewBlockMsg + const StatusCodeNewPooledTransactionHashesMsg + const StatusCodeNodeDataMsg + const StatusCodePingMsg + const StatusCodePongMsg + const StatusCodePooledTransactionsMsg + const StatusCodeReceiptsMsg + const StatusCodeStatusMsg + const StatusCodeSyncBlocksMsg + const StatusCodeSyncGetBlocksMsg + const StatusCodeSyncStatusMsg + const StatusCodeSyncStatusReq + const StatusCodeTimeSyncReq + const StatusCodeTimeSyncRsp + const StatusCodeTransactionsMsg + type SyncStatusMsg struct + BufferedEndHeight int64 + BufferedStartHeight int64 + LatestHash [32]byte + LatestHeight int64 + func NewSyncStatusMsg() SyncStatusMsg + func (x *SyncStatusMsg) PacketIdentifier() PacketIdentifier + func (x *SyncStatusMsg) Read(viewer *SyncStatusMsgViewer, reader *karmem.Reader) + func (x *SyncStatusMsg) ReadAsRoot(reader *karmem.Reader) + func (x *SyncStatusMsg) Reset() + func (x *SyncStatusMsg) Write(writer *karmem.Writer, start uint) (offset uint, err error) + func (x *SyncStatusMsg) WriteAsRoot(writer *karmem.Writer) (offset uint, err error) + type SyncStatusMsgViewer struct + func NewSyncStatusMsgViewer(reader *karmem.Reader, offset uint32) (v *SyncStatusMsgViewer) + func (x *SyncStatusMsgViewer) BufferedEndHeight() (v int64) + func (x *SyncStatusMsgViewer) BufferedStartHeight() (v int64) + func (x *SyncStatusMsgViewer) LatestHash() (v []byte) + func (x *SyncStatusMsgViewer) LatestHeight() (v int64) + type TimeSyncMsg struct + Code int8 + RecReqTime int64 + RecRspTime int64 + ReqTime int64 + RspTime int64 + func NewTimeSyncMsg() TimeSyncMsg + func (x *TimeSyncMsg) PacketIdentifier() PacketIdentifier + func (x *TimeSyncMsg) Read(viewer *TimeSyncMsgViewer, reader *karmem.Reader) + func (x *TimeSyncMsg) ReadAsRoot(reader *karmem.Reader) + func (x *TimeSyncMsg) Reset() + func (x *TimeSyncMsg) Write(writer *karmem.Writer, start uint) (offset uint, err error) + func (x *TimeSyncMsg) WriteAsRoot(writer *karmem.Writer) (offset uint, err error) + type TimeSyncMsgViewer struct + func NewTimeSyncMsgViewer(reader *karmem.Reader, offset uint32) (v *TimeSyncMsgViewer) + func (x *TimeSyncMsgViewer) Code() (v int8) + func (x *TimeSyncMsgViewer) RecReqTime() (v int64) + func (x *TimeSyncMsgViewer) RecRspTime() (v int64) + func (x *TimeSyncMsgViewer) ReqTime() (v int64) + func (x *TimeSyncMsgViewer) RspTime() (v int64)