core

package

Go to main page

Versions in this module

v1

v1.0.6-testnet

Dec 3, 2019

v1.0.5

Nov 15, 2019

Changes in this version

type HasProposalData

+ Weight uint64

v1.0.4

Oct 18, 2019

Changes in this version

type MinerVerifier

+ func (mv *MinerVerifier) KeyValueStorage() []common.Hash

v1.0.3

Sep 18, 2019

v1.0.2

Aug 6, 2019

v1.0.1

Jul 18, 2019

v1.0.0

Jul 1, 2019

Changes in this version

+ const DefaultLifespan

+ const HandshakeMsg

+ const HasProposalBlockMsg

+ const HasProposalLeaderMsg

+ const HasVoteMsg

+ const MaxLifespan

+ const MaxMinerKeySize

+ const ProposalBlockMsg

+ const ProposalLeaderMsg

+ const StatusMsg

+ const TimeoutMsg

+ const VoteMsg

+ var CodeToString = map[uint64]string

+ func BuildProof(config *params.AlgorandConfig, stateDb *state.StateDB, height uint64, ...) (err error)

+ func GetCommitteeNumber(height uint64, step uint32) (uint64, uint64)

+ func GetWeight(config *params.AlgorandConfig, miner common.Address, stateDb *state.StateDB, ...) (ownWeight, totalWeight uint64)

+ func PrintVoteJournalEntry(ts, code uint64, data interface{}, from string) error

+ func VerifyProof(config *params.AlgorandConfig, stateRoot common.Hash, height uint64, ...) error

+ func VerifySignatureAndCredential(mv *MinerVerifier, signBytes []byte, signature ed25519.ForwardSecureSignature, ...) error

+ type Backend interface

+ BlockChain func() *core.BlockChain

+ GossipInterval func() time.Duration

+ TxPool func() *core.TxPool

+ type Broadcaster interface

+ Broadcast func(code uint64, data interface{})

+ Publish func(chanId []byte, msgCode uint64, data interface{})

+ Request func(chanId []byte, value common.Hash)

+ Sub func(chanId []byte, timeout time.Duration)

+ UnSub func(chanId []byte)

+ type Context struct

+ func NewContext(eth Backend, broadcaster Broadcaster, config *params.ChainConfig, ...) *Context

+ func (ctx *Context) GetParentProposalBlockData(height uint64) *ProposalBlockData

+ func (ctx *Context) GetParentRoundVoteSet(height uint64) (*RoundVoteSet, uint32)

+ func (ctx *Context) GetProposalBlock(height uint64, value common.Hash) *ProposalBlockData

+ func (ctx *Context) GetProposalLeader(height uint64, round uint32) *ProposalLeaderData

+ func (ctx *Context) HR() (uint64, uint32)

+ func (ctx *Context) HRS() string

+ func (ctx *Context) IsMining() bool

+ func (ctx *Context) NewBlock() error

+ func (ctx *Context) OnReceive(code uint64, data interface{}, from string)

+ func (ctx *Context) Pending() (*types.Block, *state.StateDB)

+ func (ctx *Context) RoundVoteSet(height uint64, round uint32) *RoundVoteSet

+ func (ctx *Context) SaveProposalBlock(data *ProposalBlockData)

+ func (ctx *Context) SetExtra(extra []byte)

+ func (ctx *Context) SetMiner(address common.Address)

+ func (ctx *Context) Stake() uint64

+ func (ctx *Context) Start()

+ func (ctx *Context) StartMining()

+ func (ctx *Context) Stop()

+ func (ctx *Context) StopMining()

+ func (ctx *Context) UpdateProposalLeader(value *ProposalLeaderData)

+ type Credential struct

+ Address common.Address

+ Height uint64

+ Proof ed25519.VrfProof

+ Round uint32

+ Step uint32

+ Weight uint64

+ func NewCredentialFromCredentialStorage(storage *types.CredentialStorage, height uint64, round uint32, step uint32) Credential

+ func (c *Credential) LessThan(other *Credential) bool

+ func (c *Credential) String() string

+ type HandshakeData struct

+ Height uint64

+ Round uint32

+ Version uint32

+ type HasProposalData struct

+ Height uint64

+ Proof ed25519.VrfProof

+ Round uint32

