p2p_message

package
v0.0.2 Latest Latest
Warning

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

Go to latest
Published: Jul 17, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Copyright © 2019 Annchain Authors <EMAIL ADDRESS>

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2019 Annchain Authors <EMAIL ADDRESS>

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source
const (
	BloomItemNumber = 3000
	HashFuncNum     = 8
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BasicMessage

type BasicMessage struct {
	SourceId    uint16
	HeightRound HeightRound
	TermId      uint32
}

func (*BasicMessage) DecodeMsg

func (z *BasicMessage) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*BasicMessage) EncodeMsg

func (z *BasicMessage) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*BasicMessage) MarshalMsg

func (z *BasicMessage) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*BasicMessage) Msgsize

func (z *BasicMessage) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (BasicMessage) String

func (m BasicMessage) String() string

func (*BasicMessage) UnmarshalMsg

func (z *BasicMessage) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type BloomFilter

type BloomFilter struct {
	Data     []byte
	Count    uint32
	Capacity uint32
	// contains filtered or unexported fields
}

func NewBloomFilter

func NewBloomFilter(m uint32) *BloomFilter

func NewDefaultBloomFilter

func NewDefaultBloomFilter() *BloomFilter

func (*BloomFilter) AddItem

func (c *BloomFilter) AddItem(item []byte)

func (*BloomFilter) Decode

func (c *BloomFilter) Decode() error

func (*BloomFilter) DecodeMsg

func (z *BloomFilter) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*BloomFilter) Encode

func (c *BloomFilter) Encode() error

func (*BloomFilter) EncodeMsg

func (z *BloomFilter) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*BloomFilter) GetCount

func (c *BloomFilter) GetCount() uint32

func (*BloomFilter) LookUpItem

func (c *BloomFilter) LookUpItem(item []byte) (bool, error)

func (*BloomFilter) MarshalMsg

func (z *BloomFilter) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*BloomFilter) Msgsize

func (z *BloomFilter) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*BloomFilter) UnmarshalMsg

func (z *BloomFilter) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type HashOrNumber

type HashOrNumber struct {
	Hash   *common.Hash // Block hash from which to retrieve headers (excludes Number)
	Number *uint64      // Block hash from which to retrieve headers (excludes Hash)
}

hashOrNumber is a combined field for specifying an origin block.

func (*HashOrNumber) DecodeMsg

func (z *HashOrNumber) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*HashOrNumber) EncodeMsg

func (z *HashOrNumber) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*HashOrNumber) MarshalMsg

func (z *HashOrNumber) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*HashOrNumber) Msgsize

func (z *HashOrNumber) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*HashOrNumber) String

func (m *HashOrNumber) String() string

func (*HashOrNumber) UnmarshalMsg

func (z *HashOrNumber) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type HeightRound

type HeightRound struct {
	Height uint64
	Round  int
}

HeightRound is the current progress of the consensus. Height is the block height, round is the sub-progress if no consensus can be easily reached

func (*HeightRound) DecodeMsg

func (z *HeightRound) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (HeightRound) EncodeMsg

func (z HeightRound) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*HeightRound) IsAfter

func (h *HeightRound) IsAfter(o HeightRound) bool

IsAfter judges whether self is a higher HeightRound

func (*HeightRound) IsAfterOrEqual

func (h *HeightRound) IsAfterOrEqual(o HeightRound) bool

IsAfterOrEqual judges whether self is a higher or equal HeightRound

func (*HeightRound) IsBefore

func (h *HeightRound) IsBefore(o HeightRound) bool

IsAfterOrEqual judges whether self is a lower HeightRound

func (HeightRound) MarshalMsg

func (z HeightRound) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (HeightRound) Msgsize

func (z HeightRound) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*HeightRound) String

func (h *HeightRound) String() string

func (*HeightRound) UnmarshalMsg

func (z *HeightRound) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type Message

type Message interface {
	msg.Message
	String() string //string is for logging
}

type MessageBodiesRequest

type MessageBodiesRequest struct {
	SeqHashes common.Hashes
	RequestId uint32 //avoid msg drop
}

