consensus

package
v0.0.0-...-3442dc8 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2023 License: GPL-2.0 Imports: 55 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MOD_NAME      = "consensus"
	CONSENSUS_VER = uint32(1)
)
View Source 
const (
	PreparePackedExeChannel_Size      = 10
	PreparePackedExeIndicChannel_Size = 10
	PreparePackedPropChannel_Size     = 10
	ProposeChannel_Size               = 10
	BestProposeChannel_Size           = 10

	PartPubKeyChannel_Size  = 500
	DealMSGChannel_Size     = 500
	DealRespMsgChannel_Size = 500
	FinishedMsgChannel_Size = 500
)
View Source 
const (
	ConsensusDomain_MinProposer             = 3
	ConsensusDomain_MaxProposer             = 30
	ConsensusDomain_ProposerRadio           = 0.3
	ConsensusDomain_MinValidator            = 4
	ConsensusDomain_MaxValidator            = 70
	ConsensusDomain_MaxDomainOfEachNode     = 5 //Max Domain count that each node can join
	ConsensusDomain_TriggerTimesOfEachEpoch = 1
)
View Source 
const (
	DeliverStrategy_Unknown = iota
	DeliverStrategy_All
	DeliverStrategy_Specifically
)
View Source 
const (
	TxsResultValidity_MaxExecutor = 2
)
View Source 
const (
	ValidateTxMinCount = 3
)

Variables

View Source 
var (
	ErrInvalidLengthMessageCons        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessageCons          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessageCons = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ConsensusMessage_Type_name = map[int32]string{
	0:  "Unknown",
	1:  "CSDomainSel",
	2:  "PrepareExe",
	3:  "PrepareExeIndic",
	4:  "PrepareProp",
	5:  "Propose",
	6:  "ExeRSValidateReq",
	7:  "BestPropose",
	8:  "Vote",
	9:  "Commit",
	10: "PartPubKey",
	11: "DKGDeal",
	12: "DKGDealResp",
	13: "DKGFinished",
}
View Source 
var ConsensusMessage_Type_value = map[string]int32{
	"Unknown":          0,
	"CSDomainSel":      1,
	"PrepareExe":       2,
	"PrepareExeIndic":  3,
	"PrepareProp":      4,
	"Propose":          5,
	"ExeRSValidateReq": 6,
	"BestPropose":      7,
	"Vote":             8,
	"Commit":           9,
	"PartPubKey":       10,
	"DKGDeal":          11,
	"DKGDealResp":      12,
	"DKGFinished":      13,
}

Functions

func CreateConsensusActor 

func CreateConsensusActor(level tplogcmm.LogLevel, log tplog.Logger, sysActor *actor.ActorSystem, cons *consensus) (*actor.PID, error)

func NewConsensusHandler 

func NewConsensusHandler(log tplog.Logger,
	preparePackedMsgExeChan chan *PreparePackedMessageExe,
	preparePackedMsgExeIndicChan chan *PreparePackedMessageExeIndication,
	preparePackedMsgPropChan chan *PreparePackedMessageProp,
	proposeMsgChan chan *ProposeMessage,
	bestProposeMsgChan chan *BestProposeMessage,
	voteMsgChan chan *VoteMessage,
	commitMsgChan chan *CommitMessage,
	blockAddedCSDomain chan *tpchaintypes.Block,
	blockAddedProposerCh chan *tpchaintypes.Block,
	partPubKey chan *DKGPartPubKeyMessage,
	dealMsgCh chan *DKGDealMessage,
	dealRespMsgCh chan *DKGDealRespMessage,
	finishedMsgCh chan *DKGFinishedMessage,
	csDomainSelectedMsgCh chan *ConsensusDomainSelectedMessage,
	ledger ledger.Ledger,
	marshaler codec.Marshaler,
	deliver messageDeliverI,
	exeScheduler execution.ExecutionScheduler,
	epochService EpochService) *consensusHandler

func NewDkgMessageDeliver 

func NewDkgMessageDeliver(log tplog.Logger, nodeID string, priKey tpcrtypes.PrivateKey, strategy DeliverStrategy, network tpnet.Network, marshaler codec.Marshaler, cryptService tpcrt.CryptService, ledger ledger.Ledger, exeActiveNodeIds []string) dkgMessageDeliverI

func NewDomainConsensusSelector 

func NewDomainConsensusSelector(log tplog.Logger, ledger ledger.Ledger) *domainConsensusSelector

func NewDomainConsensusService 

func NewDomainConsensusService(
	nodeID string,
	stateBuilderType state.CompStateBuilderType,
	log tplog.Logger,
	ledger ledger.Ledger,
	blockAddedCh chan *tpchaintypes.Block,
	selector vrf.RoleSelectorVRF,
	csConfig *configuration.ConsensusConfiguration,
	dkgEx *dkgExchange,
	exeScheduler execution.ExecutionScheduler) *domainConsensusService

Types

type BestProposeMessage 

type BestProposeMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=Epoch,proto3" json:"epoch"`
	Round                uint64   `protobuf:"varint,4,opt,name=Round,proto3" json:"round"`
	Signature            []byte   `protobuf:"bytes,5,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,6,opt,name=PubKey,proto3" json:"pubKey"`
	StateVersion         uint64   `protobuf:"varint,7,opt,name=StateVersion,proto3" json:"stateVersion"`
	MaxPri               []byte   `protobuf:"bytes,8,opt,name=MaxPri,proto3" json:"maxPri"`
	Proposer             []byte   `protobuf:"bytes,9,opt,name=Proposer,proto3" json:"proposer"`
	PropMsgData          []byte   `protobuf:"bytes,10,opt,name=PropMsgData,proto3" json:"proposer"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BestProposeMessage) Descriptor 

func (*BestProposeMessage) Descriptor() ([]byte, []int)

func (*BestProposeMessage) GetChainID 

func (m *BestProposeMessage) GetChainID() []byte

func (*BestProposeMessage) GetEpoch 

func (m *BestProposeMessage) GetEpoch() uint64

func (*BestProposeMessage) GetMaxPri 

func (m *BestProposeMessage) GetMaxPri() []byte

func (*BestProposeMessage) GetPropMsgData 

func (m *BestProposeMessage) GetPropMsgData() []byte

func (*BestProposeMessage) GetProposer 

func (m *BestProposeMessage) GetProposer() []byte

func (*BestProposeMessage) GetPubKey 

func (m *BestProposeMessage) GetPubKey() []byte

func (*BestProposeMessage) GetRound 

func (m *BestProposeMessage) GetRound() uint64

func (*BestProposeMessage) GetSignature 

func (m *BestProposeMessage) GetSignature() []byte

func (*BestProposeMessage) GetStateVersion 

func (m *BestProposeMessage) GetStateVersion() uint64

func (*BestProposeMessage) GetVersion 

func (m *BestProposeMessage) GetVersion() uint32

func (*BestProposeMessage) Marshal 

func (m *BestProposeMessage) Marshal() (dAtA []byte, err error)

func (*BestProposeMessage) MarshalTo 

func (m *BestProposeMessage) MarshalTo(dAtA []byte) (int, error)

func (*BestProposeMessage) MarshalToSizedBuffer 

func (m *BestProposeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BestProposeMessage) ProtoMessage 

func (*BestProposeMessage) ProtoMessage()

func (*BestProposeMessage) Reset 

func (m *BestProposeMessage) Reset()

func (*BestProposeMessage) Size 

func (m *BestProposeMessage) Size() (n int)

func (*BestProposeMessage) String 

func (m *BestProposeMessage) String() string

func (*BestProposeMessage) Unmarshal 

func (m *BestProposeMessage) Unmarshal(dAtA []byte) error

func (*BestProposeMessage) XXX_DiscardUnknown 

func (m *BestProposeMessage) XXX_DiscardUnknown()

func (*BestProposeMessage) XXX_Marshal 

func (m *BestProposeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BestProposeMessage) XXX_Merge 

func (m *BestProposeMessage) XXX_Merge(src proto.Message)

func (*BestProposeMessage) XXX_Size 

func (m *BestProposeMessage) XXX_Size() int

func (*BestProposeMessage) XXX_Unmarshal 

func (m *BestProposeMessage) XXX_Unmarshal(b []byte) error

type CSActorMsgStatistics 

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

CSActorMsgStatistics is only for monitor

func (CSActorMsgStatistics) MailboxEmpty 

func (CSActorMsgStatistics) MailboxEmpty()

func (*CSActorMsgStatistics) MailboxStarted 

func (ms *CSActorMsgStatistics) MailboxStarted()

func (*CSActorMsgStatistics) MessagePosted 

func (ms *CSActorMsgStatistics) MessagePosted(message interface{})

func (*CSActorMsgStatistics) MessageReceived 

func (ms *CSActorMsgStatistics) MessageReceived(message interface{})

type CommitMessage 

type CommitMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=Epoch,proto3" json:"epoch"`
	Round                uint64   `protobuf:"varint,4,opt,name=Round,proto3" json:"round"`
	RefIndex             uint32   `protobuf:"varint,5,opt,name=RefIndex,proto3" json:"refIndex"`
	Signature            []byte   `protobuf:"bytes,6,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,7,opt,name=PubKey,proto3" json:"pubKey"`
	StateVersion         uint64   `protobuf:"varint,8,opt,name=StateVersion,proto3" json:"stateVersion"`
	BlockHead            []byte   `protobuf:"bytes,9,opt,name=BlockHead,proto3" json:"blockHead"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommitMessage) Descriptor 

func (*CommitMessage) Descriptor() ([]byte, []int)

func (*CommitMessage) GetBlockHead 

func (m *CommitMessage) GetBlockHead() []byte

func (*CommitMessage) GetChainID 

func (m *CommitMessage) GetChainID() []byte

func (*CommitMessage) GetEpoch 

func (m *CommitMessage) GetEpoch() uint64

func (*CommitMessage) GetPubKey 

func (m *CommitMessage) GetPubKey() []byte

func (*CommitMessage) GetRefIndex 

func (m *CommitMessage) GetRefIndex() uint32

func (*CommitMessage) GetRound 

func (m *CommitMessage) GetRound() uint64

func (*CommitMessage) GetSignature 

func (m *CommitMessage) GetSignature() []byte

func (*CommitMessage) GetStateVersion 

func (m *CommitMessage) GetStateVersion() uint64

func (*CommitMessage) GetVersion 

func (m *CommitMessage) GetVersion() uint32

func (*CommitMessage) Marshal 

func (m *CommitMessage) Marshal() (dAtA []byte, err error)

func (*CommitMessage) MarshalTo 

func (m *CommitMessage) MarshalTo(dAtA []byte) (int, error)

func (*CommitMessage) MarshalToSizedBuffer 

func (m *CommitMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommitMessage) ProtoMessage 

func (*CommitMessage) ProtoMessage()

func (*CommitMessage) Reset 

func (m *CommitMessage) Reset()

func (*CommitMessage) Size 

func (m *CommitMessage) Size() (n int)

func (*CommitMessage) String 

func (m *CommitMessage) String() string

func (*CommitMessage) Unmarshal 

func (m *CommitMessage) Unmarshal(dAtA []byte) error

func (*CommitMessage) XXX_DiscardUnknown 

func (m *CommitMessage) XXX_DiscardUnknown()

func (*CommitMessage) XXX_Marshal 

func (m *CommitMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitMessage) XXX_Merge 

func (m *CommitMessage) XXX_Merge(src proto.Message)

func (*CommitMessage) XXX_Size 

func (m *CommitMessage) XXX_Size() int

func (*CommitMessage) XXX_Unmarshal 

func (m *CommitMessage) XXX_Unmarshal(b []byte) error

type Consensus 

type Consensus interface {
	VerifyBlock(*tpchaintypes.Block) error

	ProcessPropose(*ProposeMessage) error

	ProcessVote(*VoteMessage) error

	UpdateHandler(handler ConsensusHandler)

	Start(*actor.ActorSystem, uint64, uint64, uint64) error

	TriggerDKG(newBlock *tpchaintypes.Block)

	Stop()
}

func NewConsensus 

func NewConsensus(chainID tpchaintypes.ChainID,
	nodeID string,
	stateBuilderType state.CompStateBuilderType,
	priKey tpcrtypes.PrivateKey,
	level tplogcmm.LogLevel,
	log tplog.Logger,
	codecType codec.CodecType,
	network tpnet.Network,
	txPool txpooli.TransactionPool,
	ledger ledger.Ledger,
	exeScheduler execution.ExecutionScheduler,
	config *tpconfig.Configuration) Consensus

type ConsensusActor 

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

func (*ConsensusActor) Receive 

func (ca *ConsensusActor) Receive(actCtx actor.Context)

type ConsensusDomainSelectedMessage 

type ConsensusDomainSelectedMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Signature            []byte   `protobuf:"bytes,3,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,4,opt,name=PubKey,proto3" json:"pubKey"`
	DomainID             []byte   `protobuf:"bytes,5,opt,name=DomainID,proto3" json:"domainID"`
	MemberNumber         uint32   `protobuf:"varint,6,opt,name=MemberNumber,proto3" json:"memberNumber"`
	NodeIDOfMember       []byte   `protobuf:"bytes,7,opt,name=NodeIDOfMember,proto3" json:"nodeIDOfMember"`
	NodeRoleOfMember     uint64   `protobuf:"varint,8,opt,name=NodeRoleOfMember,proto3" json:"nodeRoleOfMember"`
	NodeWeightOfMember   uint64   `protobuf:"varint,9,opt,name=NodeWeightOfMember,proto3" json:"nodeWeightOfMember"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConsensusDomainSelectedMessage) DataBytes 

