Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WriteMessage ¶
func WriteMessage(sink *comm.ZeroCopySink, msg Message) error
Types ¶
type Addr ¶
func (*Addr) Deserialization ¶
func (this *Addr) Deserialization(source *common.ZeroCopySource) error
func (Addr) Serialization ¶
func (this Addr) Serialization(sink *common.ZeroCopySink) error
Serialize message payload
type AddrReq ¶
type AddrReq struct{}
func (*AddrReq) Deserialization ¶
func (this *AddrReq) Deserialization(source *common.ZeroCopySource) error
Deserialize message payload
func (AddrReq) Serialization ¶
func (this AddrReq) Serialization(sink *common.ZeroCopySink) error
Serialize message payload
type DataReq ¶
type DataReq struct {
DataType common.InventoryType
Hash common.Uint256
}
func (*DataReq) Deserialization ¶
func (this *DataReq) Deserialization(source *common.ZeroCopySource) error
Deserialize message payload
func (DataReq) Serialization ¶
func (this DataReq) Serialization(sink *common.ZeroCopySink) error
Serialize message payload
type Disconnected ¶
type Disconnected struct{}
func (Disconnected) CmdType ¶
func (this Disconnected) CmdType() string
func (*Disconnected) Deserialization ¶
func (this *Disconnected) Deserialization(source *comm.ZeroCopySource) error
Deserialize message payload
func (Disconnected) Serialization ¶
func (this Disconnected) Serialization(sink *comm.ZeroCopySink) error
Serialize message payload
type Message ¶
type Message interface {
Serialization(sink *comm.ZeroCopySink) error
Deserialization(source *comm.ZeroCopySource) error
CmdType() string
}
func MakeEmptyMessage ¶
type MsgPayload ¶
type MsgPayload struct {
Id uint64 //peer ID
Addr string //link address
PayloadSize uint32 //payload size
Payload Message //msg payload
}
MsgPayload in link channel
type NotFound ¶
func (*NotFound) Deserialization ¶
func (this *NotFound) Deserialization(source *common.ZeroCopySource) error
Deserialize message payload
func (NotFound) Serialization ¶
func (this NotFound) Serialization(sink *common.ZeroCopySink) error
Serialize message payload
type Ping ¶
type Ping struct {
Height uint64
}
func (*Ping) Deserialization ¶
func (this *Ping) Deserialization(source *comm.ZeroCopySource) error
Deserialize message payload
func (Ping) Serialization ¶
func (this Ping) Serialization(sink *comm.ZeroCopySink) error
Serialize message payload
type Pong ¶
type Pong struct {
Height uint64
}
func (*Pong) Deserialization ¶
func (this *Pong) Deserialization(source *comm.ZeroCopySource) error
Deserialize message payload
func (Pong) Serialization ¶
func (this Pong) Serialization(sink *comm.ZeroCopySink) error
Serialize message payload
type VerACK ¶
type VerACK struct {
IsConsensus bool
}
func (*VerACK) Deserialization ¶
func (this *VerACK) Deserialization(source *comm.ZeroCopySource) error
Deserialize message payload
func (*VerACK) Serialization ¶
func (this *VerACK) Serialization(sink *comm.ZeroCopySink) error
Serialize message payload
type Version ¶
type Version struct {
P VersionPayload
}
func (*Version) Deserialization ¶
func (this *Version) Deserialization(source *comm.ZeroCopySource) error
Deserialize message payload
func (*Version) Serialization ¶
func (this *Version) Serialization(sink *comm.ZeroCopySink) error
Serialize message payload
Click to show internal directories.
Click to hide internal directories.