+ Value common.Hash

+ func (data *HasProposalData) String() string

+ type HasVoteData struct

+ Address common.Address

+ Height uint64

+ Round uint32

+ Step uint32

+ func ToHasVote(data *VoteData) *HasVoteData

+ func (data *HasVoteData) String() string

+ type HeightState struct

+ EmptyValue common.Hash

+ Height uint64

+ ProposalLeader map[uint32]*ProposalLeaderData

+ ReceivedProposalBlock map[string]*ProposalBlockData

+ Round uint32

+ StartingValue common.Hash

+ Step uint32

+ WaitingBlockForRound uint32

+ WaitingBlockForValue common.Hash

+ type HeightVoteSet struct

+ func NewHeightVoteSet() *HeightVoteSet

+ func (hvs *HeightVoteSet) AddVoteAndCount(vote *VoteData, threshold uint64) (added, potential, enough bool, err error)

+ func (hvs *HeightVoteSet) EnsureRoundVoteSet(round uint32) *RoundVoteSet

+ func (hvs *HeightVoteSet) GetCertVoteStorage(round uint32, value common.Hash) []*types.CertVoteStorage

+ func (hvs *HeightVoteSet) GetCertVotesOfValue(round uint32, value common.Hash) []*VoteData

+ func (hvs *HeightVoteSet) HasVote(round uint32, step uint32, user common.Address) bool

+ func (hvs *HeightVoteSet) IsNextVoteEnoughForEmptyAtAnyStep(round uint32, empty common.Hash) bool

+ func (hvs *HeightVoteSet) IsPotentialValue(round uint32, value common.Hash) bool

+ func (hvs *HeightVoteSet) IsSoftVoteEnoughForNonEmpty(empty common.Hash, round uint32) (bool, common.Hash)

+ func (hvs *HeightVoteSet) IsSoftVoteEnoughForNonEmptyForAnyRound(empty common.Hash) (bool, common.Hash)

+ func (hvs *HeightVoteSet) RoundVoteSet(round uint32) *RoundVoteSet

+ func (hvs *HeightVoteSet) SetHasVote(round uint32, step uint32, user common.Address)

+ type JournalType uint8

+ const TimeoutJournalEntry

+ const VoteJournalEntry

+ type MinerKey struct

+ func NewEmptyMinerKey(config *params.AlgorandConfig) *MinerKey

+ func (mk *MinerKey) DecodeRLP(stream *rlp.Stream) error

+ func (mk *MinerKey) EncodeRLP(writer io.Writer) error

+ func (mk *MinerKey) Seed(height uint64, parentSeed ed25519.VrfOutput256, parentHash common.Hash) (seed ed25519.VrfOutput256, proof ed25519.VrfProof, err error)

+ func (mk *MinerKey) Sign(height uint64, data []byte) (sig ed25519.ForwardSecureSignature, err error)

+ func (mk *MinerKey) Sortition(height uint64, round, step uint32, parentSeed ed25519.VrfOutput256, ...) (hash ed25519.VrfOutput256, proof ed25519.VrfProof, j uint64, err error)

+ func (mk *MinerKey) ToVerifier() *MinerVerifier

+ func (mk *MinerKey) Update(height uint64) uint64

+ func (mk *MinerKey) Validate(height uint64) bool

+ type MinerKeyManager struct

+ func NewMinerKeyManager(config *params.AlgorandConfig, dataDir string) *MinerKeyManager

+ func (mkm *MinerKeyManager) Generate(miner, coinbase common.Address, start uint64, lifespan uint32) (mv *MinerVerifier, mk *MinerKey, err error)

+ func (mkm *MinerKeyManager) GetMinerKey(miner common.Address, height uint64) (*MinerKey, error)

+ func (mkm *MinerKeyManager) StartUpdateRoutine(bc *core.BlockChain)

+ type MinerVerifier struct

+ func GetMinerVerifier(config *params.AlgorandConfig, statedb *state.StateDB, miner common.Address, ...) *MinerVerifier

+ func (mv *MinerVerifier) AbiString() string

+ func (mv *MinerVerifier) Coinbase() common.Address

+ func (mv *MinerVerifier) GenesisString() string

+ func (mv *MinerVerifier) String() string

+ func (mv *MinerVerifier) Validate(height uint64) bool