func (m *ConsensusDomainSelectedMessage) DataBytes() []byte

func (*ConsensusDomainSelectedMessage) Descriptor 

func (*ConsensusDomainSelectedMessage) Descriptor() ([]byte, []int)

func (*ConsensusDomainSelectedMessage) GetChainID 

func (m *ConsensusDomainSelectedMessage) GetChainID() []byte

func (*ConsensusDomainSelectedMessage) GetDomainID 

func (m *ConsensusDomainSelectedMessage) GetDomainID() []byte

func (*ConsensusDomainSelectedMessage) GetMemberNumber 

func (m *ConsensusDomainSelectedMessage) GetMemberNumber() uint32

func (*ConsensusDomainSelectedMessage) GetNodeIDOfMember 

func (m *ConsensusDomainSelectedMessage) GetNodeIDOfMember() []byte

func (*ConsensusDomainSelectedMessage) GetNodeRoleOfMember 

func (m *ConsensusDomainSelectedMessage) GetNodeRoleOfMember() uint64

func (*ConsensusDomainSelectedMessage) GetNodeWeightOfMember 

func (m *ConsensusDomainSelectedMessage) GetNodeWeightOfMember() uint64

func (*ConsensusDomainSelectedMessage) GetPubKey 

func (m *ConsensusDomainSelectedMessage) GetPubKey() []byte

func (*ConsensusDomainSelectedMessage) GetSignature 

func (m *ConsensusDomainSelectedMessage) GetSignature() []byte

func (*ConsensusDomainSelectedMessage) GetVersion 

func (m *ConsensusDomainSelectedMessage) GetVersion() uint32

func (*ConsensusDomainSelectedMessage) Marshal 

func (m *ConsensusDomainSelectedMessage) Marshal() (dAtA []byte, err error)

func (*ConsensusDomainSelectedMessage) MarshalTo 

func (m *ConsensusDomainSelectedMessage) MarshalTo(dAtA []byte) (int, error)

func (*ConsensusDomainSelectedMessage) MarshalToSizedBuffer 

func (m *ConsensusDomainSelectedMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConsensusDomainSelectedMessage) ProtoMessage 

func (*ConsensusDomainSelectedMessage) ProtoMessage()

func (*ConsensusDomainSelectedMessage) Reset 

func (m *ConsensusDomainSelectedMessage) Reset()

func (*ConsensusDomainSelectedMessage) Size 

func (m *ConsensusDomainSelectedMessage) Size() (n int)

func (*ConsensusDomainSelectedMessage) String 

func (m *ConsensusDomainSelectedMessage) String() string

func (*ConsensusDomainSelectedMessage) Unmarshal 

func (m *ConsensusDomainSelectedMessage) Unmarshal(dAtA []byte) error

func (*ConsensusDomainSelectedMessage) XXX_DiscardUnknown 

func (m *ConsensusDomainSelectedMessage) XXX_DiscardUnknown()

func (*ConsensusDomainSelectedMessage) XXX_Marshal 

func (m *ConsensusDomainSelectedMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConsensusDomainSelectedMessage) XXX_Merge 

func (m *ConsensusDomainSelectedMessage) XXX_Merge(src proto.Message)

func (*ConsensusDomainSelectedMessage) XXX_Size 

func (m *ConsensusDomainSelectedMessage) XXX_Size() int

func (*ConsensusDomainSelectedMessage) XXX_Unmarshal 

func (m *ConsensusDomainSelectedMessage) XXX_Unmarshal(b []byte) error

type ConsensusHandler 

type ConsensusHandler interface {
	VerifyBlock(block *tpchaintypes.Block) error

	ProcessCSDomainSelectedMsg(msg *ConsensusDomainSelectedMessage) error

	ProcessPreparePackedMsgExe(msg *PreparePackedMessageExe) error

	ProcessPreparePackedMsgExeIndication(msg *PreparePackedMessageExeIndication) error

	ProcessPreparePackedMsgProp(msg *PreparePackedMessageProp) error

	ProcessPropose(msg *ProposeMessage) error

	ProcessExeResultValidateReq(actorCtx actor.Context, msg *ExeResultValidateReqMessage) error

	ProcessBestPropose(msg *BestProposeMessage) error

	ProcessVote(msg *VoteMessage) error

	ProcessCommit(msg *CommitMessage) error

	ProcessBlockAdded(block *tpchaintypes.Block) error

	ProcessDKGPartPubKey(msg *DKGPartPubKeyMessage) error

	ProcessDKGDeal(msg *DKGDealMessage) error

	ProcessDKGDealResp(msg *DKGDealRespMessage) error

	ProcessDKGFinishedMsg(msg *DKGFinishedMessage) error
}