func (*MessageBodiesRequest) DecodeMsg

func (z *MessageBodiesRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageBodiesRequest) EncodeMsg

func (z *MessageBodiesRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageBodiesRequest) MarshalMsg

func (z *MessageBodiesRequest) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageBodiesRequest) Msgsize

func (z *MessageBodiesRequest) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageBodiesRequest) String

func (m *MessageBodiesRequest) String() string

func (*MessageBodiesRequest) UnmarshalMsg

func (z *MessageBodiesRequest) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageBodiesResponse

type MessageBodiesResponse struct {
	Bodies      []RawData
	RequestedId uint32 //avoid msg drop
}

func (*MessageBodiesResponse) DecodeMsg

func (z *MessageBodiesResponse) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageBodiesResponse) EncodeMsg

func (z *MessageBodiesResponse) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageBodiesResponse) MarshalMsg

func (z *MessageBodiesResponse) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageBodiesResponse) Msgsize

func (z *MessageBodiesResponse) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageBodiesResponse) String

func (m *MessageBodiesResponse) String() string

func (*MessageBodiesResponse) UnmarshalMsg

func (z *MessageBodiesResponse) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageBodyData

type MessageBodyData struct {
	//RawTxs         *RawTxs
	//RawTermChanges *RawTermChanges
	//RawCampaigns   *RawCampaigns
	RawSequencer *tx_types.RawSequencer
	RawTxs       *tx_types.TxisMarshaler
}

func (*MessageBodyData) DecodeMsg

func (z *MessageBodyData) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageBodyData) EncodeMsg

func (z *MessageBodyData) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageBodyData) MarshalMsg

func (z *MessageBodyData) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageBodyData) Msgsize

func (z *MessageBodyData) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageBodyData) String

func (m *MessageBodyData) String() string

func (*MessageBodyData) ToTxis

func (m *MessageBodyData) ToTxis() types.Txis

func (*MessageBodyData) UnmarshalMsg

func (z *MessageBodyData) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageCampaign

type MessageCampaign struct {
	RawCampaign *tx_types.RawCampaign
}

func (*MessageCampaign) DecodeMsg

func (z *MessageCampaign) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageCampaign) EncodeMsg

func (z *MessageCampaign) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageCampaign) MarshalMsg

func (z *MessageCampaign) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageCampaign) Msgsize

func (z *MessageCampaign) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageCampaign) String

func (m *MessageCampaign) String() string

func (*MessageCampaign) UnmarshalMsg

func (z *MessageCampaign) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageConsensusDkgDeal

type MessageConsensusDkgDeal struct {
	Id        uint32
	Data      []byte
	PublicKey []byte
	Signature []byte
	TermId    uint64
}

func (*MessageConsensusDkgDeal) DecodeMsg

func (z *MessageConsensusDkgDeal) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageConsensusDkgDeal) EncodeMsg

func (z *MessageConsensusDkgDeal) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageConsensusDkgDeal) MarshalMsg

func (z *MessageConsensusDkgDeal) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageConsensusDkgDeal) Msgsize

func (z *MessageConsensusDkgDeal) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageConsensusDkgDeal) SignatureTargets

func (m *MessageConsensusDkgDeal) SignatureTargets() []byte

func (MessageConsensusDkgDeal) String

func (m MessageConsensusDkgDeal) String() string

func (*MessageConsensusDkgDeal) UnmarshalMsg

func (z *MessageConsensusDkgDeal) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageConsensusDkgDealResponse

type MessageConsensusDkgDealResponse struct {
	Id        uint32
	Data      []byte
	PublicKey []byte
	Signature []byte
	TermId    uint64
}

func (*MessageConsensusDkgDealResponse) DecodeMsg

func (z *MessageConsensusDkgDealResponse) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageConsensusDkgDealResponse) EncodeMsg

func (z *MessageConsensusDkgDealResponse) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageConsensusDkgDealResponse) MarshalMsg

