Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

wire

package

Go to main page

Versions in this module

v1

v1.6.1

Mar 10, 2021

v0

v0.2.7

Jun 9, 2021

v0.2.6

Jun 1, 2021

v0.2.5

May 7, 2021

v0.2.4

May 7, 2021

v0.2.3

May 7, 2021

v0.2.2

Apr 29, 2021

v0.2.1

Apr 9, 2021

v0.2.0

Apr 9, 2021

Changes in this version

type TxIn

+ Age int32

v0.1.6

Jan 27, 2021

Changes in this version

+ const CmdEadAddresses

+ const CmdEadIp

+ const TxMarkNone

+ const TxMarkShardSwap

+ const TxVerEADAction

+ const TxVerTimeLockAllowance

+ type EADAddress struct

+ ExpiresAt time.Time

+ IP net.IP

+ Port uint16

+ Shards []uint32

+ TxHash *chainhash.Hash

+ TxOutIndex int

+ func (msg *EADAddress) AddShard(shardID uint32) EADAddress

+ func (msg *EADAddress) BtcDecode(r io.Reader, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *EADAddress) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *EADAddress) Command() string

+ func (msg *EADAddress) FilterOut(ip net.IP, shardID uint32) (*EADAddress, bool)

+ func (msg *EADAddress) HasShard(shards ...uint32) (allPresent bool, hasOneOf bool)

+ func (msg *EADAddress) MaxPayloadLength(uint32) uint32

+ type EADAddresses struct

+ ID uint64

+ IPs []EADAddress

+ OwnerPubKey []byte

+ func (msg *EADAddresses) AddAddress(ip net.IP, port uint16, expiresAt int64, shardID uint32, hash *chainhash.Hash, ...) *EADAddresses

+ func (msg *EADAddresses) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *EADAddresses) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *EADAddresses) Command() string

+ func (msg *EADAddresses) MaxPayloadLength(uint32) uint32

type MsgTx

+ func (msg *MsgTx) CleanVersion() int32

+ func (msg *MsgTx) Mark() int32

+ func (msg *MsgTx) SetMark(mark int32)

+ func (msg *MsgTx) SwapTx() bool

v0.1.3

Oct 23, 2020

Changes in this version

+ const BIP0031Version

+ const BIP0035Version

+ const BIP0037Version

+ const BIP0111Version

+ const BaseEncoding

+ const BlockHeaderLen

+ const CFCheckptInterval

+ const CmdAddr

+ const CmdAlert

+ const CmdBlock

+ const CmdCFCheckpt

+ const CmdCFHeaders

+ const CmdCFilter

+ const CmdFeeFilter

+ const CmdFilterAdd

+ const CmdFilterClear

+ const CmdFilterLoad

+ const CmdGetAddr

+ const CmdGetBlocks

+ const CmdGetCFCheckpt

+ const CmdGetCFHeaders

+ const CmdGetCFilters

+ const CmdGetData

+ const CmdGetHeaders

+ const CmdHeaders

+ const CmdInv

+ const CmdMemPool

+ const CmdMerkleBlock

+ const CmdNotFound

+ const CmdPing

+ const CmdPong

+ const CmdPortRedirect

+ const CmdReject

+ const CmdSendHeaders

+ const CmdTx

+ const CmdVerAck

+ const CmdVersion

+ const CommandSize

+ const DefaultUserAgent

+ const ExpansionApprove

+ const ExpansionExec

+ const FeeFilterVersion

+ const MaxAddrPerMsg

+ const MaxBeaconBlockHeaderPayload

+ const MaxBlockHeadersPerMsg

+ const MaxBlockLocatorsPerMsg

+ const MaxBlockPayload

+ const MaxBlocksPerMsg

+ const MaxCFHeaderPayload

+ const MaxCFHeadersPerMsg

+ const MaxCFilterDataSize

+ const MaxFilterAddDataSize

+ const MaxFilterLoadFilterSize

+ const MaxFilterLoadHashFuncs

+ const MaxGetCFiltersReqRange

+ const MaxMessagePayload

+ const MaxPrevOutIndex