type ConsensusMessage 

type ConsensusMessage struct {
	MsgType              ConsensusMessage_Type `protobuf:"varint,1,opt,name=MsgType,proto3,enum=proto.ConsensusMessage_Type" json:"msgType"`
	Data                 []byte                `protobuf:"bytes,2,opt,name=Data,proto3" json:"data"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConsensusMessage) Descriptor 

func (*ConsensusMessage) Descriptor() ([]byte, []int)

func (*ConsensusMessage) GetData 

func (m *ConsensusMessage) GetData() []byte

func (*ConsensusMessage) GetMsgType 

func (m *ConsensusMessage) GetMsgType() ConsensusMessage_Type

func (*ConsensusMessage) Marshal 

func (m *ConsensusMessage) Marshal() (dAtA []byte, err error)

func (*ConsensusMessage) MarshalTo 

func (m *ConsensusMessage) MarshalTo(dAtA []byte) (int, error)

func (*ConsensusMessage) MarshalToSizedBuffer 

func (m *ConsensusMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConsensusMessage) ProtoMessage 

func (*ConsensusMessage) ProtoMessage()

func (*ConsensusMessage) Reset 

func (m *ConsensusMessage) Reset()

func (*ConsensusMessage) Size 

func (m *ConsensusMessage) Size() (n int)

func (*ConsensusMessage) String 

func (m *ConsensusMessage) String() string

func (*ConsensusMessage) Unmarshal 

func (m *ConsensusMessage) Unmarshal(dAtA []byte) error

func (*ConsensusMessage) XXX_DiscardUnknown 

func (m *ConsensusMessage) XXX_DiscardUnknown()

func (*ConsensusMessage) XXX_Marshal 

func (m *ConsensusMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConsensusMessage) XXX_Merge 

func (m *ConsensusMessage) XXX_Merge(src proto.Message)

func (*ConsensusMessage) XXX_Size 

func (m *ConsensusMessage) XXX_Size() int

func (*ConsensusMessage) XXX_Unmarshal 

func (m *ConsensusMessage) XXX_Unmarshal(b []byte) error

type ConsensusMessage_Type 

type ConsensusMessage_Type int32
const (
	ConsensusMessage_Unknown          ConsensusMessage_Type = 0
	ConsensusMessage_CSDomainSel      ConsensusMessage_Type = 1
	ConsensusMessage_PrepareExe       ConsensusMessage_Type = 2
	ConsensusMessage_PrepareExeIndic  ConsensusMessage_Type = 3
	ConsensusMessage_PrepareProp      ConsensusMessage_Type = 4
	ConsensusMessage_Propose          ConsensusMessage_Type = 5
	ConsensusMessage_ExeRSValidateReq ConsensusMessage_Type = 6
	ConsensusMessage_BestPropose      ConsensusMessage_Type = 7
	ConsensusMessage_Vote             ConsensusMessage_Type = 8
	ConsensusMessage_Commit           ConsensusMessage_Type = 9
	ConsensusMessage_PartPubKey       ConsensusMessage_Type = 10
	ConsensusMessage_DKGDeal          ConsensusMessage_Type = 11
	ConsensusMessage_DKGDealResp      ConsensusMessage_Type = 12
	ConsensusMessage_DKGFinished      ConsensusMessage_Type = 13
)

func (ConsensusMessage_Type) EnumDescriptor 

func (ConsensusMessage_Type) EnumDescriptor() ([]byte, []int)

func (ConsensusMessage_Type) String 

func (x ConsensusMessage_Type) String() string

type CryptServiceMock 

type CryptServiceMock struct{}

func (*CryptServiceMock) ConvertToPublic 

func (cs *CryptServiceMock) ConvertToPublic(priKey tpcrtypes.PrivateKey) (tpcrtypes.PublicKey, error)

func (*CryptServiceMock) CreateAddress 

func (cs *CryptServiceMock) CreateAddress(pubKey tpcrtypes.PublicKey) (tpcrtypes.Address, error)

func (*CryptServiceMock) CryptType 

func (cs *CryptServiceMock) CryptType() tpcrtypes.CryptType

func (*CryptServiceMock) GeneratePriPubKey 

func (cs *CryptServiceMock) GeneratePriPubKey() (tpcrtypes.PrivateKey, tpcrtypes.PublicKey, error)

func (*CryptServiceMock) GeneratePriPubKeyWithSeed 

func (cs *CryptServiceMock) GeneratePriPubKeyWithSeed(seed []byte) (tpcrtypes.PrivateKey, tpcrtypes.PublicKey, error)

func (*CryptServiceMock) Sign 

func (cs *CryptServiceMock) Sign(priKey tpcrtypes.PrivateKey, msg []byte) (tpcrtypes.Signature, error)

func (*CryptServiceMock) Verify 

func (cs *CryptServiceMock) Verify(addr tpcrtypes.Address, msg []byte, signData tpcrtypes.Signature) (bool, error)

type DKGBLSUpdater 

type DKGBLSUpdater interface {
	// contains filtered or unexported methods
}

type DKGBls 

type DKGBls interface {
	PubKey() ([]byte, error)

	PriShare() ([]byte, error)

	PubShares() ([][]byte, error)

	Sign(msg []byte) ([]byte, []byte, error) //Signature,PubKey

	Verify(msg, sig []byte) error

	VerifyAgg(msg, sig []byte) error

	RecoverSig(msg []byte, sigs [][]byte) ([]byte, error)

	Threshold() int

	Finished() bool
}

func NewDomainConsensusCrypt 

func NewDomainConsensusCrypt(selfNode *tpcmm.NodeInfo, csDomain *tpcmm.NodeDomainInfo) (DKGBls, *tpcmm.NodeDomainMember)

type DKGDealMessage 

type DKGDealMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	TriggerNumber        uint64   `protobuf:"varint,3,opt,name=TriggerNumber,proto3" json:"triggerNumber"`
	Signature            []byte   `protobuf:"bytes,4,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,5,opt,name=PubKey,proto3" json:"pubKey"`
	DealData             []byte   `protobuf:"bytes,6,opt,name=DealData,proto3" json:"dealData"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DKGDealMessage) Descriptor 

func (*DKGDealMessage) Descriptor() ([]byte, []int)

func (*DKGDealMessage) GetChainID 

func (m *DKGDealMessage) GetChainID() []byte

func (*DKGDealMessage) GetDealData 

func (m *DKGDealMessage) GetDealData() []byte

func (*DKGDealMessage) GetPubKey 

func (m *DKGDealMessage) GetPubKey() []byte

func (*DKGDealMessage) GetSignature 

func (m *DKGDealMessage) GetSignature() []byte

func (*DKGDealMessage) GetTriggerNumber 

func (m *DKGDealMessage) GetTriggerNumber() uint64

func (*DKGDealMessage) GetVersion 

func (m *DKGDealMessage) GetVersion() uint32

func (*DKGDealMessage) Marshal 

func (m *DKGDealMessage) Marshal() (dAtA []byte, err error)

func (*DKGDealMessage) MarshalTo 

func (m *DKGDealMessage) MarshalTo(dAtA []byte) (int, error)

func (*DKGDealMessage) MarshalToSizedBuffer 

func (m *DKGDealMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DKGDealMessage) ProtoMessage 

func (*DKGDealMessage) ProtoMessage()

func (*DKGDealMessage) Reset 

func (m *DKGDealMessage) Reset()

func (*DKGDealMessage) Size 

func (m *DKGDealMessage) Size() (n int)

func (*DKGDealMessage) String 

func (m *DKGDealMessage) String() string

func (*DKGDealMessage) Unmarshal 

func (m *DKGDealMessage) Unmarshal(dAtA []byte) error

func (*DKGDealMessage) XXX_DiscardUnknown 

func (m *DKGDealMessage) XXX_DiscardUnknown()

func (*DKGDealMessage) XXX_Marshal 

func (m *DKGDealMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DKGDealMessage) XXX_Merge 

func (m *DKGDealMessage) XXX_Merge(src proto.Message)

func (*DKGDealMessage) XXX_Size 

func (m *DKGDealMessage) XXX_Size() int

func (*DKGDealMessage) XXX_Unmarshal 

func (m *DKGDealMessage) XXX_Unmarshal(b []byte) error

type DKGDealRespMessage 

type DKGDealRespMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	TriggerNumber        uint64   `protobuf:"varint,3,opt,name=TriggerNumber,proto3" json:"triggerNumber"`
	Signature            []byte   `protobuf:"bytes,4,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,5,opt,name=PubKey,proto3" json:"pubKey"`
	RespData             []byte   `protobuf:"bytes,6,opt,name=RespData,proto3" json:"respData"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DKGDealRespMessage) Descriptor 

func (*DKGDealRespMessage) Descriptor() ([]byte, []int)

func (*DKGDealRespMessage) GetChainID 

func (m *DKGDealRespMessage) GetChainID() []byte

func (*DKGDealRespMessage) GetPubKey 

func (m *DKGDealRespMessage) GetPubKey() []byte

func (*DKGDealRespMessage) GetRespData 

func (m *DKGDealRespMessage) GetRespData() []byte

func (*DKGDealRespMessage) GetSignature 

func (m *DKGDealRespMessage) GetSignature() []byte

func (*DKGDealRespMessage) GetTriggerNumber 

func (m *DKGDealRespMessage) GetTriggerNumber() uint64

func (*DKGDealRespMessage) GetVersion 

func (m *DKGDealRespMessage) GetVersion() uint32

func (*DKGDealRespMessage) Marshal 

func (m *DKGDealRespMessage) Marshal() (dAtA []byte, err error)

func (*DKGDealRespMessage) MarshalTo 

func (m *DKGDealRespMessage) MarshalTo(dAtA []byte) (int, error)

func (*DKGDealRespMessage) MarshalToSizedBuffer 

func (m *DKGDealRespMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DKGDealRespMessage) ProtoMessage 

func (*DKGDealRespMessage) ProtoMessage()

func (*DKGDealRespMessage) Reset 

func (m *DKGDealRespMessage) Reset()

func (*DKGDealRespMessage) Size 

func (m *DKGDealRespMessage) Size() (n int)

func (*DKGDealRespMessage) String 

func (m *DKGDealRespMessage) String() string

func (*DKGDealRespMessage) Unmarshal 

func (m *DKGDealRespMessage) Unmarshal(dAtA []byte) error

func (*DKGDealRespMessage) XXX_DiscardUnknown 

func (m *DKGDealRespMessage) XXX_DiscardUnknown()

func (*DKGDealRespMessage) XXX_Marshal 

func (m *DKGDealRespMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DKGDealRespMessage) XXX_Merge 

func (m *DKGDealRespMessage) XXX_Merge(src proto.Message)

func (*DKGDealRespMessage) XXX_Size 

func (m *DKGDealRespMessage) XXX_Size() int

func (*DKGDealRespMessage) XXX_Unmarshal 

func (m *DKGDealRespMessage) XXX_Unmarshal(b []byte) error

type DKGExchangeState 

type DKGExchangeState byte
const (
	DKGExchangeState_Unknown DKGExchangeState = iota
	DKGExchangeState_IDLE
	DKGExchangeState_Exchanging_PartPubKey //Haven't used it at present
	DKGExchangeState_Exchanging_Deal
	DKGExchangeState_Finished
)

func (DKGExchangeState) String 

func (state DKGExchangeState) String() string

func (DKGExchangeState) Value 

func (state DKGExchangeState) Value(stas string) DKGExchangeState

type DKGFinishedMessage 

type DKGFinishedMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	TriggerNumber        uint64   `protobuf:"varint,3,opt,name=TriggerNumber,proto3" json:"triggerNumber"`
	Signature            []byte   `protobuf:"bytes,4,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,5,opt,name=PubKey,proto3" json:"pubKey"`
	NodeID               []byte   `protobuf:"bytes,6,opt,name=NodeID,proto3" json:"nodeID"`
	PubPolyCommit        []byte   `protobuf:"bytes,7,opt,name=PubPolyCommit,proto3" json:"respData"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DKGFinishedMessage) Descriptor 

func (*DKGFinishedMessage) Descriptor() ([]byte, []int)

func (*DKGFinishedMessage) GetChainID 

func (m *DKGFinishedMessage) GetChainID() []byte

func (*DKGFinishedMessage) GetNodeID 

func (m *DKGFinishedMessage) GetNodeID() []byte

func (*DKGFinishedMessage) GetPubKey 

func (m *DKGFinishedMessage) GetPubKey() []byte

func (*DKGFinishedMessage) GetPubPolyCommit 

func (m *DKGFinishedMessage) GetPubPolyCommit() []byte

func (*DKGFinishedMessage) GetSignature 

func (m *DKGFinishedMessage) GetSignature() []byte

func (*DKGFinishedMessage) GetTriggerNumber 

func (m *DKGFinishedMessage) GetTriggerNumber() uint64

func (*DKGFinishedMessage) GetVersion 

func (m *DKGFinishedMessage) GetVersion() uint32

func (*DKGFinishedMessage) Marshal 

func (m *DKGFinishedMessage) Marshal() (dAtA []byte, err error)

func (*DKGFinishedMessage) MarshalTo 

func (m *DKGFinishedMessage) MarshalTo(dAtA []byte) (int, error)

func (*DKGFinishedMessage) MarshalToSizedBuffer 

func (m *DKGFinishedMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DKGFinishedMessage) ProtoMessage 

func (*DKGFinishedMessage) ProtoMessage()

func (*DKGFinishedMessage) Reset 

func (m *DKGFinishedMessage) Reset()

func (*DKGFinishedMessage) Size 

func (m *DKGFinishedMessage) Size() (n int)

func (*DKGFinishedMessage) String 

func (m *DKGFinishedMessage) String() string

func (*DKGFinishedMessage) Unmarshal 

func (m *DKGFinishedMessage) Unmarshal(dAtA []byte) error

func (*DKGFinishedMessage) XXX_DiscardUnknown 

func (m *DKGFinishedMessage) XXX_DiscardUnknown()

func (*DKGFinishedMessage) XXX_Marshal 

func (m *DKGFinishedMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DKGFinishedMessage) XXX_Merge 

func (m *DKGFinishedMessage) XXX_Merge(src proto.Message)

func (*DKGFinishedMessage) XXX_Size 

func (m *DKGFinishedMessage) XXX_Size() int

func (*DKGFinishedMessage) XXX_Unmarshal 

func (m *DKGFinishedMessage) XXX_Unmarshal(b []byte) error

type DKGPartPubKeyMessage 

type DKGPartPubKeyMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	TriggerNumber        uint64   `protobuf:"varint,3,opt,name=TriggerNumber,proto3" json:"triggerNumber"`
	Signature            []byte   `protobuf:"bytes,4,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,5,opt,name=PubKey,proto3" json:"pubKey"`
	PartPubKey           []byte   `protobuf:"bytes,6,opt,name=PartPubKey,proto3" json:"partPubKey"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DKGPartPubKeyMessage) Descriptor 

func (*DKGPartPubKeyMessage) Descriptor() ([]byte, []int)

func (*DKGPartPubKeyMessage) GetChainID 

func (m *DKGPartPubKeyMessage) GetChainID() []byte

func (*DKGPartPubKeyMessage) GetPartPubKey 

func (m *DKGPartPubKeyMessage) GetPartPubKey() []byte

func (*DKGPartPubKeyMessage) GetPubKey 

func (m *DKGPartPubKeyMessage) GetPubKey() []byte

func (*DKGPartPubKeyMessage) GetSignature 

func (m *DKGPartPubKeyMessage) GetSignature() []byte

func (*DKGPartPubKeyMessage) GetTriggerNumber 

func (m *DKGPartPubKeyMessage) GetTriggerNumber() uint64

func (*DKGPartPubKeyMessage) GetVersion 

func (m *DKGPartPubKeyMessage) GetVersion() uint32

func (*DKGPartPubKeyMessage) Marshal 

func (m *DKGPartPubKeyMessage) Marshal() (dAtA []byte, err error)

func (*DKGPartPubKeyMessage) MarshalTo 

func (m *DKGPartPubKeyMessage) MarshalTo(dAtA []byte) (int, error)

func (*DKGPartPubKeyMessage) MarshalToSizedBuffer 

func (m *DKGPartPubKeyMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DKGPartPubKeyMessage) ProtoMessage 

func (*DKGPartPubKeyMessage) ProtoMessage()

func (*DKGPartPubKeyMessage) Reset 

func (m *DKGPartPubKeyMessage) Reset()

func (*DKGPartPubKeyMessage) Size 

func (m *DKGPartPubKeyMessage) Size() (n int)

func (*DKGPartPubKeyMessage) String 

func (m *DKGPartPubKeyMessage) String() string

func (*DKGPartPubKeyMessage) Unmarshal 

func (m *DKGPartPubKeyMessage) Unmarshal(dAtA []byte) error

func (*DKGPartPubKeyMessage) XXX_DiscardUnknown 

func (m *DKGPartPubKeyMessage) XXX_DiscardUnknown()

func (*DKGPartPubKeyMessage) XXX_Marshal 

func (m *DKGPartPubKeyMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DKGPartPubKeyMessage) XXX_Merge 

func (m *DKGPartPubKeyMessage) XXX_Merge(src proto.Message)

func (*DKGPartPubKeyMessage) XXX_Size 

func (m *DKGPartPubKeyMessage) XXX_Size() int

func (*DKGPartPubKeyMessage) XXX_Unmarshal 

func (m *DKGPartPubKeyMessage) XXX_Unmarshal(b []byte) error

type DeliverStrategy 

type DeliverStrategy byte

type EpochService 

type EpochService interface {
	GetActiveExecutorIDs() []string

	GetActiveExecutorIDsOfDomain(domainID string) []string

	GetDomainIDOfExecutor(nodeID string) string

	GetActiveProposerIDs() []string

	GetActiveValidatorIDs() []string

	GetNodeWeight(nodeID string) (uint64, error)

	GetActiveExecutorsTotalWeight() uint64

	GetActiveExecutorsTotalWeightOfDomain(domainID string) uint64

	GetActiveProposersTotalWeight() uint64

	GetActiveValidatorsTotalWeight() uint64

	GetLatestEpoch() *tpcmm.EpochInfo

	SelfSelected() bool

	AddDKGBLSUpdater(updater DKGBLSUpdater)

	UpdateData(log tplog.Logger, ledger ledger.Ledger, csDomainMember []*tpcmm.NodeDomainMember)

	UpdateEpoch(ctx context.Context, newBH *tpchaintypes.BlockHead, compState state.CompositionState) error

	Start(ctx context.Context, latestHeight uint64)
}

func NewEpochService 

func NewEpochService(log tplog.Logger,
	nodeID string,
	stateBuilderType state.CompStateBuilderType,
	epochInterval uint64,
	currentEpoch *tpcmm.EpochInfo,
	dkgStartBeforeEpoch uint64,
	exeScheduler execution.ExecutionScheduler,
	ledger ledger.Ledger,
	deliver messageDeliverI,
	dkgExchange *dkgExchange,
	exeActiveNodeIds []*tpcmm.NodeInfo) EpochService

type EpochServiceMock 

type EpochServiceMock struct{}

func (*EpochServiceMock) GetActiveExecutorIDs 

func (m *EpochServiceMock) GetActiveExecutorIDs() []string

func (*EpochServiceMock) GetActiveExecutorsTotalWeight 

func (m *EpochServiceMock) GetActiveExecutorsTotalWeight() uint64

func (*EpochServiceMock) GetActiveProposerIDs 

func (m *EpochServiceMock) GetActiveProposerIDs() []string

func (*EpochServiceMock) GetActiveProposersTotalWeight 

func (m *EpochServiceMock) GetActiveProposersTotalWeight() uint64

func (*EpochServiceMock) GetActiveValidatorIDs 

func (m *EpochServiceMock) GetActiveValidatorIDs() []string

func (*EpochServiceMock) GetActiveValidatorsTotalWeight 

func (m *EpochServiceMock) GetActiveValidatorsTotalWeight() uint64

func (*EpochServiceMock) GetLatestEpoch 

func (m *EpochServiceMock) GetLatestEpoch() *tpcmm.EpochInfo

func (*EpochServiceMock) GetNodeWeight 

func (m *EpochServiceMock) GetNodeWeight(nodeID string) (uint64, error)

func (*EpochServiceMock) Start 

func (m *EpochServiceMock) Start(ctx context.Context)

type ExeResultValidateReqMessage 

type ExeResultValidateReqMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=Epoch,proto3" json:"epoch"`
	Round                uint64   `protobuf:"varint,4,opt,name=Round,proto3" json:"round"`
	Validator            []byte   `protobuf:"bytes,5,opt,name=Validator,proto3" json:"proposer"`
	Signature            []byte   `protobuf:"bytes,6,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,7,opt,name=PubKey,proto3" json:"pubKey"`
	StateVersion         uint64   `protobuf:"varint,8,opt,name=StateVersion,proto3" json:"stateVersion"`
	TxHashs              [][]byte `protobuf:"bytes,9,rep,name=TxHashs,proto3" json:"txHashs"`
	TxResultHashs        [][]byte `protobuf:"bytes,10,rep,name=TxResultHashs,proto3" json:"txResultHashs"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExeResultValidateReqMessage) Descriptor 

func (*ExeResultValidateReqMessage) Descriptor() ([]byte, []int)

func (*ExeResultValidateReqMessage) GetChainID 

func (m *ExeResultValidateReqMessage) GetChainID() []byte

func (*ExeResultValidateReqMessage) GetEpoch 

func (m *ExeResultValidateReqMessage) GetEpoch() uint64

func (*ExeResultValidateReqMessage) GetPubKey 

func (m *ExeResultValidateReqMessage) GetPubKey() []byte

func (*ExeResultValidateReqMessage) GetRound 

func (m *ExeResultValidateReqMessage) GetRound() uint64

func (*ExeResultValidateReqMessage) GetSignature 

func (m *ExeResultValidateReqMessage) GetSignature() []byte

func (*ExeResultValidateReqMessage) GetStateVersion 

func (m *ExeResultValidateReqMessage) GetStateVersion() uint64

func (*ExeResultValidateReqMessage) GetTxHashs 

func (m *ExeResultValidateReqMessage) GetTxHashs() [][]byte

func (*ExeResultValidateReqMessage) GetTxResultHashs 

func (m *ExeResultValidateReqMessage) GetTxResultHashs() [][]byte

func (*ExeResultValidateReqMessage) GetValidator 

func (m *ExeResultValidateReqMessage) GetValidator() []byte

func (*ExeResultValidateReqMessage) GetVersion 

func (m *ExeResultValidateReqMessage) GetVersion() uint32

func (*ExeResultValidateReqMessage) Marshal 

func (m *ExeResultValidateReqMessage) Marshal() (dAtA []byte, err error)

func (*ExeResultValidateReqMessage) MarshalTo 

func (m *ExeResultValidateReqMessage) MarshalTo(dAtA []byte) (int, error)

func (*ExeResultValidateReqMessage) MarshalToSizedBuffer 

func (m *ExeResultValidateReqMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExeResultValidateReqMessage) ProtoMessage 

func (*ExeResultValidateReqMessage) ProtoMessage()

func (*ExeResultValidateReqMessage) Reset 

func (m *ExeResultValidateReqMessage) Reset()

func (*ExeResultValidateReqMessage) Size 

func (m *ExeResultValidateReqMessage) Size() (n int)

func (*ExeResultValidateReqMessage) String 

func (m *ExeResultValidateReqMessage) String() string

func (*ExeResultValidateReqMessage) TxAndResultHashsData 

func (m *ExeResultValidateReqMessage) TxAndResultHashsData() []byte

func (*ExeResultValidateReqMessage) Unmarshal 

func (m *ExeResultValidateReqMessage) Unmarshal(dAtA []byte) error

func (*ExeResultValidateReqMessage) XXX_DiscardUnknown 

func (m *ExeResultValidateReqMessage) XXX_DiscardUnknown()

func (*ExeResultValidateReqMessage) XXX_Marshal 

func (m *ExeResultValidateReqMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExeResultValidateReqMessage) XXX_Merge 

func (m *ExeResultValidateReqMessage) XXX_Merge(src proto.Message)

func (*ExeResultValidateReqMessage) XXX_Size 

func (m *ExeResultValidateReqMessage) XXX_Size() int

func (*ExeResultValidateReqMessage) XXX_Unmarshal 

func (m *ExeResultValidateReqMessage) XXX_Unmarshal(b []byte) error

type ExeResultValidateRespMessage 

type ExeResultValidateRespMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=Epoch,proto3" json:"epoch"`
	Round                uint64   `protobuf:"varint,4,opt,name=Round,proto3" json:"round"`
	Executor             []byte   `protobuf:"bytes,5,opt,name=Executor,proto3" json:"executor"`
	Signature            []byte   `protobuf:"bytes,6,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,7,opt,name=PubKey,proto3" json:"pubKey"`
	StateVersion         uint64   `protobuf:"varint,8,opt,name=StateVersion,proto3" json:"stateVersion"`
	TxProofs             [][]byte `protobuf:"bytes,9,rep,name=TxProofs,proto3" json:"txProofs"`
	TxResultProofs       [][]byte `protobuf:"bytes,10,rep,name=TxResultProofs,proto3" json:"txResultProofs"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExeResultValidateRespMessage) Descriptor 

func (*ExeResultValidateRespMessage) Descriptor() ([]byte, []int)

func (*ExeResultValidateRespMessage) GetChainID 

func (m *ExeResultValidateRespMessage) GetChainID() []byte

func (*ExeResultValidateRespMessage) GetEpoch 

func (m *ExeResultValidateRespMessage) GetEpoch() uint64

func (*ExeResultValidateRespMessage) GetExecutor 

func (m *ExeResultValidateRespMessage) GetExecutor() []byte

func (*ExeResultValidateRespMessage) GetPubKey 

func (m *ExeResultValidateRespMessage) GetPubKey() []byte

func (*ExeResultValidateRespMessage) GetRound 

func (m *ExeResultValidateRespMessage) GetRound() uint64

func (*ExeResultValidateRespMessage) GetSignature 

func (m *ExeResultValidateRespMessage) GetSignature() []byte

func (*ExeResultValidateRespMessage) GetStateVersion 

func (m *ExeResultValidateRespMessage) GetStateVersion() uint64

func (*ExeResultValidateRespMessage) GetTxProofs 

func (m *ExeResultValidateRespMessage) GetTxProofs() [][]byte

func (*ExeResultValidateRespMessage) GetTxResultProofs 

func (m *ExeResultValidateRespMessage) GetTxResultProofs() [][]byte

func (*ExeResultValidateRespMessage) GetVersion 

func (m *ExeResultValidateRespMessage) GetVersion() uint32

func (*ExeResultValidateRespMessage) Marshal 

func (m *ExeResultValidateRespMessage) Marshal() (dAtA []byte, err error)

func (*ExeResultValidateRespMessage) MarshalTo 

func (m *ExeResultValidateRespMessage) MarshalTo(dAtA []byte) (int, error)

func (*ExeResultValidateRespMessage) MarshalToSizedBuffer 

func (m *ExeResultValidateRespMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExeResultValidateRespMessage) ProtoMessage 

func (*ExeResultValidateRespMessage) ProtoMessage()

func (*ExeResultValidateRespMessage) Reset 

func (m *ExeResultValidateRespMessage) Reset()

func (*ExeResultValidateRespMessage) Size 

func (m *ExeResultValidateRespMessage) Size() (n int)

func (*ExeResultValidateRespMessage) String 

func (m *ExeResultValidateRespMessage) String() string

func (*ExeResultValidateRespMessage) TxAndResultProofsData 

func (m *ExeResultValidateRespMessage) TxAndResultProofsData() []byte

func (*ExeResultValidateRespMessage) Unmarshal 

func (m *ExeResultValidateRespMessage) Unmarshal(dAtA []byte) error

func (*ExeResultValidateRespMessage) XXX_DiscardUnknown 

func (m *ExeResultValidateRespMessage) XXX_DiscardUnknown()

func (*ExeResultValidateRespMessage) XXX_Marshal 

func (m *ExeResultValidateRespMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExeResultValidateRespMessage) XXX_Merge 

func (m *ExeResultValidateRespMessage) XXX_Merge(src proto.Message)

func (*ExeResultValidateRespMessage) XXX_Size 

func (m *ExeResultValidateRespMessage) XXX_Size() int

func (*ExeResultValidateRespMessage) XXX_Unmarshal 

func (m *ExeResultValidateRespMessage) XXX_Unmarshal(b []byte) error

type PreparePackedMessageExe 

type PreparePackedMessageExe struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=Epoch,proto3" json:"epoch"`
	Round                uint64   `protobuf:"varint,4,opt,name=Round,proto3" json:"epoch"`
	Signature            []byte   `protobuf:"bytes,5,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,6,opt,name=PubKey,proto3" json:"pubKey"`
	ParentBlockHash      []byte   `protobuf:"bytes,7,opt,name=ParentBlockHash,proto3" json:"parentBlockHash"`
	VRFProof             []byte   `protobuf:"bytes,8,opt,name=VRFProof,proto3" json:"vrfProof"`
	VRFProofPubKey       []byte   `protobuf:"bytes,9,opt,name=VRFProofPubKey,proto3" json:"vrfProof"`
	DomainID             []byte   `protobuf:"bytes,10,opt,name=DomainID,proto3" json:"domainID"`
	Launcher             []byte   `protobuf:"bytes,11,opt,name=Launcher,proto3" json:"launcher"`
	StateVersion         uint64   `protobuf:"varint,12,opt,name=StateVersion,proto3" json:"stateVersion"`
	TxRoot               []byte   `protobuf:"bytes,13,opt,name=TxRoot,proto3" json:"txRoot"`
	Txs                  [][]byte `protobuf:"bytes,14,rep,name=Txs,proto3" json:"txs"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PreparePackedMessageExe) Descriptor 

func (*PreparePackedMessageExe) Descriptor() ([]byte, []int)

func (*PreparePackedMessageExe) GetChainID 

func (m *PreparePackedMessageExe) GetChainID() []byte

func (*PreparePackedMessageExe) GetDomainID 

func (m *PreparePackedMessageExe) GetDomainID() []byte

func (*PreparePackedMessageExe) GetEpoch 

func (m *PreparePackedMessageExe) GetEpoch() uint64

func (*PreparePackedMessageExe) GetLauncher 

func (m *PreparePackedMessageExe) GetLauncher() []byte

func (*PreparePackedMessageExe) GetParentBlockHash 

func (m *PreparePackedMessageExe) GetParentBlockHash() []byte

func (*PreparePackedMessageExe) GetPubKey 

func (m *PreparePackedMessageExe) GetPubKey() []byte

func (*PreparePackedMessageExe) GetRound 

func (m *PreparePackedMessageExe) GetRound() uint64

func (*PreparePackedMessageExe) GetSignature 

func (m *PreparePackedMessageExe) GetSignature() []byte

func (*PreparePackedMessageExe) GetStateVersion 

func (m *PreparePackedMessageExe) GetStateVersion() uint64

func (*PreparePackedMessageExe) GetTxRoot 

func (m *PreparePackedMessageExe) GetTxRoot() []byte

func (*PreparePackedMessageExe) GetTxs 

func (m *PreparePackedMessageExe) GetTxs() [][]byte

func (*PreparePackedMessageExe) GetVRFProof 

func (m *PreparePackedMessageExe) GetVRFProof() []byte

func (*PreparePackedMessageExe) GetVRFProofPubKey 

func (m *PreparePackedMessageExe) GetVRFProofPubKey() []byte

func (*PreparePackedMessageExe) GetVersion 

func (m *PreparePackedMessageExe) GetVersion() uint32

func (*PreparePackedMessageExe) Marshal 

func (m *PreparePackedMessageExe) Marshal() (dAtA []byte, err error)

func (*PreparePackedMessageExe) MarshalTo 

func (m *PreparePackedMessageExe) MarshalTo(dAtA []byte) (int, error)

func (*PreparePackedMessageExe) MarshalToSizedBuffer 

func (m *PreparePackedMessageExe) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreparePackedMessageExe) ProtoMessage 

func (*PreparePackedMessageExe) ProtoMessage()

func (*PreparePackedMessageExe) Reset 

func (m *PreparePackedMessageExe) Reset()

func (*PreparePackedMessageExe) Size 

func (m *PreparePackedMessageExe) Size() (n int)

func (*PreparePackedMessageExe) String 

func (m *PreparePackedMessageExe) String() string

func (*PreparePackedMessageExe) TxsData 

func (m *PreparePackedMessageExe) TxsData() []byte

func (*PreparePackedMessageExe) Unmarshal 

func (m *PreparePackedMessageExe) Unmarshal(dAtA []byte) error

func (*PreparePackedMessageExe) XXX_DiscardUnknown 

func (m *PreparePackedMessageExe) XXX_DiscardUnknown()

func (*PreparePackedMessageExe) XXX_Marshal 

func (m *PreparePackedMessageExe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PreparePackedMessageExe) XXX_Merge 

func (m *PreparePackedMessageExe) XXX_Merge(src proto.Message)

func (*PreparePackedMessageExe) XXX_Size 

func (m *PreparePackedMessageExe) XXX_Size() int

func (*PreparePackedMessageExe) XXX_Unmarshal 

func (m *PreparePackedMessageExe) XXX_Unmarshal(b []byte) error

type PreparePackedMessageExeIndication 

type PreparePackedMessageExeIndication struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=Epoch,proto3" json:"epoch"`
	Round                uint64   `protobuf:"varint,4,opt,name=Round,proto3" json:"epoch"`
	Signature            []byte   `protobuf:"bytes,5,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,6,opt,name=PubKey,proto3" json:"pubKey"`
	DomainID             []byte   `protobuf:"bytes,7,opt,name=DomainID,proto3" json:"domainID"`
	StateVersion         uint64   `protobuf:"varint,8,opt,name=StateVersion,proto3" json:"stateVersion"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PreparePackedMessageExeIndication) DataBytes 

func (m *PreparePackedMessageExeIndication) DataBytes() []byte

func (*PreparePackedMessageExeIndication) Descriptor 

func (*PreparePackedMessageExeIndication) Descriptor() ([]byte, []int)

func (*PreparePackedMessageExeIndication) GetChainID 

func (m *PreparePackedMessageExeIndication) GetChainID() []byte

func (*PreparePackedMessageExeIndication) GetDomainID 

func (m *PreparePackedMessageExeIndication) GetDomainID() []byte

func (*PreparePackedMessageExeIndication) GetEpoch 

func (m *PreparePackedMessageExeIndication) GetEpoch() uint64

func (*PreparePackedMessageExeIndication) GetPubKey 

func (m *PreparePackedMessageExeIndication) GetPubKey() []byte

func (*PreparePackedMessageExeIndication) GetRound 

func (m *PreparePackedMessageExeIndication) GetRound() uint64

func (*PreparePackedMessageExeIndication) GetSignature 

func (m *PreparePackedMessageExeIndication) GetSignature() []byte

func (*PreparePackedMessageExeIndication) GetStateVersion 

func (m *PreparePackedMessageExeIndication) GetStateVersion() uint64

func (*PreparePackedMessageExeIndication) GetVersion 

func (m *PreparePackedMessageExeIndication) GetVersion() uint32

func (*PreparePackedMessageExeIndication) Marshal 

func (m *PreparePackedMessageExeIndication) Marshal() (dAtA []byte, err error)

func (*PreparePackedMessageExeIndication) MarshalTo 

func (m *PreparePackedMessageExeIndication) MarshalTo(dAtA []byte) (int, error)

func (*PreparePackedMessageExeIndication) MarshalToSizedBuffer 

func (m *PreparePackedMessageExeIndication) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreparePackedMessageExeIndication) ProtoMessage 

func (*PreparePackedMessageExeIndication) ProtoMessage()

func (*PreparePackedMessageExeIndication) Reset 

func (m *PreparePackedMessageExeIndication) Reset()

func (*PreparePackedMessageExeIndication) Size 

func (m *PreparePackedMessageExeIndication) Size() (n int)

func (*PreparePackedMessageExeIndication) String 

func (m *PreparePackedMessageExeIndication) String() string

func (*PreparePackedMessageExeIndication) Unmarshal 

func (m *PreparePackedMessageExeIndication) Unmarshal(dAtA []byte) error

func (*PreparePackedMessageExeIndication) XXX_DiscardUnknown 

func (m *PreparePackedMessageExeIndication) XXX_DiscardUnknown()

func (*PreparePackedMessageExeIndication) XXX_Marshal 

func (m *PreparePackedMessageExeIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PreparePackedMessageExeIndication) XXX_Merge 

func (m *PreparePackedMessageExeIndication) XXX_Merge(src proto.Message)

func (*PreparePackedMessageExeIndication) XXX_Size 

func (m *PreparePackedMessageExeIndication) XXX_Size() int

func (*PreparePackedMessageExeIndication) XXX_Unmarshal 

func (m *PreparePackedMessageExeIndication) XXX_Unmarshal(b []byte) error

type PreparePackedMessageProp 

type PreparePackedMessageProp struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=Epoch,proto3" json:"epoch"`
	Round                uint64   `protobuf:"varint,4,opt,name=Round,proto3" json:"round"`
	Signature            []byte   `protobuf:"bytes,5,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,6,opt,name=PubKey,proto3" json:"pubKey"`
	ParentBlockHash      []byte   `protobuf:"bytes,7,opt,name=ParentBlockHash,proto3" json:"parentBlockHash"`
	VRFProof             []byte   `protobuf:"bytes,8,opt,name=VRFProof,proto3" json:"vrfProof"`
	VRFProofPubKey       []byte   `protobuf:"bytes,9,opt,name=VRFProofPubKey,proto3" json:"vrfProofPubKey"`
	DomainID             []byte   `protobuf:"bytes,10,opt,name=DomainID,proto3" json:"domainID"`
	Launcher             []byte   `protobuf:"bytes,11,opt,name=Launcher,proto3" json:"launcher"`
	StateVersion         uint64   `protobuf:"varint,12,opt,name=StateVersion,proto3" json:"stateVersion"`
	TxRoot               []byte   `protobuf:"bytes,13,opt,name=TxRoot,proto3" json:"txRoot"`
	TxResultRoot         []byte   `protobuf:"bytes,14,opt,name=TxResultRoot,proto3" json:"txResultRoot"`
	TxHashs              [][]byte `protobuf:"bytes,15,rep,name=TxHashs,proto3" json:"txHashs"`
	TxResultHashs        [][]byte `protobuf:"bytes,16,rep,name=TxResultHashs,proto3" json:"txResultHashs"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PreparePackedMessageProp) Descriptor 

func (*PreparePackedMessageProp) Descriptor() ([]byte, []int)

func (*PreparePackedMessageProp) GetChainID 

func (m *PreparePackedMessageProp) GetChainID() []byte

func (*PreparePackedMessageProp) GetDomainID 

func (m *PreparePackedMessageProp) GetDomainID() []byte

func (*PreparePackedMessageProp) GetEpoch 

func (m *PreparePackedMessageProp) GetEpoch() uint64

func (*PreparePackedMessageProp) GetLauncher 

func (m *PreparePackedMessageProp) GetLauncher() []byte

func (*PreparePackedMessageProp) GetParentBlockHash 

func (m *PreparePackedMessageProp) GetParentBlockHash() []byte

func (*PreparePackedMessageProp) GetPubKey 

func (m *PreparePackedMessageProp) GetPubKey() []byte

func (*PreparePackedMessageProp) GetRound 

func (m *PreparePackedMessageProp) GetRound() uint64

func (*PreparePackedMessageProp) GetSignature 

func (m *PreparePackedMessageProp) GetSignature() []byte

func (*PreparePackedMessageProp) GetStateVersion 

func (m *PreparePackedMessageProp) GetStateVersion() uint64

func (*PreparePackedMessageProp) GetTxHashs 

func (m *PreparePackedMessageProp) GetTxHashs() [][]byte

func (*PreparePackedMessageProp) GetTxResultHashs 

func (m *PreparePackedMessageProp) GetTxResultHashs() [][]byte

func (*PreparePackedMessageProp) GetTxResultRoot 

func (m *PreparePackedMessageProp) GetTxResultRoot() []byte

func (*PreparePackedMessageProp) GetTxRoot 

func (m *PreparePackedMessageProp) GetTxRoot() []byte

func (*PreparePackedMessageProp) GetVRFProof 

func (m *PreparePackedMessageProp) GetVRFProof() []byte

func (*PreparePackedMessageProp) GetVRFProofPubKey 

func (m *PreparePackedMessageProp) GetVRFProofPubKey() []byte

func (*PreparePackedMessageProp) GetVersion 

func (m *PreparePackedMessageProp) GetVersion() uint32

func (*PreparePackedMessageProp) Marshal 

func (m *PreparePackedMessageProp) Marshal() (dAtA []byte, err error)

func (*PreparePackedMessageProp) MarshalTo 

func (m *PreparePackedMessageProp) MarshalTo(dAtA []byte) (int, error)

func (*PreparePackedMessageProp) MarshalToSizedBuffer 

func (m *PreparePackedMessageProp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreparePackedMessageProp) ProtoMessage 

func (*PreparePackedMessageProp) ProtoMessage()

func (*PreparePackedMessageProp) Reset 

func (m *PreparePackedMessageProp) Reset()

func (*PreparePackedMessageProp) Size 

func (m *PreparePackedMessageProp) Size() (n int)

func (*PreparePackedMessageProp) String 

func (m *PreparePackedMessageProp) String() string

func (*PreparePackedMessageProp) TxHashsData 

func (m *PreparePackedMessageProp) TxHashsData() []byte

func (*PreparePackedMessageProp) Unmarshal 

func (m *PreparePackedMessageProp) Unmarshal(dAtA []byte) error

func (*PreparePackedMessageProp) XXX_DiscardUnknown 

func (m *PreparePackedMessageProp) XXX_DiscardUnknown()

func (*PreparePackedMessageProp) XXX_Marshal 

func (m *PreparePackedMessageProp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PreparePackedMessageProp) XXX_Merge 

func (m *PreparePackedMessageProp) XXX_Merge(src proto.Message)

func (*PreparePackedMessageProp) XXX_Size 

func (m *PreparePackedMessageProp) XXX_Size() int

func (*PreparePackedMessageProp) XXX_Unmarshal 

func (m *PreparePackedMessageProp) XXX_Unmarshal(b []byte) error

type PreparePackedMessagePropMap 

type PreparePackedMessagePropMap struct {
	StateVersion uint64
	PPMProps     map[string]*PreparePackedMessageProp //domainID->PreparePackedMessageProp
}

type PropData 

type PropData struct {
	Version              uint32   `protobuf:"varint,1,opt,name=Version,proto3" json:"version"`
	DomainID             []byte   `protobuf:"bytes,2,opt,name=DomainID,proto3" json:"domainID"`
	TxHashs              [][]byte `protobuf:"bytes,3,rep,name=TxHashs,proto3" json:"txHashs"`
	TxResultHashs        [][]byte `protobuf:"bytes,4,rep,name=TxResultHashs,proto3" json:"txResultHashs"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PropData) Descriptor 

