msg

package
v0.4.2 Latest Latest
Warning

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

 Go to latest Published: Mar 5, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// MaxFilterLoadHashFuncs is the maximum number of hash functions to
	// load into the Bloom filter.
	MaxFilterLoadHashFuncs = 50

	// MaxFilterLoadFilterSize is the maximum size in bytes a filter may be.
	MaxFilterLoadFilterSize = 36000
)
View Source 
const MaxAddrPerMsg = 1000
View Source 
const MaxBlockLocatorsPerMsg = 500

MaxBlockLocatorsPerMsg is the maximum number of block locator hashes allowed per message.

View Source 
const (
	// MaxFilterAddDataSize is the maximum byte size of a data
	// element to add to the Bloom filter.  It is equal to the
	// maximum element size of a script.
	MaxFilterAddDataSize = 520
)
View Source 
const (
	// MaxInvPerMsg is the maximum number of inventory vectors that can be in a
	// single inv message.
	MaxInvPerMsg = 50000
)
View Source 
const (
	// MaxTxFilterLoadDataSize is the maximum size in bytes a filter may be.
	MaxTxFilterLoadDataSize = 50000
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Addr 

type Addr struct {
	AddrList []*p2p.NetAddress
}

func NewAddr 

func NewAddr(addresses []*p2p.NetAddress) *Addr

func (*Addr) CMD 

func (msg *Addr) CMD() string

func (*Addr) Deserialize 

func (msg *Addr) Deserialize(r io.Reader) error

func (*Addr) MaxLength 

func (msg *Addr) MaxLength() uint32

func (*Addr) Serialize 

func (msg *Addr) Serialize(w io.Writer) error

type Block 

type Block struct {
	common.Serializable
}

func NewBlock 

func NewBlock(block common.Serializable) *Block

func (*Block) CMD 

func (msg *Block) CMD() string

func (*Block) MaxLength 

func (msg *Block) MaxLength() uint32

type DAddr added in v0.3.2 

type DAddr struct {
	// The peer ID indicates who's address it is.
	PID [33]byte

	// Timestamp represents the time when this message created.
	Timestamp time.Time

	// Which peer ID is used to encode the address cipher.
	Encode [33]byte

	// The encrypted network address using the encode peer ID.
	Cipher []byte

	// Signature of the encode peer ID and cipher to proof the sender itself.
	Signature []byte
}

DAddr represents a DPOS peer address.

func (*DAddr) CMD added in v0.3.2 

func (a *DAddr) CMD() string

func (*DAddr) Data added in v0.3.2 

func (a *DAddr) Data() []byte

func (*DAddr) Deserialize added in v0.3.2 

func (a *DAddr) Deserialize(r io.Reader) error

func (*DAddr) Hash added in v0.3.2 

func (a *DAddr) Hash() common.Uint256

func (*DAddr) MaxLength added in v0.3.2 

func (a *DAddr) MaxLength() uint32

func (*DAddr) Serialize added in v0.3.2 

func (a *DAddr) Serialize(w io.Writer) error

type FilterAdd 

type FilterAdd struct {
	Data []byte
}

func (*FilterAdd) CMD 

func (msg *FilterAdd) CMD() string

func (*FilterAdd) Deserialize 

func (msg *FilterAdd) Deserialize(reader io.Reader) error

func (*FilterAdd) MaxLength 

func (msg *FilterAdd) MaxLength() uint32

func (*FilterAdd) Serialize 

func (msg *FilterAdd) Serialize(writer io.Writer) error

type FilterClear 

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

func (*FilterClear) CMD 

func (msg *FilterClear) CMD() string

func (*FilterClear) Deserialize 

func (msg *FilterClear) Deserialize(io.Reader) error

func (*FilterClear) MaxLength 

func (msg *FilterClear) MaxLength() uint32

func (*FilterClear) Serialize 

func (msg *FilterClear) Serialize(io.Writer) error

type FilterLoad 

type FilterLoad struct {
	Filter    []byte
	HashFuncs uint32
	Tweak     uint32
	Flags     uint8
}

func (*FilterLoad) CMD 

func (msg *FilterLoad) CMD() string

func (*FilterLoad) Deserialize 

func (msg *FilterLoad) Deserialize(r io.Reader) error

func (*FilterLoad) MaxLength 

func (msg *FilterLoad) MaxLength() uint32

func (*FilterLoad) Serialize 

func (msg *FilterLoad) Serialize(w io.Writer) error

type GetAddr 

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

func NewGetAddr 

func NewGetAddr() *GetAddr

func (*GetAddr) CMD 

func (msg *GetAddr) CMD() string

func (*GetAddr) Deserialize 

func (msg *GetAddr) Deserialize(io.Reader) error

func (*GetAddr) MaxLength 

func (msg *GetAddr) MaxLength() uint32

func (*GetAddr) Serialize 

func (msg *GetAddr) Serialize(io.Writer) error

type GetBlocks 

type GetBlocks struct {
	Locator  []*common.Uint256
	HashStop common.Uint256
}

func NewGetBlocks 

func NewGetBlocks(locator []*common.Uint256, hashStop common.Uint256) *GetBlocks

func (*GetBlocks) CMD 

func (msg *GetBlocks) CMD() string

func (*GetBlocks) Deserialize 

func (msg *GetBlocks) Deserialize(reader io.Reader) error

func (*GetBlocks) MaxLength 

func (msg *GetBlocks) MaxLength() uint32

func (*GetBlocks) Serialize 

func (msg *GetBlocks) Serialize(w io.Writer) error

type GetData 

type GetData struct {
	Inv
}

func NewGetData 

func NewGetData() *GetData

func (*GetData) CMD 

func (msg *GetData) CMD() string

type Inv 

type Inv struct {
	InvList []*InvVect
}

func NewInv 

func NewInv() *Inv

func NewInvSize 

func NewInvSize(size uint) *Inv

func (*Inv) AddInvVect 

func (msg *Inv) AddInvVect(iv *InvVect) error

AddInvVect adds an inventory vector to the message.

func (*Inv) CMD 

func (msg *Inv) CMD() string

func (*Inv) Deserialize 

func (msg *Inv) Deserialize(r io.Reader) error

func (*Inv) MaxLength 

func (msg *Inv) MaxLength() uint32

func (*Inv) Serialize 

func (msg *Inv) Serialize(w io.Writer) error

type InvType 

type InvType uint32
const (
	InvTypeError InvType = iota
	InvTypeTx
	InvTypeBlock
	InvTypeFilteredBlock
	InvTypeConfirmedBlock
	InvTypeAddress
)

func (InvType) String 

func (i InvType) String() string

type InvVect 

type InvVect struct {
	Type InvType
	Hash common.Uint256
}

func NewInvVect 

func NewInvVect(typ InvType, hash *common.Uint256) *InvVect

NewInvVect returns a new InvVect using the provided type and hash.

func (*InvVect) Deserialize 

func (vect *InvVect) Deserialize(r io.Reader) error

func (*InvVect) Serialize 

func (vect *InvVect) Serialize(w io.Writer) error

type MemPool 

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

func (*MemPool) CMD 

func (msg *MemPool) CMD() string

func (*MemPool) Deserialize 

func (msg *MemPool) Deserialize(io.Reader) error

func (*MemPool) MaxLength 

func (msg *MemPool) MaxLength() uint32

func (*MemPool) Serialize 

func (msg *MemPool) Serialize(io.Writer) error

type MerkleBlock 

type MerkleBlock struct {
	Header       common.Serializable
	Transactions uint32
	Hashes       []*common.Uint256
	Flags        []byte
}

func NewMerkleBlock 

func NewMerkleBlock(header common.Serializable) *MerkleBlock

func (*MerkleBlock) CMD 

func (msg *MerkleBlock) CMD() string

func (*MerkleBlock) Deserialize 

func (msg *MerkleBlock) Deserialize(r io.Reader) error

func (*MerkleBlock) MaxLength 

func (msg *MerkleBlock) MaxLength() uint32

func (*MerkleBlock) Serialize 

func (msg *MerkleBlock) Serialize(w io.Writer) error

type NotFound 

type NotFound struct {
	Inv
}

func NewNotFound 

func NewNotFound() *NotFound

func (*NotFound) CMD 

func (msg *NotFound) CMD() string

type Ping 

type Ping struct {
	Nonce uint64
}

func NewPing 

func NewPing(nonce uint64) *Ping

func (*Ping) CMD 

func (msg *Ping) CMD() string

func (*Ping) Deserialize 

func (msg *Ping) Deserialize(reader io.Reader) error

func (*Ping) MaxLength 

func (msg *Ping) MaxLength() uint32

func (*Ping) Serialize 

func (msg *Ping) Serialize(writer io.Writer) error

type Pong 

type Pong struct {
	Ping
}

func NewPong 

func NewPong(nonce uint64) *Pong

func (*Pong) CMD 

func (msg *Pong) CMD() string

type Reject 

type Reject struct {
	// Cmd is the command for the message which was rejected such as
	// as CmdBlock or CmdReject.  This can be obtained from the Command function
	// of a Message.
	Cmd string

	// RejectCode is a code indicating why the command was rejected.  It
	// is encoded as a uint8 on the wire.
	Code RejectCode

	// Reason is a human-readable string with specific details (over and
	// above the reject code) about why the command was rejected.
	Reason string

	// Hash identifies a specific block or transaction that was rejected
	// and therefore only applies the MsgBlock and MsgReject messages.
	Hash common.Uint256
}

func NewReject 

func NewReject(cmd string, code RejectCode, reason string) *Reject

func (*Reject) CMD 

func (msg *Reject) CMD() string

func (*Reject) Deserialize 

func (msg *Reject) Deserialize(r io.Reader) (err error)

func (*Reject) MaxLength 

func (msg *Reject) MaxLength() uint32

func (*Reject) Serialize 

func (msg *Reject) Serialize(w io.Writer) error

type RejectCode 

type RejectCode uint8

RejectCode represents a numeric value by which a remote peer indicates why a message was rejected. 

const (
	RejectMalformed       RejectCode = 0x01
	RejectInvalid         RejectCode = 0x10
	RejectObsolete        RejectCode = 0x11
	RejectDuplicate       RejectCode = 0x12
	RejectNonstandard     RejectCode = 0x40
	RejectDust            RejectCode = 0x41
	RejectInsufficientFee RejectCode = 0x42
	RejectCheckpoint      RejectCode = 0x43
)

These constants define the various supported reject codes.

func (RejectCode) String 

func (code RejectCode) String() string

String returns the RejectCode in human-readable form.

type Tx 

type Tx struct {
	common.Serializable
}

func NewTx 

func NewTx(tx common.Serializable) *Tx

func (*Tx) CMD 

func (msg *Tx) CMD() string

func (*Tx) MaxLength 

func (msg *Tx) MaxLength() uint32

type TxFilterLoad 

type TxFilterLoad struct {
	Type uint8
	Data []byte
}

TxFilterLoad is a message to load a transaction filter, it can be a bloom filter or other transaction filters.

func (*TxFilterLoad) CMD 

func (msg *TxFilterLoad) CMD() string

func (*TxFilterLoad) Deserialize 

func (msg *TxFilterLoad) Deserialize(r io.Reader) error

func (*TxFilterLoad) MaxLength 

func (msg *TxFilterLoad) MaxLength() uint32

func (*TxFilterLoad) Serialize 

func (msg *TxFilterLoad) Serialize(w io.Writer) error

type VerAck 

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

func NewVerAck 

func NewVerAck() *VerAck

func (*VerAck) CMD 

func (msg *VerAck) CMD() string

func (*VerAck) Deserialize 

func (msg *VerAck) Deserialize(io.Reader) error

func (*VerAck) MaxLength 

func (msg *VerAck) MaxLength() uint32

func (*VerAck) Serialize 

func (msg *VerAck) Serialize(io.Writer) error

type Version 

type Version struct {
	Version   uint32
	Services  uint64
	Timestamp time.Time
	Port      uint16
	Nonce     uint64
	Height    uint64
	Relay     bool
}

func NewVersion 

func NewVersion(pver uint32, port uint16, services, nonce, height uint64,
	disableRelayTx bool) *Version

func (*Version) CMD 

func (msg *Version) CMD() string

func (*Version) Deserialize 

func (msg *Version) Deserialize(r io.Reader) error

func (*Version) MaxLength 

func (msg *Version) MaxLength() uint32

func (*Version) Serialize 

func (msg *Version) Serialize(w io.Writer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.