+ func (mv *MinerVerifier) VerifySeed(height uint64, parentSeed ed25519.VrfOutput256, parentHash common.Hash, ...) error

+ func (mv *MinerVerifier) VerifySignature(height uint64, data []byte, sig ed25519.ForwardSecureSignature) error

+ func (mv *MinerVerifier) VerifySortition(height uint64, round, step uint32, proof ed25519.VrfProof, ...) (err error, j uint64)

+ type ProposalBlockData struct

+ Block *types.Block

+ ESignValue ed25519.ForwardSecureSignature

+ func NewProposalBlockDataFromProposalStorage(leader *types.ProposalStorage, block *types.Block) *ProposalBlockData

+ func (data *ProposalBlockData) LessThan(other *ProposalBlockData) bool

+ func (data *ProposalBlockData) NewProposalLeaderData() *ProposalLeaderData

+ func (data *ProposalBlockData) SignBytes() []byte

+ func (data *ProposalBlockData) String() string

+ func (data *ProposalBlockData) ToHasProposalData() *HasProposalData

+ func (data *ProposalBlockData) ToProposalStorage() types.ProposalStorage

+ func (data *ProposalBlockData) Valid(height uint64) bool

+ type ProposalLeaderData struct

+ ESignValue ed25519.ForwardSecureSignature

+ Value common.Hash

+ func NewProposalLeaderDataFromStorage(value common.Hash, height uint64, storage *types.ProposalStorage) *ProposalLeaderData

+ func (data *ProposalLeaderData) LessThan(other *ProposalLeaderData) bool

+ func (data *ProposalLeaderData) SignBytes() []byte

+ func (data *ProposalLeaderData) String() string

+ func (data *ProposalLeaderData) ToHasProposalData() *HasProposalData

+ func (data *ProposalLeaderData) Valid(height uint64) bool

+ type RoundVoteSet struct

+ func NewRoundVoteSet() *RoundVoteSet

+ func NewRoundVoteSetFromCertificates(votes []*VoteData, threshold uint64) *RoundVoteSet

+ func (rvs *RoundVoteSet) AddVoteAndCount(vote *VoteData, threshold uint64) (added, newPotential, enough bool, err error)

+ func (rvs *RoundVoteSet) GetCertMajorValue() common.Hash

+ func (rvs *RoundVoteSet) GetCertVotesOfValue(value common.Hash) []*VoteData

+ func (rvs *RoundVoteSet) GetPotentialCertifiedValues() []common.Hash

+ func (rvs *RoundVoteSet) GetPotentialSoftedValues() []common.Hash

+ func (rvs *RoundVoteSet) GetSoftMajorValue() common.Hash

+ func (rvs *RoundVoteSet) HasPotentialValue(value common.Hash) bool

+ func (rvs *RoundVoteSet) HasVote(step uint32, user common.Address) bool

+ func (rvs *RoundVoteSet) IsNextVoteEnoughForEmptyAtAnyStep(empty common.Hash) bool

+ func (rvs *RoundVoteSet) PickNextVoteToSend(other *RoundVoteSet) *VoteData

+ func (rvs *RoundVoteSet) PickVoteToSend(other *RoundVoteSet) *VoteData

+ func (rvs *RoundVoteSet) SetHasVote(step uint32, user common.Address)

+ type Snapshot struct

+ func (s *Snapshot) Copy() *snapshotBlockState

+ type State interface

+ OnCertVoteEnough func(value common.Hash, round uint32) StateEvent

+ OnEnter func()

+ OnExit func()

+ OnNextVoteEnough func(value common.Hash, round uint32, step uint32) StateEvent

+ OnPotentialVoteEnough func(value common.Hash, round uint32, step uint32)

+ OnProposalDataComplete func(data *ProposalBlockData) StateEvent

+ OnProposalLeaderReceived func(value *ProposalLeaderData)

+ OnSoftVoteEnough func(value common.Hash, round uint32)

+ OnTimeout func()

+ SetContext func(c *Context)

+ String func() string

+ type StateBase struct

+ func (s *StateBase) OnCertVoteEnough(value common.Hash, round uint32) StateEvent

+ func (s *StateBase) OnEnter()

+ func (s *StateBase) OnExit()

+ func (s *StateBase) OnNextVoteEnough(value common.Hash, round uint32, step uint32) StateEvent

+ func (s *StateBase) OnPotentialVoteEnough(value common.Hash, round, step uint32)

+ func (s *StateBase) OnProposalDataComplete(data *ProposalBlockData) StateEvent

+ func (s *StateBase) OnProposalLeaderReceived(value *ProposalLeaderData)

+ func (s *StateBase) OnSoftVoteEnough(value common.Hash, round uint32)

+ func (s *StateBase) OnTimeout()

+ func (s *StateBase) SetContext(c *Context)

+ func (s *StateBase) String() string

+ type StateCertifying struct

+ func (s *StateCertifying) OnEnter()

+ func (s *StateCertifying) OnExit()

+ func (s *StateCertifying) OnProposalDataComplete(data *ProposalBlockData) StateEvent

+ func (s *StateCertifying) OnSoftVoteEnough(value common.Hash, round uint32)

+ func (s *StateCertifying) OnTimeout()

+ func (s *StateCertifying) String() string

+ type StateEvent int

+ const HeightEnd

+ const NewRound

+ const Unchanged

+ func (se StateEvent) IsChanged() bool

+ type StateFiltering struct

+ func (s *StateFiltering) OnEnter()

+ func (s *StateFiltering) String() string

+ type StateFirstFinishing struct

+ func (s *StateFirstFinishing) OnEnter()

+ func (s *StateFirstFinishing) String() string

+ type StateNewHeight struct

+ func (s *StateNewHeight) OnEnter()

+ func (s *StateNewHeight) String() string

+ type StateProposal struct

+ func (s *StateProposal) OnEnter()

+ func (s *StateProposal) OnExit()

+ func (s *StateProposal) OnTimeout()

+ func (s *StateProposal) String() string

+ type StateSecondFinishing struct

+ func (s *StateSecondFinishing) OnEnter()

+ func (s *StateSecondFinishing) OnExit()

+ func (s *StateSecondFinishing) OnNextVoteEnough(value common.Hash, round uint32, step uint32) StateEvent

+ func (s *StateSecondFinishing) OnProposalDataComplete(data *ProposalBlockData) StateEvent

+ func (s *StateSecondFinishing) OnSoftVoteEnough(value common.Hash, round uint32)

+ func (s *StateSecondFinishing) OnTimeout()

+ func (s *StateSecondFinishing) String() string

+ type StatusData struct

+ Height uint64

+ Round uint32

+ type StepVoteSet struct

+ MajorValue common.Hash

+ PotentialValue []common.Hash

+ Values map[string]*VoteSet

+ func NewStepVoteSet() *StepVoteSet

+ func (svs *StepVoteSet) RandomNotIn(other *StepVoteSet) *VoteData

+ type TimeoutInfo struct

+ Duration uint64

+ Height uint64

+ Round uint32

+ Step uint32

+ func (ti *TimeoutInfo) String() string

+ type TimeoutTicker interface

+ Chan func() <-chan TimeoutInfo

+ ScheduleTimeout func(ti TimeoutInfo)

+ Start func() error

+ Stop func()

+ func NewTimeoutTicker() TimeoutTicker

+ type UserSet struct

+ func (us *UserSet) Add(user common.Address)

+ func (us *UserSet) Has(user common.Address) bool

+ type VoteData struct

+ ESignValue ed25519.ForwardSecureSignature

+ Value common.Hash

+ func NewVoteDataFromCertVoteStorage(storage *types.CertVoteStorage, height uint64, round uint32, value common.Hash) *VoteData

+ func RandomSelect(from []*VoteData) *VoteData

+ func (data *VoteData) SignBytes() []byte

+ func (data *VoteData) String() string

+ func (data *VoteData) Valid(height uint64, emptyValue common.Hash) bool

+ type VoteJournal struct

+ func NewVoteJournal(path string) *VoteJournal

+ func (j *VoteJournal) CloseFile() error

+ func (j *VoteJournal) OpenFile() error

+ func (j *VoteJournal) Read(load func(ts, code uint64, data interface{}, from string) error) error

+ func (j *VoteJournal) Write(code uint64, data interface{}, from string) error

+ type VoteSet struct

+ Votes []*VoteData

+ Weight uint64

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