func (*PropData) Descriptor() ([]byte, []int)

func (*PropData) GetDomainID 

func (m *PropData) GetDomainID() []byte

func (*PropData) GetTxHashs 

func (m *PropData) GetTxHashs() [][]byte

func (*PropData) GetTxResultHashs 

func (m *PropData) GetTxResultHashs() [][]byte

func (*PropData) GetVersion 

func (m *PropData) GetVersion() uint32

func (*PropData) Marshal 

func (m *PropData) Marshal() (dAtA []byte, err error)

func (*PropData) MarshalTo 

func (m *PropData) MarshalTo(dAtA []byte) (int, error)

func (*PropData) MarshalToSizedBuffer 

func (m *PropData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PropData) ProtoMessage 

func (*PropData) ProtoMessage()

func (*PropData) Reset 

func (m *PropData) Reset()

func (*PropData) Size 

func (m *PropData) Size() (n int)

func (*PropData) String 

func (m *PropData) String() string

func (*PropData) TxResultRoot 

func (p *PropData) TxResultRoot() []byte

func (*PropData) TxRoot 

func (p *PropData) TxRoot() []byte

func (*PropData) Unmarshal 

func (m *PropData) Unmarshal(dAtA []byte) error

func (*PropData) XXX_DiscardUnknown 