func (z *MessageConsensusDkgDealResponse) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageConsensusDkgDealResponse) Msgsize

func (z *MessageConsensusDkgDealResponse) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageConsensusDkgDealResponse) SignatureTargets

func (m *MessageConsensusDkgDealResponse) SignatureTargets() []byte

func (MessageConsensusDkgDealResponse) String

func (*MessageConsensusDkgDealResponse) UnmarshalMsg

func (z *MessageConsensusDkgDealResponse) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageConsensusDkgGenesisPublicKey

type MessageConsensusDkgGenesisPublicKey struct {
	DkgPublicKey []byte
	PublicKey    []byte
	Signature    []byte
	TermId       uint64
}

func (*MessageConsensusDkgGenesisPublicKey) DecodeMsg

func (z *MessageConsensusDkgGenesisPublicKey) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageConsensusDkgGenesisPublicKey) EncodeMsg

func (z *MessageConsensusDkgGenesisPublicKey) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageConsensusDkgGenesisPublicKey) MarshalMsg

func (z *MessageConsensusDkgGenesisPublicKey) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageConsensusDkgGenesisPublicKey) Msgsize

func (z *MessageConsensusDkgGenesisPublicKey) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageConsensusDkgGenesisPublicKey) SignatureTargets

func (m *MessageConsensusDkgGenesisPublicKey) SignatureTargets() []byte

func (*MessageConsensusDkgGenesisPublicKey) String

func (*MessageConsensusDkgGenesisPublicKey) UnmarshalMsg

func (z *MessageConsensusDkgGenesisPublicKey) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageConsensusDkgSigSets

type MessageConsensusDkgSigSets struct {
	PkBls     []byte
	PublicKey []byte
	Signature []byte
	TermId    uint64
}

func (*MessageConsensusDkgSigSets) DecodeMsg

func (z *MessageConsensusDkgSigSets) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageConsensusDkgSigSets) EncodeMsg

func (z *MessageConsensusDkgSigSets) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageConsensusDkgSigSets) MarshalMsg

func (z *MessageConsensusDkgSigSets) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageConsensusDkgSigSets) Msgsize

func (z *MessageConsensusDkgSigSets) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageConsensusDkgSigSets) SignatureTargets

func (m *MessageConsensusDkgSigSets) SignatureTargets() []byte

func (*MessageConsensusDkgSigSets) String

func (m *MessageConsensusDkgSigSets) String() string

func (*MessageConsensusDkgSigSets) UnmarshalMsg

func (z *MessageConsensusDkgSigSets) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageControl

type MessageControl struct {
	Hash *common.Hash
}

func (*MessageControl) DecodeMsg

func (z *MessageControl) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageControl) EncodeMsg

func (z *MessageControl) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageControl) MarshalMsg

func (z *MessageControl) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageControl) Msgsize

func (z *MessageControl) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageControl) String

func (m *MessageControl) String() string

func (*MessageControl) UnmarshalMsg

func (z *MessageControl) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageDuplicate

type MessageDuplicate bool

func (*MessageDuplicate) DecodeMsg

func (z *MessageDuplicate) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (MessageDuplicate) EncodeMsg

func (z MessageDuplicate) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (MessageDuplicate) MarshalMsg

func (z MessageDuplicate) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (MessageDuplicate) Msgsize

func (z MessageDuplicate) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageDuplicate) String

func (m *MessageDuplicate) String() string

func (*MessageDuplicate) UnmarshalMsg

func (z *MessageDuplicate) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageGetMsg

type MessageGetMsg struct {
	Hash *common.Hash
}

func (*MessageGetMsg) DecodeMsg

func (z *MessageGetMsg) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageGetMsg) EncodeMsg

func (z *MessageGetMsg) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageGetMsg) MarshalMsg

func (z *MessageGetMsg) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageGetMsg) Msgsize

func (z *MessageGetMsg) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageGetMsg) String

func (m *MessageGetMsg) String() string

func (*MessageGetMsg) UnmarshalMsg

func (z *MessageGetMsg) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageHeaderRequest

type MessageHeaderRequest struct {
	Origin    HashOrNumber // Block from which to retrieve headers
	Amount    uint64       // Maximum number of headers to retrieve
	Skip      uint64       // Blocks to skip between consecutive headers
	Reverse   bool         // Query direction (false = rising towards latest, true = falling towards genesis)
	RequestId uint32       //avoid msg drop
}

getBlockHeadersData represents a block header query.

func (*MessageHeaderRequest) DecodeMsg

func (z *MessageHeaderRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageHeaderRequest) EncodeMsg

func (z *MessageHeaderRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageHeaderRequest) MarshalMsg

func (z *MessageHeaderRequest) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageHeaderRequest) Msgsize

func (z *MessageHeaderRequest) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageHeaderRequest) String

func (m *MessageHeaderRequest) String() string

func (*MessageHeaderRequest) UnmarshalMsg

func (z *MessageHeaderRequest) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageHeaderResponse

type MessageHeaderResponse struct {
	Headers     *tx_types.SequencerHeaders
	RequestedId uint32 //avoid msg drop
}

func (*MessageHeaderResponse) DecodeMsg

func (z *MessageHeaderResponse) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageHeaderResponse) EncodeMsg

func (z *MessageHeaderResponse) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageHeaderResponse) MarshalMsg

func (z *MessageHeaderResponse) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageHeaderResponse) Msgsize

func (z *MessageHeaderResponse) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageHeaderResponse) String

func (m *MessageHeaderResponse) String() string

func (*MessageHeaderResponse) UnmarshalMsg

func (z *MessageHeaderResponse) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageNewActionTx

type MessageNewActionTx struct {
	ActionTx *tx_types.ActionTx
}

func (*MessageNewActionTx) DecodeMsg

func (z *MessageNewActionTx) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageNewActionTx) EncodeMsg

func (z *MessageNewActionTx) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageNewActionTx) MarshalMsg

func (z *MessageNewActionTx) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageNewActionTx) Msgsize

func (z *MessageNewActionTx) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageNewActionTx) String

func (m *MessageNewActionTx) String() string

func (*MessageNewActionTx) UnmarshalMsg

func (z *MessageNewActionTx) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageNewArchive

type MessageNewArchive struct {
	Archive *tx_types.Archive
}

func (*MessageNewArchive) DecodeMsg

func (z *MessageNewArchive) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageNewArchive) EncodeMsg

func (z *MessageNewArchive) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageNewArchive) MarshalMsg

func (z *MessageNewArchive) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageNewArchive) Msgsize

func (z *MessageNewArchive) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageNewArchive) String

func (m *MessageNewArchive) String() string

func (*MessageNewArchive) UnmarshalMsg

func (z *MessageNewArchive) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageNewSequencer

type MessageNewSequencer struct {
	RawSequencer *tx_types.RawSequencer
}

func (*MessageNewSequencer) DecodeMsg

func (z *MessageNewSequencer) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageNewSequencer) EncodeMsg

func (z *MessageNewSequencer) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageNewSequencer) GetHash

func (m *MessageNewSequencer) GetHash() *common.Hash

func (*MessageNewSequencer) MarshalMsg

func (z *MessageNewSequencer) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageNewSequencer) Msgsize

func (z *MessageNewSequencer) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageNewSequencer) String

func (m *MessageNewSequencer) String() string

func (*MessageNewSequencer) UnmarshalMsg

func (z *MessageNewSequencer) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageNewTx

type MessageNewTx struct {
	RawTx *tx_types.RawTx
}

func (*MessageNewTx) DecodeMsg

func (z *MessageNewTx) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageNewTx) EncodeMsg

func (z *MessageNewTx) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageNewTx) GetHash

func (m *MessageNewTx) GetHash() *common.Hash

func (*MessageNewTx) MarshalMsg

func (z *MessageNewTx) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageNewTx) Msgsize

func (z *MessageNewTx) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageNewTx) String

func (m *MessageNewTx) String() string

