core

package

Go to main page

Versions in this module

v0

v0.7.1

Nov 27, 2020

v0.7.0

Nov 6, 2020

Changes in this version

+ const MaxSizeBacklogUnchecked

type Backend

+ KnownMsgHash func() []common.Hash

+ RemoveMessageFromLocalCache func(payload []byte)

type Message

+ func (m *Message) Validate(validateFn func(*types.Header, []byte, []byte) (common.Address, error), ...) (*types.CommitteeMember, error)

type MockBackend

+ func (m *MockBackend) KnownMsgHash() []common.Hash

+ func (m *MockBackend) RemoveMessageFromLocalCache(payload []byte)

type MockBackendMockRecorder

+ func (mr *MockBackendMockRecorder) KnownMsgHash() *gomock.Call

+ func (mr *MockBackendMockRecorder) RemoveMessageFromLocalCache(payload interface{}) *gomock.Call

type MockTendermint

+ func (m *MockTendermint) CoreState() TendermintState

type MockTendermintMockRecorder

+ func (mr *MockTendermintMockRecorder) CoreState() *gomock.Call

+ type MsgForDump struct

+ Hash common.Hash

+ Height *big.Int

+ Power uint64

+ Round int64

type Proposal

+ func (p *Proposal) String() string

+ type RoundState struct

+ PrecommitState []VoteState

+ PrevoteState []VoteState

+ Proposal common.Hash

+ Round int64

type Tendermint

+ CoreState func() TendermintState

+ type TendermintState struct

+ BacklogMessages []*MsgForDump

+ BlockPeriod uint64

+ Client common.Address

+ Committee types.Committee

+ CurHeightMessages []*MsgForDump

+ Height *big.Int

+ IsProposer bool

+ KnownMsgHash []common.Hash

+ LockedRound int64

+ LockedValue *common.Hash

+ PrecommitTimerStarted bool

+ PrevoteTimerStarted bool

+ Proposal *common.Hash

+ ProposeTimerStarted bool

+ Proposer common.Address

+ ProposerPolicy uint64

+ QuorumVotePower uint64

+ Round int64

+ RoundStates []RoundState

+ SentPrecommit bool

+ SentPrevote bool

+ SentProposal bool

+ SetValidRoundAndValue bool

+ Step uint64

+ UncheckedMsgs []*MsgForDump

+ ValidRound int64

+ ValidValue *common.Hash

+ type VoteState struct

+ ProposalVerified bool

+ Value common.Hash

+ VotePower uint64

v0.5.0

Jul 10, 2020

Changes in this version

+ var ErrEmptyCommitteeSet = errors.New("committee set can't be empty")

type Backend

+ BlockChain func() *ethcore.BlockChain

+ SetBlockchain func(bc *ethcore.BlockChain)

type MockBackend

+ func (m *MockBackend) BlockChain() *ethcore.BlockChain

+ func (m *MockBackend) SetBlockchain(bc *ethcore.BlockChain)

type MockBackendMockRecorder

+ func (mr *MockBackendMockRecorder) BlockChain() *gomock.Call

+ func (mr *MockBackendMockRecorder) SetBlockchain(bc interface{}) *gomock.Call

+ type MockTendermint struct

+ func NewMockTendermint(ctrl *gomock.Controller) *MockTendermint

+ func (m *MockTendermint) EXPECT() *MockTendermintMockRecorder

+ func (m *MockTendermint) GetCurrentHeightMessages() []*Message

+ func (m *MockTendermint) Start(ctx context.Context, contract *autonity.Contract)

+ func (m *MockTendermint) Stop()

+ type MockTendermintMockRecorder struct

+ func (mr *MockTendermintMockRecorder) GetCurrentHeightMessages() *gomock.Call

+ func (mr *MockTendermintMockRecorder) Start(ctx, contract interface{}) *gomock.Call

+ func (mr *MockTendermintMockRecorder) Stop() *gomock.Call

+ type Tendermint interface

+ GetCurrentHeightMessages func() []*Message

+ Start func(ctx context.Context, contract *autonity.Contract)

+ Stop func()

v0.4.1

Aug 4, 2020

v0.4.0

Apr 2, 2020

Changes in this version

+ const MaxRound

+ func NewRoundMessages() *roundMessages

type Backend

+ AddSeal func(block *types.Block) (*types.Block, error)

+ Committee func(number uint64) (committee.Set, error)

+ type Changes struct

+ func NewChanges() Changes

+ type ConsensusMsg interface

+ GetHeight func() *big.Int

+ GetRound func() int64

type Message

+ func (m *Message) GetPower() uint64

+ func (m *Message) Height() (*big.Int, error)

+ func (m *Message) Round() (int64, error)

type MockBackend

+ func (m *MockBackend) AddSeal(block *types.Block) (*types.Block, error)

+ func (m *MockBackend) Committee(number uint64) (committee.Set, error)

type MockBackendMockRecorder

+ func (mr *MockBackendMockRecorder) AddSeal(block interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Committee(number interface{}) *gomock.Call

+ type Modifier interface

+ ModifyHeader func(header *types.Header) *types.Header

+ type ModifyCommitteeEngine struct

+ func NewAddValidatorCore(c consensus.Engine, changedValidators Changes) *ModifyCommitteeEngine

+ func NewRemoveValidatorCore(c consensus.Engine, changedValidators Changes) *ModifyCommitteeEngine

+ func NewReplaceValidatorCore(c consensus.Engine, changedValidators Changes) *ModifyCommitteeEngine

+ func (*ModifyCommitteeEngine) VerifyHeader(_ consensus.ChainReader, _ *types.Header, _ bool) error

+ func (c *ModifyCommitteeEngine) FinalizeAndAssemble(chain consensus.ChainReader, header *types.Header, state *state.StateDB, ...) (*types.Block, error)

+ func (c ModifyCommitteeEngine) APIs(chain consensus.ChainReader) []rpc.API

+ func (c ModifyCommitteeEngine) Author(header *types.Header) (common.Address, error)

+ func (c ModifyCommitteeEngine) CalcDifficulty(chain consensus.ChainReader, time uint64, parent *types.Header) *big.Int

+ func (c ModifyCommitteeEngine) Close() error

+ func (c ModifyCommitteeEngine) CommitteeSet() committee.Set

+ func (c ModifyCommitteeEngine) Finalize(chain consensus.ChainReader, header *types.Header, state *state.StateDB, ...) (types.Committee, *types.Receipt, error)

+ func (c ModifyCommitteeEngine) GetCurrentHeightMessages() []*Message

+ func (c ModifyCommitteeEngine) HandleMsg(address common.Address, data p2p.Msg) (bool, error)

+ func (c ModifyCommitteeEngine) Height() *big.Int

+ func (c ModifyCommitteeEngine) IsMember(address common.Address) bool

+ func (c ModifyCommitteeEngine) NewChainHead() error

+ func (c ModifyCommitteeEngine) Prepare(chain consensus.ChainReader, header *types.Header) error

+ func (c ModifyCommitteeEngine) Protocol() (protocolName string, extraMsgCodes uint64)

+ func (c ModifyCommitteeEngine) ResetPeerCache(address common.Address)

+ func (c ModifyCommitteeEngine) Round() int64

+ func (c ModifyCommitteeEngine) Seal(chain consensus.ChainReader, block *types.Block, results chan<- *types.Block, ...) error

+ func (c ModifyCommitteeEngine) SealHash(header *types.Header) common.Hash

+ func (c ModifyCommitteeEngine) SetBroadcaster(b consensus.Broadcaster)

+ func (c ModifyCommitteeEngine) Start(ctx context.Context, chain consensus.ChainReader, ...) error

+ func (c ModifyCommitteeEngine) Stop() error

+ func (c ModifyCommitteeEngine) SyncPeer(address common.Address)

+ func (c ModifyCommitteeEngine) VerifyHeaders(chain consensus.ChainReader, headers []*types.Header, seals []bool) (chan<- struct{}, <-chan error)

+ func (c ModifyCommitteeEngine) VerifySeal(chain consensus.ChainReader, header *types.Header) error

+ func (c ModifyCommitteeEngine) VerifyUncles(chain consensus.ChainReader, block *types.Block) error

type Proposal

+ func (p *Proposal) GetHeight() *big.Int

+ func (p *Proposal) GetRound() int64

+ type VerifySelfProposalAlwaysTrueBackend struct

+ func NewChangeValidatorBackend(t *testing.T, basicCore Backend, brokenValidators Changes, ...) *VerifySelfProposalAlwaysTrueBackend

+ func (b *VerifySelfProposalAlwaysTrueBackend) GetOriginal() Backend

+ func (b *VerifySelfProposalAlwaysTrueBackend) VerifyHeader(chain consensus.ChainReader, header *types.Header, seal bool) error

+ func (b *VerifySelfProposalAlwaysTrueBackend) VerifyProposal(block types.Block) (time.Duration, error)

type Vote

+ func (sub *Vote) GetHeight() *big.Int

+ func (sub *Vote) GetRound() int64

v0.3.0

Nov 15, 2019

Changes in this version

type Backend

+ AskSync func(set validator.Set)

+ GetContractABI func() string

+ GetContractAddress func() common.Address

+ HandleUnhandledMsgs func(ctx context.Context)

+ WhiteList func() []string

type MockBackend

+ func (m *MockBackend) AskSync(set validator.Set)

+ func (m *MockBackend) GetContractABI() string

+ func (m *MockBackend) GetContractAddress() common.Address

+ func (m *MockBackend) HandleUnhandledMsgs(ctx context.Context)

+ func (m *MockBackend) WhiteList() []string

type MockBackendMockRecorder

+ func (mr *MockBackendMockRecorder) AskSync(set interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) GetContractABI() *gomock.Call

+ func (mr *MockBackendMockRecorder) GetContractAddress() *gomock.Call

+ func (mr *MockBackendMockRecorder) HandleUnhandledMsgs(ctx interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) WhiteList() *gomock.Call

v0.2.1

Sep 30, 2019

v0.2.0-rc

Sep 27, 2019

v0.1.6

Sep 13, 2019

Changes in this version

+ var ErrUnauthorizedAddress = errors.New("unauthorized address")

+ type Backend interface

+ Address func() common.Address

+ Broadcast func(ctx context.Context, valSet validator.Set, payload []byte) error

+ CheckSignature func(data []byte, addr common.Address, sig []byte) error

+ Commit func(proposalBlock types.Block, seals [][]byte) error

+ GetProposer func(number uint64) common.Address

+ Gossip func(ctx context.Context, valSet validator.Set, payload []byte)

+ HasBadProposal func(hash common.Hash) bool

+ LastCommittedProposal func() (*types.Block, common.Address)

+ Post func(ev interface{})

+ ResetPeerCache func(address common.Address)

+ SetProposedBlockHash func(hash common.Hash)

+ Sign func([]byte) ([]byte, error)

+ Start func(ctx context.Context, chain consensus.ChainReader, ...) error

+ Subscribe func(types ...interface{}) *event.TypeMuxSubscription

+ SyncPeer func(address common.Address, messages []*Message)

+ Validators func(number uint64) validator.Set

+ VerifyProposal func(types.Block) (time.Duration, error)

+ type Message struct

+ Address common.Address

+ Code uint64

+ CommittedSeal []byte

+ Msg []byte

+ Signature []byte

+ func (m *Message) Decode(val interface{}) error

+ func (m *Message) DecodeRLP(s *rlp.Stream) error

+ func (m *Message) EncodeRLP(w io.Writer) error

+ func (m *Message) FromPayload(b []byte, valSet validator.Set, ...) (*validator.Validator, error)

+ func (m *Message) GetCode() uint64

+ func (m *Message) GetSignature() []byte

+ func (m *Message) Payload() ([]byte, error)

+ func (m *Message) PayloadNoSig() ([]byte, error)

+ func (m *Message) String() string

+ type MockBackend struct

+ func NewMockBackend(ctrl *gomock.Controller) *MockBackend

+ func (m *MockBackend) APIs(chain consensus.ChainReader) []rpc.API

+ func (m *MockBackend) Address() common.Address

+ func (m *MockBackend) Author(header *types.Header) (common.Address, error)

+ func (m *MockBackend) Broadcast(ctx context.Context, valSet validator.Set, payload []byte) error

+ func (m *MockBackend) CalcDifficulty(chain consensus.ChainReader, time uint64, parent *types.Header) *big.Int

+ func (m *MockBackend) CheckSignature(data []byte, addr common.Address, sig []byte) error

+ func (m *MockBackend) Close() error

+ func (m *MockBackend) Commit(proposalBlock types.Block, seals [][]byte) error

+ func (m *MockBackend) EXPECT() *MockBackendMockRecorder

+ func (m *MockBackend) Finalize(chain consensus.ChainReader, header *types.Header, state *state.StateDB, ...)

+ func (m *MockBackend) FinalizeAndAssemble(chain consensus.ChainReader, header *types.Header, state *state.StateDB, ...) (*types.Block, error)

+ func (m *MockBackend) GetProposer(number uint64) common.Address

+ func (m *MockBackend) Gossip(ctx context.Context, valSet validator.Set, payload []byte)

+ func (m *MockBackend) HandleMsg(address common.Address, data p2p.Msg) (bool, error)

+ func (m *MockBackend) HasBadProposal(hash common.Hash) bool

+ func (m *MockBackend) LastCommittedProposal() (*types.Block, common.Address)

+ func (m *MockBackend) NewChainHead() error

+ func (m *MockBackend) Post(ev interface{})

+ func (m *MockBackend) Prepare(chain consensus.ChainReader, header *types.Header) error

+ func (m *MockBackend) Protocol() (string, uint64)

+ func (m *MockBackend) ResetPeerCache(address common.Address)

+ func (m *MockBackend) Seal(chain consensus.ChainReader, block *types.Block, results chan<- *types.Block, ...) error

+ func (m *MockBackend) SealHash(header *types.Header) common.Hash

+ func (m *MockBackend) SetBroadcaster(arg0 consensus.Broadcaster)

+ func (m *MockBackend) SetProposedBlockHash(hash common.Hash)

+ func (m *MockBackend) Sign(arg0 []byte) ([]byte, error)

+ func (m *MockBackend) Start(ctx context.Context, chain consensus.ChainReader, ...) error

+ func (m *MockBackend) Subscribe(types ...interface{}) *event.TypeMuxSubscription

+ func (m *MockBackend) SyncPeer(address common.Address, messages []*Message)

+ func (m *MockBackend) Validators(number uint64) validator.Set

+ func (m *MockBackend) VerifyHeader(chain consensus.ChainReader, header *types.Header, seal bool) error

+ func (m *MockBackend) VerifyHeaders(chain consensus.ChainReader, headers []*types.Header, seals []bool) (chan<- struct{}, <-chan error)

+ func (m *MockBackend) VerifyProposal(arg0 types.Block) (time.Duration, error)

+ func (m *MockBackend) VerifySeal(chain consensus.ChainReader, header *types.Header) error

+ func (m *MockBackend) VerifyUncles(chain consensus.ChainReader, block *types.Block) error

+ type MockBackendMockRecorder struct

+ func (mr *MockBackendMockRecorder) APIs(chain interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Address() *gomock.Call

+ func (mr *MockBackendMockRecorder) Author(header interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Broadcast(ctx, valSet, payload interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) CalcDifficulty(chain, time, parent interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) CheckSignature(data, addr, sig interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Close() *gomock.Call

+ func (mr *MockBackendMockRecorder) Commit(proposalBlock, seals interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Finalize(chain, header, state, txs, uncles interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) FinalizeAndAssemble(chain, header, state, txs, uncles, receipts interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) GetProposer(number interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Gossip(ctx, valSet, payload interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) HandleMsg(address, data interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) HasBadProposal(hash interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) LastCommittedProposal() *gomock.Call

+ func (mr *MockBackendMockRecorder) NewChainHead() *gomock.Call

+ func (mr *MockBackendMockRecorder) Post(ev interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Prepare(chain, header interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Protocol() *gomock.Call

+ func (mr *MockBackendMockRecorder) ResetPeerCache(address interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Seal(chain, block, results, stop interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) SealHash(header interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) SetBroadcaster(arg0 interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) SetProposedBlockHash(hash interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Sign(arg0 interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Start(ctx, chain, currentBlock, hasBadBlock interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Subscribe(types ...interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) SyncPeer(address, messages interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) Validators(number interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) VerifyHeader(chain, header, seal interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) VerifyHeaders(chain, headers, seals interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) VerifyProposal(arg0 interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) VerifySeal(chain, header interface{}) *gomock.Call

+ func (mr *MockBackendMockRecorder) VerifyUncles(chain, block interface{}) *gomock.Call

+ type Proposal struct

+ Height *big.Int

+ IsValidRoundNil *big.Int

+ ProposalBlock *types.Block

+ Round *big.Int

+ ValidRound *big.Int

+ func NewProposal(r *big.Int, h *big.Int, vr *big.Int, p *types.Block) *Proposal

+ func (p *Proposal) DecodeRLP(s *rlp.Stream) error

+ func (p *Proposal) EncodeRLP(w io.Writer) error

+ type TimeoutEvent struct

+ type VerifyHeaderAlwaysTrueEngine struct

+ func NewVerifyHeaderAlwaysTrueEngine(c consensus.Engine) *VerifyHeaderAlwaysTrueEngine

+ func (c *VerifyHeaderAlwaysTrueEngine) VerifyHeader(_ consensus.ChainReader, _ *types.Header, _ bool) error

+ func (c VerifyHeaderAlwaysTrueEngine) APIs(chain consensus.ChainReader) []rpc.API

+ func (c VerifyHeaderAlwaysTrueEngine) Author(header *types.Header) (common.Address, error)

+ func (c VerifyHeaderAlwaysTrueEngine) CalcDifficulty(chain consensus.ChainReader, time uint64, parent *types.Header) *big.Int

+ func (c VerifyHeaderAlwaysTrueEngine) Close() error

+ func (c VerifyHeaderAlwaysTrueEngine) Finalize(chain consensus.ChainReader, header *types.Header, state *state.StateDB, ...)

+ func (c VerifyHeaderAlwaysTrueEngine) FinalizeAndAssemble(chain consensus.ChainReader, header *types.Header, state *state.StateDB, ...) (*types.Block, error)

+ func (c VerifyHeaderAlwaysTrueEngine) GetCurrentHeightMessages() []*Message

+ func (c VerifyHeaderAlwaysTrueEngine) HandleMsg(address common.Address, data p2p.Msg) (bool, error)

+ func (c VerifyHeaderAlwaysTrueEngine) IsValidator(address common.Address) bool

+ func (c VerifyHeaderAlwaysTrueEngine) NewChainHead() error

+ func (c VerifyHeaderAlwaysTrueEngine) Prepare(chain consensus.ChainReader, header *types.Header) error

+ func (c VerifyHeaderAlwaysTrueEngine) Protocol() (protocolName string, extraMsgCodes uint64)

+ func (c VerifyHeaderAlwaysTrueEngine) Quorum(i int) bool

+ func (c VerifyHeaderAlwaysTrueEngine) ResetPeerCache(address common.Address)

+ func (c VerifyHeaderAlwaysTrueEngine) Seal(chain consensus.ChainReader, block *types.Block, results chan<- *types.Block, ...) error

+ func (c VerifyHeaderAlwaysTrueEngine) SealHash(header *types.Header) common.Hash

+ func (c VerifyHeaderAlwaysTrueEngine) SetBroadcaster(b consensus.Broadcaster)

+ func (c VerifyHeaderAlwaysTrueEngine) Start(ctx context.Context, chain consensus.ChainReader, ...) error

+ func (c VerifyHeaderAlwaysTrueEngine) Stop() error

+ func (c VerifyHeaderAlwaysTrueEngine) SyncPeer(address common.Address)

+ func (c VerifyHeaderAlwaysTrueEngine) VerifyHeaders(chain consensus.ChainReader, headers []*types.Header, seals []bool) (chan<- struct{}, <-chan error)

+ func (c VerifyHeaderAlwaysTrueEngine) VerifySeal(chain consensus.ChainReader, header *types.Header) error

+ func (c VerifyHeaderAlwaysTrueEngine) VerifyUncles(chain consensus.ChainReader, block *types.Block) error

+ type Vote struct

+ Height *big.Int

+ ProposedBlockHash common.Hash

+ Round *big.Int

+ func (sub *Vote) DecodeRLP(s *rlp.Stream) error

+ func (sub *Vote) EncodeRLP(w io.Writer) error

+ func (sub *Vote) String() string

v0.1.5

Aug 14, 2019

Changes in this version

+ func Encode(val interface{}) ([]byte, error)

+ func NewRoundState(r *big.Int, h *big.Int) *roundState

+ func PrepareCommittedSeal(hash common.Hash) []byte

+ type Engine interface

+ Start func() error

+ Stop func() error

+ func New(backend tendermint.Backend, config *tendermint.Config) Engine

+ type Step uint64

+ func (s Step) Cmp(y Step) int

+ func (s Step) String() string

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