func (m *PropData) XXX_DiscardUnknown()

func (*PropData) XXX_Marshal 

func (m *PropData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PropData) XXX_Merge 

func (m *PropData) XXX_Merge(src proto.Message)

func (*PropData) XXX_Size 

func (m *PropData) XXX_Size() int

func (*PropData) XXX_Unmarshal 

func (m *PropData) XXX_Unmarshal(b []byte) error

type ProposeMessage 

type ProposeMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=Epoch,proto3" json:"epoch"`
	Round                uint64   `protobuf:"varint,4,opt,name=Round,proto3" json:"round"`
	Signature            []byte   `protobuf:"bytes,5,opt,name=Signature,proto3" json:"signature"`
	PubKey               []byte   `protobuf:"bytes,6,opt,name=PubKey,proto3" json:"pubKey"`
	StateVersion         uint64   `protobuf:"varint,7,opt,name=StateVersion,proto3" json:"stateVersion"`
	MaxPri               []byte   `protobuf:"bytes,8,opt,name=MaxPri,proto3" json:"maxPri"`
	Proposer             []byte   `protobuf:"bytes,9,opt,name=Proposer,proto3" json:"proposer"`
	PropDatas            [][]byte `protobuf:"bytes,10,rep,name=PropDatas,proto3" json:"propDatas"`
	BlockHead            []byte   `protobuf:"bytes,11,opt,name=BlockHead,proto3" json:"blockHead"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProposeMessage) BlockHeadInfo 

func (m *ProposeMessage) BlockHeadInfo() (*tpchaintypes.BlockHead, error)

func (*ProposeMessage) Descriptor 

func (*ProposeMessage) Descriptor() ([]byte, []int)

func (*ProposeMessage) GetBlockHead 

func (m *ProposeMessage) GetBlockHead() []byte

func (*ProposeMessage) GetChainID 

func (m *ProposeMessage) GetChainID() []byte

func (*ProposeMessage) GetEpoch 

func (m *ProposeMessage) GetEpoch() uint64

func (*ProposeMessage) GetMaxPri 

func (m *ProposeMessage) GetMaxPri() []byte

func (*ProposeMessage) GetPropDatas 

func (m *ProposeMessage) GetPropDatas() [][]byte

func (*ProposeMessage) GetProposer 

func (m *ProposeMessage) GetProposer() []byte

func (*ProposeMessage) GetPubKey 

func (m *ProposeMessage) GetPubKey() []byte

func (*ProposeMessage) GetRound 

func (m *ProposeMessage) GetRound() uint64

func (*ProposeMessage) GetSignature 

func (m *ProposeMessage) GetSignature() []byte

func (*ProposeMessage) GetStateVersion 

func (m *ProposeMessage) GetStateVersion() uint64

func (*ProposeMessage) GetVersion 

func (m *ProposeMessage) GetVersion() uint32

func (*ProposeMessage) Marshal 

func (m *ProposeMessage) Marshal() (dAtA []byte, err error)

func (*ProposeMessage) MarshalTo 

func (m *ProposeMessage) MarshalTo(dAtA []byte) (int, error)

func (*ProposeMessage) MarshalToSizedBuffer 

func (m *ProposeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProposeMessage) ProtoMessage 

func (*ProposeMessage) ProtoMessage()

func (*ProposeMessage) Reset 

func (m *ProposeMessage) Reset()

func (*ProposeMessage) Size 

func (m *ProposeMessage) Size() (n int)

func (*ProposeMessage) String 

func (m *ProposeMessage) String() string

func (*ProposeMessage) Unmarshal 

func (m *ProposeMessage) Unmarshal(dAtA []byte) error

func (*ProposeMessage) XXX_DiscardUnknown 

func (m *ProposeMessage) XXX_DiscardUnknown()

func (*ProposeMessage) XXX_Marshal 

func (m *ProposeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProposeMessage) XXX_Merge 

func (m *ProposeMessage) XXX_Merge(src proto.Message)

func (*ProposeMessage) XXX_Size 

func (m *ProposeMessage) XXX_Size() int

func (*ProposeMessage) XXX_Unmarshal 

func (m *ProposeMessage) XXX_Unmarshal(b []byte) error

type RoundInfo 

type RoundInfo struct {
	Epoch        uint64
	LastRoundNum uint64
	CurRoundNum  uint64
	Proof        *tpchaintypes.ConsensusProof
}

type Statistics 

type Statistics interface {
	MailboxStarted()
	MessagePosted(message interface{})
	MessageReceived(message interface{})
	MailboxEmpty()
}

type TestCacheData 

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

type VoteMessage 

type VoteMessage struct {
	ChainID              []byte   `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"chainID"`
	Version              uint32   `protobuf:"varint,2,opt,name=Version,proto3" json:"version"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=Epoch,proto3" json:"epoch"`
	Round                uint64   `protobuf:"varint,4,opt,name=Round,proto3" json:"round"`
	Signature            []byte   `protobuf:"bytes,5,opt,name=Signature,proto3" json:"signature"`
	Voter                []byte   `protobuf:"bytes,6,opt,name=Voter,proto3" json:"voter"`
	PubKey               []byte   `protobuf:"bytes,7,opt,name=PubKey,proto3" json:"pubKey"`
	StateVersion         uint64   `protobuf:"varint,8,opt,name=StateVersion,proto3" json:"stateVersion"`
	BlockHead            []byte   `protobuf:"bytes,9,opt,name=BlockHead,proto3" json:"blockHead"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VoteMessage) Descriptor 

func (*VoteMessage) Descriptor() ([]byte, []int)

func (*VoteMessage) GetBlockHead 

func (m *VoteMessage) GetBlockHead() []byte

func (*VoteMessage) GetChainID 

func (m *VoteMessage) GetChainID() []byte

func (*VoteMessage) GetEpoch 

func (m *VoteMessage) GetEpoch() uint64

func (*VoteMessage) GetPubKey 

func (m *VoteMessage) GetPubKey() []byte

func (*VoteMessage) GetRound 

func (m *VoteMessage) GetRound() uint64

func (*VoteMessage) GetSignature 

func (m *VoteMessage) GetSignature() []byte

func (*VoteMessage) GetStateVersion 

func (m *VoteMessage) GetStateVersion() uint64

func (*VoteMessage) GetVersion 

func (m *VoteMessage) GetVersion() uint32

func (*VoteMessage) GetVoter 

func (m *VoteMessage) GetVoter() []byte

func (*VoteMessage) Marshal 

func (m *VoteMessage) Marshal() (dAtA []byte, err error)

func (*VoteMessage) MarshalTo 

func (m *VoteMessage) MarshalTo(dAtA []byte) (int, error)

func (*VoteMessage) MarshalToSizedBuffer 

func (m *VoteMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VoteMessage) ProtoMessage 

func (*VoteMessage) ProtoMessage()

func (*VoteMessage) Reset 

func (m *VoteMessage) Reset()

func (*VoteMessage) Size 

func (m *VoteMessage) Size() (n int)

func (*VoteMessage) String 

func (m *VoteMessage) String() string

func (*VoteMessage) Unmarshal 

func (m *VoteMessage) Unmarshal(dAtA []byte) error

func (*VoteMessage) XXX_DiscardUnknown 

func (m *VoteMessage) XXX_DiscardUnknown()

func (*VoteMessage) XXX_Marshal 

func (m *VoteMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VoteMessage) XXX_Merge 

func (m *VoteMessage) XXX_Merge(src proto.Message)

func (*VoteMessage) XXX_Size 

func (m *VoteMessage) XXX_Size() int

func (*VoteMessage) XXX_Unmarshal 

func (m *VoteMessage) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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