func (*MessageNewTx) UnmarshalMsg

func (z *MessageNewTx) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageNewTxs

type MessageNewTxs struct {
	RawTxs *tx_types.RawTxs
}

func (*MessageNewTxs) DecodeMsg

func (z *MessageNewTxs) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageNewTxs) EncodeMsg

func (z *MessageNewTxs) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageNewTxs) Hashes

func (m *MessageNewTxs) Hashes() common.Hashes

func (*MessageNewTxs) MarshalMsg

func (z *MessageNewTxs) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageNewTxs) Msgsize

func (z *MessageNewTxs) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageNewTxs) String

func (m *MessageNewTxs) String() string

func (*MessageNewTxs) Txis

func (m *MessageNewTxs) Txis() types.Txis

func (*MessageNewTxs) UnmarshalMsg

func (z *MessageNewTxs) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessagePing

type MessagePing struct {
	Data []byte
}

func (*MessagePing) DecodeMsg

func (z *MessagePing) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessagePing) EncodeMsg

func (z *MessagePing) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessagePing) MarshalMsg

func (z *MessagePing) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessagePing) Msgsize

func (z *MessagePing) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessagePing) String

func (m *MessagePing) String() string

func (*MessagePing) UnmarshalMsg

func (z *MessagePing) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessagePong

type MessagePong struct {
	Data []byte
}

func (*MessagePong) DecodeMsg

func (z *MessagePong) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessagePong) EncodeMsg

func (z *MessagePong) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessagePong) MarshalMsg

func (z *MessagePong) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessagePong) Msgsize

func (z *MessagePong) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessagePong) String

func (m *MessagePong) String() string

func (*MessagePong) UnmarshalMsg

func (z *MessagePong) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessagePreCommit

type MessagePreCommit struct {
	BasicMessage
	Idv          *common.Hash // ID of the proposal, usually be the hash of the proposal
	BlsSignature hexutil.Bytes
	Signature    hexutil.Bytes
	PublicKey    hexutil.Bytes
}

func (*MessagePreCommit) BlsSignatureTargets

func (m *MessagePreCommit) BlsSignatureTargets() []byte

func (*MessagePreCommit) DecodeMsg

func (z *MessagePreCommit) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessagePreCommit) EncodeMsg

func (z *MessagePreCommit) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessagePreCommit) MarshalMsg

func (z *MessagePreCommit) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessagePreCommit) Msgsize

func (z *MessagePreCommit) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessagePreCommit) SignatureTargets

func (m *MessagePreCommit) SignatureTargets() []byte

func (MessagePreCommit) String

func (m MessagePreCommit) String() string

func (*MessagePreCommit) UnmarshalMsg

func (z *MessagePreCommit) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessagePreVote

type MessagePreVote struct {
	BasicMessage
	Idv       *common.Hash // ID of the proposal, usually be the hash of the proposal
	Signature hexutil.Bytes
	PublicKey hexutil.Bytes
}

func (*MessagePreVote) DecodeMsg

func (z *MessagePreVote) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessagePreVote) EncodeMsg

func (z *MessagePreVote) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessagePreVote) MarshalMsg

func (z *MessagePreVote) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessagePreVote) Msgsize

func (z *MessagePreVote) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessagePreVote) SignatureTargets

func (m *MessagePreVote) SignatureTargets() []byte

func (MessagePreVote) String

func (m MessagePreVote) String() string

func (*MessagePreVote) UnmarshalMsg

func (z *MessagePreVote) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageProposal

type MessageProposal struct {
	BasicMessage
	Value      Proposal //TODO
	ValidRound int
	//PublicKey  []byte
	Signature hexutil.Bytes
}

func (MessageProposal) Copy

func (m MessageProposal) Copy() *MessageProposal

func (*MessageProposal) DecodeMsg

func (z *MessageProposal) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageProposal) EncodeMsg

func (z *MessageProposal) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageProposal) MarshalMsg

func (z *MessageProposal) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageProposal) Msgsize

func (z *MessageProposal) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageProposal) SignatureTargets