+ const MaxShardBlockHeaderPayload

+ const MaxTxInSequenceNum

+ const MaxUserAgentLen

+ const MessageHeaderSize

+ const MinTxOutPayload

+ const MultipleAddressVersion

+ const NetAddressTimeVersion

+ const ProtocolVersion

+ const RejectVersion

+ const SendHeadersVersion

+ const SequenceLockTimeDisabled

+ const SequenceLockTimeGranularity

+ const SequenceLockTimeIsSeconds

+ const SequenceLockTimeMask

+ const ShardBlockHeaderLen

+ const TxVerRegular

+ const TxVerShardsSwap

+ const TxVerTimeLock

+ const TxVersion

+ const WitnessEncoding

+ var ErrInsaneCFHeaderCount = errors.New("refusing to decode unreasonable number of filter headers")

+ var LatestEncoding = WitnessEncoding

+ func ReadBeaconBlockHeader(r io.Reader, bh *BeaconHeader) error

+ func ReadShardBlockHeader(r io.Reader, bh *ShardHeader) error

+ func WriteBeaconBlockHeader(w io.Writer, bh *BeaconHeader) error

+ func WriteMessage(w io.Writer, msg Message, pver uint32, btcnet types.BitcoinNet) error

+ func WriteMessageN(w io.Writer, msg Message, pver uint32, btcnet types.BitcoinNet) (int, error)

+ func WriteMessageWithEncodingN(w io.Writer, msg Message, pver uint32, btcnet types.BitcoinNet, ...) (int, error)

+ func WriteShardBlockHeader(w io.Writer, bh *ShardHeader) error

+ func WriteShardBlockHeaderNoBC(w io.Writer, bh *ShardHeader) error

+ func WriteTxOut(w io.Writer, pver uint32, version int32, to *TxOut) error

+ type Alert struct

+ Cancel int32

+ Comment string

+ Expiration int64

+ ID int32

+ MaxVer int32

+ MinVer int32

+ Priority int32

+ RelayUntil int64

+ Reserved string

+ SetCancel []int32

+ SetSubVer []string

+ StatusBar string

+ Version int32

+ func NewAlert(version int32, relayUntil int64, expiration int64, id int32, cancel int32, ...) *Alert

+ func NewAlertFromPayload(serializedPayload []byte, pver uint32) (*Alert, error)

+ func (alert *Alert) Deserialize(r io.Reader, pver uint32) error

+ func (alert *Alert) Serialize(w io.Writer, pver uint32) error

+ type BVersion int32

+ func NewBVersion(version int32) BVersion

+ func (bv BVersion) ExpansionApproved() bool

+ func (bv BVersion) ExpansionMade() bool

+ func (bv BVersion) SetExpansionApproved() BVersion

+ func (bv BVersion) SetExpansionMade() BVersion

+ func (bv BVersion) UnsetExpansionApproved() BVersion

+ func (bv BVersion) UnsetExpansionMade() BVersion

+ func (bv BVersion) Version() int32

+ type BeaconHeader struct

+ func EmptyBeaconHeader() *BeaconHeader

+ func NewBeaconBlockHeader(version BVersion, prevHash, merkleRootHash chainhash.Hash, ...) *BeaconHeader

+ func (h *BeaconHeader) BeaconHeader() *BeaconHeader

+ func (h *BeaconHeader) Bits() uint32

+ func (h *BeaconHeader) BlockData() []byte

+ func (h *BeaconHeader) BlockHash() chainhash.Hash

+ func (h *BeaconHeader) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (h *BeaconHeader) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (h *BeaconHeader) Copy() BlockHeader

+ func (h *BeaconHeader) MaxLength() int

+ func (h *BeaconHeader) MergeMiningRoot() chainhash.Hash

+ func (h *BeaconHeader) MergedMiningTree() []byte

+ func (h *BeaconHeader) MergedMiningTreeCodingProof() (hashes, coding []byte, codingLengthBits uint32)

+ func (h *BeaconHeader) MerkleRoot() chainhash.Hash

+ func (h *BeaconHeader) Nonce() uint32

+ func (h *BeaconHeader) PrevBlock() chainhash.Hash

+ func (h *BeaconHeader) Read(r io.Reader) error

+ func (h *BeaconHeader) Serialize(w io.Writer) error

+ func (h *BeaconHeader) SetBeaconHeader(bh *BeaconHeader)

+ func (h *BeaconHeader) SetBits(bits uint32)

+ func (h *BeaconHeader) SetMergeMiningRoot(value chainhash.Hash)

+ func (h *BeaconHeader) SetMergedMiningTree(treeData []byte)

+ func (h *BeaconHeader) SetMergedMiningTreeCodingProof(hashes, coding []byte, codingLengthBits uint32)

+ func (h *BeaconHeader) SetMerkleRoot(hash chainhash.Hash)

+ func (h *BeaconHeader) SetNonce(n uint32)

+ func (h *BeaconHeader) SetPrevBlock(prevBlock chainhash.Hash)

+ func (h *BeaconHeader) SetShards(value uint32)

+ func (h *BeaconHeader) SetTimestamp(t time.Time)

+ func (h *BeaconHeader) SetVersion(v BVersion)

+ func (h *BeaconHeader) Shards() uint32

+ func (h *BeaconHeader) Timestamp() time.Time

+ func (h *BeaconHeader) Version() BVersion

+ func (h *BeaconHeader) Write(w io.Writer) error

+ type BeaconHeaderConstructor struct

+ func (b BeaconHeaderConstructor) BlockHeaderOverhead() int

+ func (b BeaconHeaderConstructor) EmptyHeader() BlockHeader

+ func (b BeaconHeaderConstructor) IsBeacon() bool

+ func (b BeaconHeaderConstructor) MaxBlockHeaderPayload() int

+ func (b BeaconHeaderConstructor) ShardID() uint32

+ type BlockHeader interface

+ BeaconHeader func() *BeaconHeader

+ Bits func() uint32

+ BlockData func() []byte

+ BlockHash func() chainhash.Hash

+ BtcEncode func(w io.Writer, prev uint32, enc encoder.MessageEncoding) error

+ Copy func() BlockHeader

+ MaxLength func() int

+ MerkleRoot func() chainhash.Hash

+ Nonce func() uint32

+ PrevBlock func() chainhash.Hash

+ Read func(r io.Reader) error

+ SetBeaconHeader func(bh *BeaconHeader)

+ SetBits func(uint32)

+ SetMerkleRoot func(chainhash.Hash)

+ SetNonce func(uint32)

+ SetPrevBlock func(prevBlock chainhash.Hash)

+ SetTimestamp func(time.Time)

+ Timestamp func() time.Time

+ Version func() BVersion

+ Write func(r io.Writer) error

+ type FilterType uint8

+ const GCSFilterRegular

+ type HeaderConstructor interface

+ BlockHeaderOverhead func() int

+ EmptyHeader func() BlockHeader

+ IsBeacon func() bool

+ MaxBlockHeaderPayload func() int

+ ShardID func() uint32

+ type Message interface

+ BtcDecode func(io.Reader, uint32, encoder.MessageEncoding) error

+ BtcEncode func(io.Writer, uint32, encoder.MessageEncoding) error

+ Command func() string

+ MaxPayloadLength func(uint32) uint32

+ func ReadMessage(chain HeaderConstructor, r io.Reader, pver uint32, btcnet types.BitcoinNet) (Message, []byte, error)

+ func ReadMessageN(chain HeaderConstructor, r io.Reader, pver uint32, btcnet types.BitcoinNet) (int, Message, []byte, error)

+ func ReadMessageWithEncodingN(chain HeaderConstructor, r io.Reader, pver uint32, btcnet types.BitcoinNet, ...) (int, Message, []byte, error)

+ type MessageError struct

+ Description string

+ Func string

+ func (e *MessageError) Error() string

+ type MsgAddr struct

+ AddrList []*NetAddress

+ Shards []*ShardAddress

+ func NewMsgAddr() *MsgAddr

+ func (msg *MsgAddr) AddAddress(na *NetAddress) error

+ func (msg *MsgAddr) AddAddresses(netAddrs ...*NetAddress) error

+ func (msg *MsgAddr) AddShardAddress(shardId uint32, na *NetAddress) error

+ func (msg *MsgAddr) AddShards(netAddrs ...*ShardAddress) error

+ func (msg *MsgAddr) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgAddr) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgAddr) ClearAddresses()

+ func (msg *MsgAddr) Command() string

+ func (msg *MsgAddr) MaxPayloadLength(pver uint32) uint32

+ type MsgAlert struct

+ Payload *Alert

+ SerializedPayload []byte

+ Signature []byte

+ func NewMsgAlert(serializedPayload []byte, signature []byte) *MsgAlert

+ func (msg *MsgAlert) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgAlert) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgAlert) Command() string

+ func (msg *MsgAlert) MaxPayloadLength(pver uint32) uint32

+ type MsgBlock struct

+ Header BlockHeader

+ ShardBlock bool

+ Transactions []*MsgTx

+ func EmptyBeaconBlock() MsgBlock

+ func EmptyShardBlock() MsgBlock

+ func NewMsgBlock(blockHeader BlockHeader) *MsgBlock

+ func (msg *MsgBlock) AddTransaction(tx *MsgTx) error

+ func (msg *MsgBlock) BlockHash() chainhash.Hash

+ func (msg *MsgBlock) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) (err error)

+ func (msg *MsgBlock) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgBlock) ClearTransactions()

+ func (msg *MsgBlock) Command() string

+ func (msg *MsgBlock) Copy() *MsgBlock

+ func (msg *MsgBlock) Deserialize(r io.Reader) error

+ func (msg *MsgBlock) DeserializeNoWitness(r io.Reader) error

+ func (msg *MsgBlock) DeserializeTxLoc(r *bytes.Buffer) ([]TxLoc, error)

+ func (msg *MsgBlock) MaxPayloadLength(pver uint32) uint32

+ func (msg *MsgBlock) Serialize(w io.Writer) error

+ func (msg *MsgBlock) SerializeNoWitness(w io.Writer) error

+ func (msg *MsgBlock) SerializeSize() int

+ func (msg *MsgBlock) SerializeSizeStripped() int

+ func (msg *MsgBlock) TxHashes() ([]chainhash.Hash, error)

+ type MsgCFCheckpt struct

+ FilterHeaders []*chainhash.Hash

+ FilterType FilterType

+ StopHash chainhash.Hash

+ func NewMsgCFCheckpt(filterType FilterType, stopHash *chainhash.Hash, headersCount int) *MsgCFCheckpt

+ func (msg *MsgCFCheckpt) AddCFHeader(header *chainhash.Hash) error

+ func (msg *MsgCFCheckpt) BtcDecode(r io.Reader, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgCFCheckpt) BtcEncode(w io.Writer, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgCFCheckpt) Command() string

+ func (msg *MsgCFCheckpt) Deserialize(r io.Reader) error

+ func (msg *MsgCFCheckpt) MaxPayloadLength(pver uint32) uint32

+ type MsgCFHeaders struct

+ FilterHashes []*chainhash.Hash

+ FilterType FilterType

+ PrevFilterHeader chainhash.Hash

+ StopHash chainhash.Hash

+ func NewMsgCFHeaders() *MsgCFHeaders

+ func (msg *MsgCFHeaders) AddCFHash(hash *chainhash.Hash) error

+ func (msg *MsgCFHeaders) BtcDecode(r io.Reader, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgCFHeaders) BtcEncode(w io.Writer, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgCFHeaders) Command() string

+ func (msg *MsgCFHeaders) Deserialize(r io.Reader) error

+ func (msg *MsgCFHeaders) MaxPayloadLength(pver uint32) uint32

+ type MsgCFilter struct

+ BlockHash chainhash.Hash

+ Data []byte

+ FilterType FilterType

+ func NewMsgCFilter(filterType FilterType, blockHash *chainhash.Hash, data []byte) *MsgCFilter

+ func (msg *MsgCFilter) BtcDecode(r io.Reader, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgCFilter) BtcEncode(w io.Writer, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgCFilter) Command() string

+ func (msg *MsgCFilter) Deserialize(r io.Reader) error

+ func (msg *MsgCFilter) MaxPayloadLength(pver uint32) uint32

+ type MsgFeeFilter struct

+ MinFee int64

+ func NewMsgFeeFilter(minfee int64) *MsgFeeFilter

+ func (msg *MsgFeeFilter) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgFeeFilter) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgFeeFilter) Command() string

+ func (msg *MsgFeeFilter) MaxPayloadLength(pver uint32) uint32

+ type MsgFilterAdd struct

+ Data []byte

+ func NewMsgFilterAdd(data []byte) *MsgFilterAdd

+ func (msg *MsgFilterAdd) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgFilterAdd) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgFilterAdd) Command() string

+ func (msg *MsgFilterAdd) MaxPayloadLength(pver uint32) uint32

+ type MsgFilterClear struct

+ func NewMsgFilterClear() *MsgFilterClear

+ func (msg *MsgFilterClear) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgFilterClear) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgFilterClear) Command() string

+ func (msg *MsgFilterClear) MaxPayloadLength(pver uint32) uint32

+ type MsgFilterLoad struct

+ Filter []byte

+ Flags types.BloomUpdateType

+ HashFuncs uint32

+ Tweak uint32

+ func NewMsgFilterLoad(filter []byte, hashFuncs uint32, tweak uint32, flags types.BloomUpdateType) *MsgFilterLoad

+ func (msg *MsgFilterLoad) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgFilterLoad) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgFilterLoad) Command() string

+ func (msg *MsgFilterLoad) MaxPayloadLength(pver uint32) uint32

+ type MsgGetAddr struct

+ ShardID uint32

+ func NewMsgGetAddr() *MsgGetAddr

+ func (msg *MsgGetAddr) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgGetAddr) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgGetAddr) Command() string

+ func (msg *MsgGetAddr) MaxPayloadLength(pver uint32) uint32

+ type MsgGetBlocks struct

+ BlockLocatorHashes []*chainhash.Hash

+ HashStop chainhash.Hash

+ ProtocolVersion uint32

+ func NewMsgGetBlocks(hashStop *chainhash.Hash) *MsgGetBlocks

+ func (msg *MsgGetBlocks) AddBlockLocatorHash(hash *chainhash.Hash) error

+ func (msg *MsgGetBlocks) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgGetBlocks) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgGetBlocks) Command() string

+ func (msg *MsgGetBlocks) MaxPayloadLength(pver uint32) uint32

+ type MsgGetCFCheckpt struct

+ FilterType FilterType

+ StopHash chainhash.Hash

+ func NewMsgGetCFCheckpt(filterType FilterType, stopHash *chainhash.Hash) *MsgGetCFCheckpt

+ func (msg *MsgGetCFCheckpt) BtcDecode(r io.Reader, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgGetCFCheckpt) BtcEncode(w io.Writer, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgGetCFCheckpt) Command() string

+ func (msg *MsgGetCFCheckpt) MaxPayloadLength(pver uint32) uint32

+ type MsgGetCFHeaders struct

+ FilterType FilterType

+ StartHeight uint32

+ StopHash chainhash.Hash

+ func NewMsgGetCFHeaders(filterType FilterType, startHeight uint32, stopHash *chainhash.Hash) *MsgGetCFHeaders

+ func (msg *MsgGetCFHeaders) BtcDecode(r io.Reader, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgGetCFHeaders) BtcEncode(w io.Writer, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgGetCFHeaders) Command() string

+ func (msg *MsgGetCFHeaders) MaxPayloadLength(pver uint32) uint32

+ type MsgGetCFilters struct

+ FilterType FilterType

+ StartHeight uint32

+ StopHash chainhash.Hash

+ func NewMsgGetCFilters(filterType FilterType, startHeight uint32, stopHash *chainhash.Hash) *MsgGetCFilters

+ func (msg *MsgGetCFilters) BtcDecode(r io.Reader, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgGetCFilters) BtcEncode(w io.Writer, pver uint32, _ encoder.MessageEncoding) error

+ func (msg *MsgGetCFilters) Command() string

+ func (msg *MsgGetCFilters) MaxPayloadLength(pver uint32) uint32

+ type MsgGetData struct

+ InvList []*types.InvVect

+ func NewMsgGetData() *MsgGetData

+ func NewMsgGetDataSizeHint(sizeHint uint) *MsgGetData

+ func (msg *MsgGetData) AddInvVect(iv *types.InvVect) error

+ func (msg *MsgGetData) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgGetData) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgGetData) Command() string

+ func (msg *MsgGetData) MaxPayloadLength(pver uint32) uint32

+ type MsgGetHeaders struct

+ BlockLocatorHashes []*chainhash.Hash

+ HashStop chainhash.Hash

+ ProtocolVersion uint32

+ func NewMsgGetHeaders() *MsgGetHeaders

+ func (msg *MsgGetHeaders) AddBlockLocatorHash(hash *chainhash.Hash) error

+ func (msg *MsgGetHeaders) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgGetHeaders) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgGetHeaders) Command() string

+ func (msg *MsgGetHeaders) MaxPayloadLength(pver uint32) uint32

+ type MsgHeaders struct

+ Chain HeaderConstructor

+ Headers []BlockHeader

+ func NewMsgHeaders() *MsgHeaders

+ func (msg *MsgHeaders) AddBlockHeader(bh BlockHeader) error

+ func (msg *MsgHeaders) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgHeaders) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgHeaders) Command() string

+ func (msg *MsgHeaders) MaxPayloadLength(pver uint32) uint32

+ type MsgInv struct

+ InvList []*types.InvVect

+ func NewMsgInv() *MsgInv

+ func NewMsgInvSizeHint(sizeHint uint) *MsgInv

+ func (msg *MsgInv) AddInvVect(iv *types.InvVect) error

+ func (msg *MsgInv) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgInv) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgInv) Command() string

+ func (msg *MsgInv) MaxPayloadLength(pver uint32) uint32

+ type MsgMemPool struct

+ func NewMsgMemPool() *MsgMemPool

+ func (msg *MsgMemPool) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgMemPool) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgMemPool) Command() string

+ func (msg *MsgMemPool) MaxPayloadLength(pver uint32) uint32

+ type MsgMerkleBlock struct

+ Flags []byte

+ Hashes []*chainhash.Hash

+ Header BlockHeader

+ Transactions uint32

+ func NewMsgMerkleBlock(bh BlockHeader) *MsgMerkleBlock

+ func (msg *MsgMerkleBlock) AddTxHash(hash *chainhash.Hash) error

+ func (msg *MsgMerkleBlock) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) (err error)

+ func (msg *MsgMerkleBlock) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgMerkleBlock) Command() string

+ func (msg *MsgMerkleBlock) MaxPayloadLength(pver uint32) uint32

+ type MsgNotFound struct

+ InvList []*types.InvVect

+ func NewMsgNotFound() *MsgNotFound

+ func (msg *MsgNotFound) AddInvVect(iv *types.InvVect) error

+ func (msg *MsgNotFound) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgNotFound) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgNotFound) Command() string

+ func (msg *MsgNotFound) MaxPayloadLength(pver uint32) uint32

+ type MsgPing struct

+ Nonce uint64

+ func NewMsgPing(nonce uint64) *MsgPing

+ func (msg *MsgPing) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgPing) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgPing) Command() string

+ func (msg *MsgPing) MaxPayloadLength(pver uint32) uint32

+ type MsgPong struct

+ Nonce uint64

+ func NewMsgPong(nonce uint64) *MsgPong

+ func (msg *MsgPong) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgPong) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgPong) Command() string

+ func (msg *MsgPong) MaxPayloadLength(pver uint32) uint32

+ type MsgPortRedirect struct

+ IP net.IP

+ Port uint32

+ ShardID uint32

+ func NewMsgPortRedirect(shardID, port uint32, ip net.IP) *MsgPortRedirect

+ func (m *MsgPortRedirect) BtcDecode(r io.Reader, _ uint32, _ encoder.MessageEncoding) error

+ func (m *MsgPortRedirect) BtcEncode(w io.Writer, _ uint32, _ encoder.MessageEncoding) error

+ func (m *MsgPortRedirect) Command() string

+ func (m *MsgPortRedirect) MaxPayloadLength(uint32) uint32

+ type MsgReject struct

+ Cmd string

+ Code RejectCode

+ Hash chainhash.Hash

+ Reason string

+ func NewMsgReject(command string, code RejectCode, reason string) *MsgReject

+ func (msg *MsgReject) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgReject) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgReject) Command() string

+ func (msg *MsgReject) MaxPayloadLength(pver uint32) uint32

+ type MsgSendHeaders struct

+ func NewMsgSendHeaders() *MsgSendHeaders

+ func (msg *MsgSendHeaders) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgSendHeaders) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgSendHeaders) Command() string

+ func (msg *MsgSendHeaders) MaxPayloadLength(pver uint32) uint32

+ type MsgTx struct

+ LockTime uint32

+ TxIn []*TxIn

+ TxOut []*TxOut

+ Version int32

+ func NewMsgTx(version int32) *MsgTx

+ func (msg *MsgTx) AddTxIn(ti *TxIn)

+ func (msg *MsgTx) AddTxOut(to *TxOut)

+ func (msg *MsgTx) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgTx) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgTx) Command() string

+ func (msg *MsgTx) Copy() *MsgTx

+ func (msg *MsgTx) Deserialize(r io.Reader) error

+ func (msg *MsgTx) DeserializeNoWitness(r io.Reader) error

+ func (msg *MsgTx) HasWitness() bool

+ func (msg *MsgTx) MaxPayloadLength(pver uint32) uint32

+ func (msg *MsgTx) PkScriptLocs() []int

+ func (msg *MsgTx) Serialize(w io.Writer) error

+ func (msg *MsgTx) SerializeNoWitness(w io.Writer) error

+ func (msg *MsgTx) SerializeSize() int

+ func (msg *MsgTx) SerializeSizeStripped() int

+ func (msg *MsgTx) TxHash() chainhash.Hash

+ func (msg *MsgTx) WitnessHash() chainhash.Hash

+ type MsgVerAck struct

+ func NewMsgVerAck() *MsgVerAck

+ func (msg *MsgVerAck) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgVerAck) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgVerAck) Command() string

+ func (msg *MsgVerAck) MaxPayloadLength(pver uint32) uint32

+ type MsgVersion struct

+ AddrMe NetAddress

+ AddrYou NetAddress

+ DisableRelayTx bool

+ IsBeacon bool

+ LastBlock int32

+ Nonce uint64

+ ProtocolVersion int32

+ Services ServiceFlag

+ Shard uint32

+ Timestamp time.Time

+ UserAgent string

+ func NewMsgVersion(chain HeaderConstructor, me *NetAddress, you *NetAddress, nonce uint64, ...) *MsgVersion

+ func (*MsgVersion) Command() string

+ func (msg *MsgVersion) AddService(service ServiceFlag)

+ func (msg *MsgVersion) AddUserAgent(name string, version string, comments ...string) error

+ func (msg *MsgVersion) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgVersion) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (msg *MsgVersion) HasService(service ServiceFlag) bool

+ func (msg *MsgVersion) MaxPayloadLength(pver uint32) uint32

+ type NetAddress struct

+ IP net.IP

+ Port uint16

+ Services ServiceFlag

+ Timestamp time.Time

+ func NewNetAddress(addr *net.TCPAddr, services ServiceFlag) *NetAddress

+ func NewNetAddressIPPort(ip net.IP, port uint16, services ServiceFlag) *NetAddress

+ func NewNetAddressTimestamp(timestamp time.Time, services ServiceFlag, ip net.IP, port uint16) *NetAddress

+ func (na *NetAddress) AddService(service ServiceFlag)

+ func (na *NetAddress) HasService(service ServiceFlag) bool

+ type OutPoint struct

+ Hash chainhash.Hash

+ Index uint32

+ func NewOutPoint(hash *chainhash.Hash, index uint32) *OutPoint

+ func (o OutPoint) String() string

+ type RejectCode uint8

+ const RejectCheckpoint

+ const RejectDuplicate

+ const RejectDust

+ const RejectInsufficientFee

+ const RejectInvalid

+ const RejectMalformed

+ const RejectNonstandard

+ const RejectObsolete

+ func (code RejectCode) String() string

+ type ServiceFlag uint64

+ const SFNode2X

+ const SFNodeBit5

+ const SFNodeBloom

+ const SFNodeCF

+ const SFNodeGetUTXO

+ const SFNodeNetwork

+ const SFNodeWitness

+ const SFNodeXthin

+ func (f ServiceFlag) String() string

+ type ShardAddress struct

+ Address *NetAddress

+ ShardID uint32

+ type ShardHeader struct

+ BCHeader BeaconHeader

+ func EmptyShardHeader() *ShardHeader

+ func NewShardBlockHeader(prevHash, merkleRootHash chainhash.Hash, timestamp time.Time, bits uint32, ...) *ShardHeader

+ func (h *ShardHeader) BeaconHeader() *BeaconHeader

+ func (h *ShardHeader) Bits() uint32

+ func (h *ShardHeader) BlockData() []byte

+ func (h *ShardHeader) BlockHash() chainhash.Hash

+ func (h *ShardHeader) BtcDecode(r io.Reader, pver uint32, enc encoder.MessageEncoding) error

+ func (h *ShardHeader) BtcEncode(w io.Writer, pver uint32, enc encoder.MessageEncoding) error

+ func (h *ShardHeader) Copy() BlockHeader

+ func (h *ShardHeader) MaxLength() int

+ func (h *ShardHeader) MergeMiningNumber() uint32

+ func (h *ShardHeader) MergeMiningRoot() chainhash.Hash

+ func (h *ShardHeader) MerkleRoot() chainhash.Hash

+ func (h *ShardHeader) Nonce() uint32

+ func (h *ShardHeader) PrevBlock() chainhash.Hash

+ func (h *ShardHeader) Read(r io.Reader) error

+ func (h *ShardHeader) Serialize(w io.Writer) error

+ func (h *ShardHeader) SetBeaconHeader(bh *BeaconHeader)

+ func (h *ShardHeader) SetBits(bits uint32)

+ func (h *ShardHeader) SetMergeMiningNumber(n uint32)

+ func (h *ShardHeader) SetMergeMiningRoot(value chainhash.Hash)

+ func (h *ShardHeader) SetMerkleRoot(hash chainhash.Hash)

+ func (h *ShardHeader) SetNonce(n uint32)

+ func (h *ShardHeader) SetPrevBlock(prevBlock chainhash.Hash)

+ func (h *ShardHeader) SetTimestamp(t time.Time)

+ func (h *ShardHeader) ShardBlockHash() chainhash.Hash

+ func (h *ShardHeader) Timestamp() time.Time

+ func (h *ShardHeader) Version() BVersion

+ func (h *ShardHeader) Write(w io.Writer) error

+ type ShardHeaderConstructor struct

+ ID uint32

+ func (b ShardHeaderConstructor) BlockHeaderOverhead() int

+ func (b ShardHeaderConstructor) EmptyHeader() BlockHeader

+ func (b ShardHeaderConstructor) IsBeacon() bool

+ func (b ShardHeaderConstructor) MaxBlockHeaderPayload() int

+ func (b ShardHeaderConstructor) ShardID() uint32

+ type TxIn struct

+ PreviousOutPoint OutPoint

+ Sequence uint32

+ SignatureScript []byte

+ Witness TxWitness

+ func NewTxIn(prevOut *OutPoint, signatureScript []byte, witness [][]byte) *TxIn

+ func (t *TxIn) SerializeSize() int

+ type TxLoc struct

+ TxLen int

+ TxStart int

+ type TxOut struct

+ PkScript []byte

+ Value int64

+ func NewTxOut(value int64, pkScript []byte) *TxOut

+ func (t *TxOut) SerializeSize() int

+ type TxWitness [][]byte

+ func (t TxWitness) SerializeSize() int