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
- type BasicMessage
- func (z *BasicMessage) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *BasicMessage) EncodeMsg(en *msgp.Writer) (err error)
- func (z *BasicMessage) MarshalMsg(b []byte) (o []byte, err error)
- func (z *BasicMessage) Msgsize() (s int)
- func (m BasicMessage) String() string
- func (z *BasicMessage) UnmarshalMsg(bts []byte) (o []byte, err error)
- type BloomFilter
- func (c *BloomFilter) AddItem(item []byte)
- func (c *BloomFilter) Decode() error
- func (z *BloomFilter) DecodeMsg(dc *msgp.Reader) (err error)
- func (c *BloomFilter) Encode() error
- func (z *BloomFilter) EncodeMsg(en *msgp.Writer) (err error)
- func (c *BloomFilter) GetCount() uint32
- func (c *BloomFilter) LookUpItem(item []byte) (bool, error)
- func (z *BloomFilter) MarshalMsg(b []byte) (o []byte, err error)
- func (z *BloomFilter) Msgsize() (s int)
- func (z *BloomFilter) UnmarshalMsg(bts []byte) (o []byte, err error)
- type HashOrNumber
- func (z *HashOrNumber) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *HashOrNumber) EncodeMsg(en *msgp.Writer) (err error)
- func (z *HashOrNumber) MarshalMsg(b []byte) (o []byte, err error)
- func (z *HashOrNumber) Msgsize() (s int)
- func (m *HashOrNumber) String() string
- func (z *HashOrNumber) UnmarshalMsg(bts []byte) (o []byte, err error)
- type HeightRound
- func (z *HeightRound) DecodeMsg(dc *msgp.Reader) (err error)
- func (z HeightRound) EncodeMsg(en *msgp.Writer) (err error)
- func (h *HeightRound) IsAfter(o HeightRound) bool
- func (h *HeightRound) IsAfterOrEqual(o HeightRound) bool
- func (h *HeightRound) IsBefore(o HeightRound) bool
- func (z HeightRound) MarshalMsg(b []byte) (o []byte, err error)
- func (z HeightRound) Msgsize() (s int)
- func (h *HeightRound) String() string
- func (z *HeightRound) UnmarshalMsg(bts []byte) (o []byte, err error)
- type Message
- type MessageBodiesRequest
- func (z *MessageBodiesRequest) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageBodiesRequest) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageBodiesRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageBodiesRequest) Msgsize() (s int)
- func (m *MessageBodiesRequest) String() string
- func (z *MessageBodiesRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageBodiesResponse
- func (z *MessageBodiesResponse) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageBodiesResponse) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageBodiesResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageBodiesResponse) Msgsize() (s int)
- func (m *MessageBodiesResponse) String() string
- func (z *MessageBodiesResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageBodyData
- func (z *MessageBodyData) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageBodyData) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageBodyData) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageBodyData) Msgsize() (s int)
- func (m *MessageBodyData) String() string
- func (m *MessageBodyData) ToTxis() types.Txis
- func (z *MessageBodyData) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageCampaign
- func (z *MessageCampaign) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageCampaign) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageCampaign) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageCampaign) Msgsize() (s int)
- func (m *MessageCampaign) String() string
- func (z *MessageCampaign) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageConsensusDkgDeal
- func (z *MessageConsensusDkgDeal) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageConsensusDkgDeal) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageConsensusDkgDeal) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageConsensusDkgDeal) Msgsize() (s int)
- func (m *MessageConsensusDkgDeal) SignatureTargets() []byte
- func (m MessageConsensusDkgDeal) String() string
- func (z *MessageConsensusDkgDeal) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageConsensusDkgDealResponse
- func (z *MessageConsensusDkgDealResponse) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageConsensusDkgDealResponse) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageConsensusDkgDealResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageConsensusDkgDealResponse) Msgsize() (s int)
- func (m *MessageConsensusDkgDealResponse) SignatureTargets() []byte
- func (m MessageConsensusDkgDealResponse) String() string
- func (z *MessageConsensusDkgDealResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageConsensusDkgGenesisPublicKey
- func (z *MessageConsensusDkgGenesisPublicKey) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageConsensusDkgGenesisPublicKey) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageConsensusDkgGenesisPublicKey) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageConsensusDkgGenesisPublicKey) Msgsize() (s int)
- func (m *MessageConsensusDkgGenesisPublicKey) SignatureTargets() []byte
- func (m *MessageConsensusDkgGenesisPublicKey) String() string
- func (z *MessageConsensusDkgGenesisPublicKey) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageConsensusDkgSigSets
- func (z *MessageConsensusDkgSigSets) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageConsensusDkgSigSets) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageConsensusDkgSigSets) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageConsensusDkgSigSets) Msgsize() (s int)
- func (m *MessageConsensusDkgSigSets) SignatureTargets() []byte
- func (m *MessageConsensusDkgSigSets) String() string
- func (z *MessageConsensusDkgSigSets) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageControl
- func (z *MessageControl) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageControl) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageControl) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageControl) Msgsize() (s int)
- func (m *MessageControl) String() string
- func (z *MessageControl) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageDuplicate
- func (z *MessageDuplicate) DecodeMsg(dc *msgp.Reader) (err error)
- func (z MessageDuplicate) EncodeMsg(en *msgp.Writer) (err error)
- func (z MessageDuplicate) MarshalMsg(b []byte) (o []byte, err error)
- func (z MessageDuplicate) Msgsize() (s int)
- func (m *MessageDuplicate) String() string
- func (z *MessageDuplicate) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageGetMsg
- func (z *MessageGetMsg) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageGetMsg) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageGetMsg) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageGetMsg) Msgsize() (s int)
- func (m *MessageGetMsg) String() string
- func (z *MessageGetMsg) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageHeaderRequest
- func (z *MessageHeaderRequest) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageHeaderRequest) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageHeaderRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageHeaderRequest) Msgsize() (s int)
- func (m *MessageHeaderRequest) String() string
- func (z *MessageHeaderRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageHeaderResponse
- func (z *MessageHeaderResponse) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageHeaderResponse) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageHeaderResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageHeaderResponse) Msgsize() (s int)
- func (m *MessageHeaderResponse) String() string
- func (z *MessageHeaderResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageNewActionTx
- func (z *MessageNewActionTx) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageNewActionTx) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageNewActionTx) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageNewActionTx) Msgsize() (s int)
- func (m *MessageNewActionTx) String() string
- func (z *MessageNewActionTx) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageNewArchive
- func (z *MessageNewArchive) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageNewArchive) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageNewArchive) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageNewArchive) Msgsize() (s int)
- func (m *MessageNewArchive) String() string
- func (z *MessageNewArchive) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageNewSequencer
- func (z *MessageNewSequencer) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageNewSequencer) EncodeMsg(en *msgp.Writer) (err error)
- func (m *MessageNewSequencer) GetHash() *common.Hash
- func (z *MessageNewSequencer) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageNewSequencer) Msgsize() (s int)
- func (m *MessageNewSequencer) String() string
- func (z *MessageNewSequencer) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageNewTx
- func (z *MessageNewTx) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageNewTx) EncodeMsg(en *msgp.Writer) (err error)
- func (m *MessageNewTx) GetHash() *common.Hash
- func (z *MessageNewTx) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageNewTx) Msgsize() (s int)
- func (m *MessageNewTx) String() string
- func (z *MessageNewTx) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageNewTxs
- func (z *MessageNewTxs) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageNewTxs) EncodeMsg(en *msgp.Writer) (err error)
- func (m *MessageNewTxs) Hashes() common.Hashes
- func (z *MessageNewTxs) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageNewTxs) Msgsize() (s int)
- func (m *MessageNewTxs) String() string
- func (m *MessageNewTxs) Txis() types.Txis
- func (z *MessageNewTxs) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessagePing
- func (z *MessagePing) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessagePing) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessagePing) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessagePing) Msgsize() (s int)
- func (m *MessagePing) String() string
- func (z *MessagePing) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessagePong
- func (z *MessagePong) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessagePong) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessagePong) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessagePong) Msgsize() (s int)
- func (m *MessagePong) String() string
- func (z *MessagePong) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessagePreCommit
- func (m *MessagePreCommit) BlsSignatureTargets() []byte
- func (z *MessagePreCommit) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessagePreCommit) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessagePreCommit) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessagePreCommit) Msgsize() (s int)
- func (m *MessagePreCommit) SignatureTargets() []byte
- func (m MessagePreCommit) String() string
- func (z *MessagePreCommit) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessagePreVote
- func (z *MessagePreVote) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessagePreVote) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessagePreVote) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessagePreVote) Msgsize() (s int)
- func (m *MessagePreVote) SignatureTargets() []byte
- func (m MessagePreVote) String() string
- func (z *MessagePreVote) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageProposal
- func (m MessageProposal) Copy() *MessageProposal
- func (z *MessageProposal) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageProposal) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageProposal) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageProposal) Msgsize() (s int)
- func (m *MessageProposal) SignatureTargets() []byte
- func (m MessageProposal) String() string
- func (z *MessageProposal) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageSequencerHeader
- func (z *MessageSequencerHeader) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageSequencerHeader) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageSequencerHeader) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageSequencerHeader) Msgsize() (s int)
- func (m *MessageSequencerHeader) String() string
- func (z *MessageSequencerHeader) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageSyncRequest
- func (z *MessageSyncRequest) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageSyncRequest) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageSyncRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageSyncRequest) Msgsize() (s int)
- func (m *MessageSyncRequest) String() string
- func (z *MessageSyncRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageSyncResponse
- func (z *MessageSyncResponse) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageSyncResponse) EncodeMsg(en *msgp.Writer) (err error)
- func (m *MessageSyncResponse) Hashes() common.Hashes
- func (z *MessageSyncResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageSyncResponse) Msgsize() (s int)
- func (m *MessageSyncResponse) String() string
- func (m *MessageSyncResponse) Txis() types.Txis
- func (z *MessageSyncResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageTermChange
- func (z *MessageTermChange) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageTermChange) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageTermChange) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageTermChange) Msgsize() (s int)
- func (m *MessageTermChange) String() string
- func (z *MessageTermChange) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageTermChangeRequest
- func (z *MessageTermChangeRequest) DecodeMsg(dc *msgp.Reader) (err error)
- func (z MessageTermChangeRequest) EncodeMsg(en *msgp.Writer) (err error)
- func (z MessageTermChangeRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z MessageTermChangeRequest) Msgsize() (s int)
- func (m MessageTermChangeRequest) String() string
- func (z *MessageTermChangeRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageTermChangeResponse
- func (z *MessageTermChangeResponse) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageTermChangeResponse) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageTermChangeResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageTermChangeResponse) Msgsize() (s int)
- func (m MessageTermChangeResponse) String() string
- func (z *MessageTermChangeResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageTxsRequest
- func (z *MessageTxsRequest) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageTxsRequest) EncodeMsg(en *msgp.Writer) (err error)
- func (z *MessageTxsRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageTxsRequest) Msgsize() (s int)
- func (m *MessageTxsRequest) String() string
- func (z *MessageTxsRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type MessageTxsResponse
- func (z *MessageTxsResponse) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *MessageTxsResponse) EncodeMsg(en *msgp.Writer) (err error)
- func (m *MessageTxsResponse) Hashes() common.Hashes
- func (z *MessageTxsResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *MessageTxsResponse) Msgsize() (s int)
- func (m *MessageTxsResponse) String() string
- func (z *MessageTxsResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type Proposal
- type RawData
- type SequencerProposal
- func (s SequencerProposal) Copy() Proposal
- func (z *SequencerProposal) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *SequencerProposal) EncodeMsg(en *msgp.Writer) (err error)
- func (s SequencerProposal) Equal(o Proposal) bool
- func (s SequencerProposal) GetId() *common.Hash
- func (z *SequencerProposal) MarshalMsg(b []byte) (o []byte, err error)
- func (z *SequencerProposal) Msgsize() (s int)
- func (s *SequencerProposal) String() string
- func (z *SequencerProposal) UnmarshalMsg(bts []byte) (o []byte, err error)
- type StringProposal
- func (s StringProposal) Copy() Proposal
- func (z *StringProposal) DecodeMsg(dc *msgp.Reader) (err error)
- func (z StringProposal) EncodeMsg(en *msgp.Writer) (err error)
- func (s StringProposal) Equal(o Proposal) bool
- func (s StringProposal) GetId() *common.Hash
- func (z StringProposal) MarshalMsg(b []byte) (o []byte, err error)
- func (z StringProposal) Msgsize() (s int)
- func (s StringProposal) String() string
- func (z *StringProposal) UnmarshalMsg(bts []byte) (o []byte, err error)
Constants ¶
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 ¶
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 MessageBodiesRequest ¶
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 ¶
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 (m MessageConsensusDkgDealResponse) String() 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 (m *MessageConsensusDkgGenesisPublicKey) String() 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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 RawData ¶
type RawData []byte
func (RawData) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
type SequencerProposal ¶
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