func (m *MessageProposal) SignatureTargets() []byte

func (MessageProposal) String

func (m MessageProposal) String() string

func (*MessageProposal) UnmarshalMsg

func (z *MessageProposal) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageSequencerHeader

type MessageSequencerHeader struct {
	Hash   *common.Hash
	Number *uint64
}

func (*MessageSequencerHeader) DecodeMsg

func (z *MessageSequencerHeader) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageSequencerHeader) EncodeMsg

func (z *MessageSequencerHeader) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageSequencerHeader) MarshalMsg

func (z *MessageSequencerHeader) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageSequencerHeader) Msgsize

func (z *MessageSequencerHeader) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageSequencerHeader) String

func (m *MessageSequencerHeader) String() string

func (*MessageSequencerHeader) UnmarshalMsg

func (z *MessageSequencerHeader) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageSyncRequest

type MessageSyncRequest struct {
	Hashes    *common.Hashes
	Filter    *BloomFilter
	Height    *uint64
	RequestId uint32 //avoid msg drop
}

func (*MessageSyncRequest) DecodeMsg

func (z *MessageSyncRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageSyncRequest) EncodeMsg

func (z *MessageSyncRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageSyncRequest) MarshalMsg

func (z *MessageSyncRequest) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageSyncRequest) Msgsize

func (z *MessageSyncRequest) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageSyncRequest) String

func (m *MessageSyncRequest) String() string

func (*MessageSyncRequest) UnmarshalMsg

func (z *MessageSyncRequest) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageSyncResponse

type MessageSyncResponse struct {
	//RawTxs *RawTxs
	////SequencerIndex  []uint32
	//RawSequencers  *RawSequencers
	//RawCampaigns   *RawCampaigns
	//RawTermChanges *RawTermChanges
	RawTxs      *tx_types.TxisMarshaler
	RequestedId uint32 //avoid msg drop
}

func (*MessageSyncResponse) DecodeMsg

func (z *MessageSyncResponse) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageSyncResponse) EncodeMsg

func (z *MessageSyncResponse) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageSyncResponse) Hashes

func (m *MessageSyncResponse) Hashes() common.Hashes

func (*MessageSyncResponse) MarshalMsg

func (z *MessageSyncResponse) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageSyncResponse) Msgsize

func (z *MessageSyncResponse) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageSyncResponse) String

func (m *MessageSyncResponse) String() string

func (*MessageSyncResponse) Txis

func (m *MessageSyncResponse) Txis() types.Txis

func (*MessageSyncResponse) UnmarshalMsg

func (z *MessageSyncResponse) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageTermChange

type MessageTermChange struct {
	RawTermChange *tx_types.RawTermChange
}

func (*MessageTermChange) DecodeMsg

func (z *MessageTermChange) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageTermChange) EncodeMsg

func (z *MessageTermChange) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageTermChange) MarshalMsg

func (z *MessageTermChange) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageTermChange) Msgsize

func (z *MessageTermChange) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageTermChange) String

func (m *MessageTermChange) String() string

func (*MessageTermChange) UnmarshalMsg

func (z *MessageTermChange) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageTermChangeRequest

type MessageTermChangeRequest struct {
	Id uint32
}

func (*MessageTermChangeRequest) DecodeMsg

func (z *MessageTermChangeRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (MessageTermChangeRequest) EncodeMsg

func (z MessageTermChangeRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (MessageTermChangeRequest) MarshalMsg

func (z MessageTermChangeRequest) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (MessageTermChangeRequest) Msgsize

func (z MessageTermChangeRequest) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (MessageTermChangeRequest) String

func (m MessageTermChangeRequest) String() string

func (*MessageTermChangeRequest) UnmarshalMsg

func (z *MessageTermChangeRequest) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageTermChangeResponse

type MessageTermChangeResponse struct {
	TermChange *tx_types.TermChange
	Id         uint32
}

func (*MessageTermChangeResponse) DecodeMsg

func (z *MessageTermChangeResponse) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageTermChangeResponse) EncodeMsg

func (z *MessageTermChangeResponse) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageTermChangeResponse) MarshalMsg

func (z *MessageTermChangeResponse) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageTermChangeResponse) Msgsize

func (z *MessageTermChangeResponse) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (MessageTermChangeResponse) String

func (m MessageTermChangeResponse) String() string

func (*MessageTermChangeResponse) UnmarshalMsg

func (z *MessageTermChangeResponse) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageTxsRequest

type MessageTxsRequest struct {
	Hashes    *common.Hashes
	SeqHash   *common.Hash
	Id        *uint64
	RequestId uint32 //avoid msg drop
}

func (*MessageTxsRequest) DecodeMsg

func (z *MessageTxsRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageTxsRequest) EncodeMsg

func (z *MessageTxsRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageTxsRequest) MarshalMsg

func (z *MessageTxsRequest) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageTxsRequest) Msgsize

func (z *MessageTxsRequest) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageTxsRequest) String

func (m *MessageTxsRequest) String() string

func (*MessageTxsRequest) UnmarshalMsg

func (z *MessageTxsRequest) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type MessageTxsResponse

type MessageTxsResponse struct {
	//RawTxs         *RawTxs
	RawSequencer *tx_types.RawSequencer
	//RawCampaigns   *RawCampaigns
	//RawTermChanges *RawTermChanges
	RawTxs      *tx_types.TxisMarshaler
	RequestedId uint32 //avoid msg drop
}

func (*MessageTxsResponse) DecodeMsg

func (z *MessageTxsResponse) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*MessageTxsResponse) EncodeMsg

func (z *MessageTxsResponse) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*MessageTxsResponse) Hashes

func (m *MessageTxsResponse) Hashes() common.Hashes

func (*MessageTxsResponse) MarshalMsg

func (z *MessageTxsResponse) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*MessageTxsResponse) Msgsize

func (z *MessageTxsResponse) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MessageTxsResponse) String

func (m *MessageTxsResponse) String() string

func (*MessageTxsResponse) UnmarshalMsg

func (z *MessageTxsResponse) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type Proposal

type Proposal interface {
	Equal(Proposal) bool
	GetId() *common.Hash
	msg.Message
	String() string
	Copy() Proposal
}

type RawData

type RawData []byte

func (*RawData) DecodeMsg

func (z *RawData) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (RawData) EncodeMsg

func (z RawData) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (RawData) MarshalMsg

func (z RawData) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (RawData) Msgsize

func (z RawData) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*RawData) UnmarshalMsg

func (z *RawData) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type SequencerProposal

type SequencerProposal struct {
	tx_types.Sequencer
}

func (SequencerProposal) Copy

func (s SequencerProposal) Copy() Proposal

func (*SequencerProposal) DecodeMsg

func (z *SequencerProposal) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*SequencerProposal) EncodeMsg

func (z *SequencerProposal) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (SequencerProposal) Equal

func (s SequencerProposal) Equal(o Proposal) bool

func (SequencerProposal) GetId

func (s SequencerProposal) GetId() *common.Hash

func (*SequencerProposal) MarshalMsg

func (z *SequencerProposal) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*SequencerProposal) Msgsize

func (z *SequencerProposal) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*SequencerProposal) String

func (s *SequencerProposal) String() string

func (*SequencerProposal) UnmarshalMsg

func (z *SequencerProposal) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type StringProposal

type StringProposal string

StringProposal is for test

func (StringProposal) Copy

func (s StringProposal) Copy() Proposal

func (*StringProposal) DecodeMsg

func (z *StringProposal) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (StringProposal) EncodeMsg

func (z StringProposal) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (StringProposal) Equal

func (s StringProposal) Equal(o Proposal) bool

func (StringProposal) GetId

func (s StringProposal) GetId() *common.Hash

func (StringProposal) MarshalMsg

func (z StringProposal) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (StringProposal) Msgsize

func (z StringProposal) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (StringProposal) String

func (s StringProposal) String() string

func (*StringProposal) UnmarshalMsg

func (z *StringProposal) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL