state

package

Go to main page

Versions in this module

v0

v0.4.3

May 9, 2020

v0.4.2

Mar 5, 2020

v0.4.1

Jan 8, 2020

v0.4.0

Dec 11, 2019

Changes in this version

type CheckPoint

+ func NewCheckpoint(ar *arbitrators) *CheckPoint

+ func (c *CheckPoint) DataExtension() string

+ func (c *CheckPoint) Deserialize(r io.Reader) (err error)

+ func (c *CheckPoint) EffectivePeriod() uint32

+ func (c *CheckPoint) Generator() func(buf []byte) checkpoint.ICheckPoint

+ func (c *CheckPoint) GetHeight() uint32

+ func (c *CheckPoint) Key() string

+ func (c *CheckPoint) LogError(err error)

+ func (c *CheckPoint) OnBlockSaved(block *types.DposBlock)

+ func (c *CheckPoint) OnInit()

+ func (c *CheckPoint) OnRollbackTo(height uint32) error

+ func (c *CheckPoint) Priority() checkpoint.Priority

+ func (c *CheckPoint) SavePeriod() uint32

+ func (c *CheckPoint) Serialize(w io.Writer) (err error)

+ func (c *CheckPoint) SetHeight(height uint32)

+ func (c *CheckPoint) Snapshot() checkpoint.ICheckPoint

+ func (c *CheckPoint) StartHeight() uint32

type Producer

+ func (p *Producer) DepositAmount() common.Fixed64

type State

+ func (s *State) ExistProducerByDepositHash(programHash common.Uint168) bool

type StateKeyFrame

+ DepositOutputs map[string]*types.Output

+ ProducerDepositMap map[common.Uint168]struct{}

+ func NewStateKeyFrame() *StateKeyFrame

+ func (s *StateKeyFrame) DeserializeDIDSet(r io.Reader) (vmap map[common.Uint168]struct{}, err error)

+ func (s *StateKeyFrame) DeserializeOutputsMap(r io.Reader) (vmap map[string]*types.Output, err error)

+ func (s *StateKeyFrame) SerializeDIDSet(vmap map[common.Uint168]struct{}, w io.Writer) (err error)

+ func (s *StateKeyFrame) SerializeOutputsMap(vmap map[string]*types.Output, w io.Writer) (err error)

v0.3.9

Nov 21, 2019

Changes in this version

type State

+ func (s *State) ProcessVoteStatisticsBlock(block *types.Block)

v0.3.8

Oct 23, 2019

Changes in this version

+ const CacheVotesSize

v0.3.7

Aug 17, 2019

v0.3.6

Aug 8, 2019

v0.3.5

Aug 1, 2019

v0.3.4

Jul 20, 2019

v0.3.3

Jun 14, 2019

v0.3.2

Jun 2, 2019

Changes in this version

+ const ActivateDuration

+ const CheckPointInterval

+ const DSInactive

+ const DSNormal

+ const DSUnderstaffed

+ const MajoritySignRatioDenominator

+ const MajoritySignRatioNumerator

+ const MaxNormalInactiveChangesCount

+ const MaxSnapshotLength

+ var ErrInsufficientProducer = errors.New("producers count less than min arbitrators count")

type Arbitrators

+ CheckDPOSIllegalTx func(block *types.Block) error

+ GetArbitersRoundReward func() map[common.Uint168]common.Fixed64

+ GetCRCArbiters func() [][]byte

+ GetCRCArbitersCount func() int

+ GetCrossChainArbiters func() [][]byte

+ GetCrossChainArbitersCount func() int

+ GetCrossChainArbitersMajorityCount func() int

+ GetCurrentRewardData func() RewardData

+ GetFinalRoundChange func() common.Fixed64

+ GetNextRewardData func() RewardData

+ GetOnDutyCrossChainArbitrator func() []byte

+ GetSnapshot func(height uint32) []*KeyFrame

+ IsActiveProducer func(pk []byte) bool

+ IsDisabledProducer func(pk []byte) bool

+ IsInactiveMode func() bool

+ IsUnderstaffedMode func() bool

+ RecoverFromCheckPoints func(height uint32) (uint32, error)

+ Start func()

type ArbitratorsMock

+ ActiveProducer [][]byte

+ ArbitersRoundReward map[common.Uint168]common.Fixed64

+ CRCArbitrators [][]byte

+ CRCArbitratorsMap map[string]*Producer

+ CurrentReward RewardData

+ FinalRoundChange common.Fixed64

+ InactiveMode bool

+ NextReward RewardData

+ Snapshot []*KeyFrame

+ func (a *ArbitratorsMock) CheckDPOSIllegalTx(block *types.Block) error

+ func (a *ArbitratorsMock) GetArbitersRoundReward() map[common.Uint168]common.Fixed64

+ func (a *ArbitratorsMock) GetCRCArbiters() [][]byte

+ func (a *ArbitratorsMock) GetCRCArbitersCount() int

+ func (a *ArbitratorsMock) GetCrossChainArbiters() [][]byte

+ func (a *ArbitratorsMock) GetCrossChainArbitersCount() int

+ func (a *ArbitratorsMock) GetCrossChainArbitersMajorityCount() int

+ func (a *ArbitratorsMock) GetCurrentRewardData() RewardData

+ func (a *ArbitratorsMock) GetFinalRoundChange() common.Fixed64

+ func (a *ArbitratorsMock) GetNextRewardData() RewardData

+ func (a *ArbitratorsMock) GetOnDutyCrossChainArbitrator() []byte

+ func (a *ArbitratorsMock) GetSnapshot(height uint32) []*KeyFrame

+ func (a *ArbitratorsMock) IsActiveProducer(pk []byte) bool

+ func (a *ArbitratorsMock) IsDisabledProducer(pk []byte) bool

+ func (a *ArbitratorsMock) IsInactiveMode() bool

+ func (a *ArbitratorsMock) IsUnderstaffedMode() bool

+ func (a *ArbitratorsMock) RecoverFromCheckPoints(height uint32) (uint32, error)

+ func (a *ArbitratorsMock) SaveCheckPoint(height uint32) error

+ func (a *ArbitratorsMock) Start()

+ type CheckPoint struct

+ CurrentCandidates [][]byte

+ CurrentReward RewardData

+ DutyIndex int

+ Height uint32

+ NextArbitrators [][]byte

+ NextCandidates [][]byte

+ NextReward RewardData

+ type IArbitratorsRecord interface

+ GetCheckPoint func(height uint32) (*CheckPoint, error)

+ GetHeightsDesc func() ([]uint32, error)

+ SaveArbitersState func(point *CheckPoint) error

+ type KeyFrame struct

+ CurrentArbitrators [][]byte

type Producer

+ func (p *Producer) ActivateRequestHeight() uint32

+ func (p *Producer) Deserialize(r io.Reader) (err error)

+ func (p *Producer) Serialize(w io.Writer) error

type ProducerState

+ const Active

+ const Illegal

+ const Inactive

+ const Returned

+ type RewardData struct

+ CandidateOwnerProgramHashes []*common.Uint168

+ OwnerProgramHashes []*common.Uint168

+ OwnerVotesInRound map[common.Uint168]common.Fixed64

+ TotalVotesInRound common.Fixed64

+ func NewRewardData() *RewardData

+ func (d *RewardData) Deserialize(r io.Reader) (err error)

+ func (d *RewardData) Serialize(w io.Writer) error

type State

+ func (s *State) GetAllProducers() []*Producer

+ func (s *State) GetPendingCanceledProducers() []*Producer

+ func (s *State) GetReturnedDepositProducers() []*Producer

+ func (s *State) GetVotedProducers() []*Producer

+ func (s *State) IsAbleToRecoverFromInactiveMode() bool

+ func (s *State) IsAbleToRecoverFromUnderstaffedState() bool

+ func (s *State) LeaveEmergency()

+ func (s *State) ProducerNodePublicKeyExists(publicKey []byte) bool

+ func (s *State) ProducerOwnerPublicKeyExists(publicKey []byte) bool

+ type StateKeyFrame struct

+ ActivityProducers map[string]*Producer

+ CanceledProducers map[string]*Producer

+ EmergencyInactiveArbiters map[string]struct{}

+ IllegalProducers map[string]*Producer

+ InactiveProducers map[string]*Producer

+ Nicknames map[string]struct{}

+ NodeOwnerKeys map[string]string

+ PendingCanceledProducers map[string]*Producer

+ PendingProducers map[string]*Producer

+ PreBlockArbiters map[string]struct{}

+ SpecialTxHashes map[common.Uint256]struct{}

+ VersionEndHeight uint32

+ VersionStartHeight uint32

+ Votes map[string]*types.Output

+ func (s *StateKeyFrame) Deserialize(r io.Reader) (err error)

+ func (s *StateKeyFrame) DeserializeHashSet(r io.Reader) (vmap map[common.Uint256]struct{}, err error)

+ func (s *StateKeyFrame) DeserializeProducerMap(r io.Reader) (pmap map[string]*Producer, err error)

+ func (s *StateKeyFrame) DeserializeStringMap(r io.Reader) (smap map[string]string, err error)

+ func (s *StateKeyFrame) DeserializeStringSet(r io.Reader) (vmap map[string]struct{}, err error)

+ func (s *StateKeyFrame) DeserializeVotesMap(r io.Reader) (vmap map[string]*types.Output, err error)

+ func (s *StateKeyFrame) Serialize(w io.Writer) (err error)

+ func (s *StateKeyFrame) SerializeHashSet(vmap map[common.Uint256]struct{}, w io.Writer) (err error)

+ func (s *StateKeyFrame) SerializeProducerMap(pmap map[string]*Producer, w io.Writer) (err error)

+ func (s *StateKeyFrame) SerializeStringMap(smap map[string]string, w io.Writer) (err error)

+ func (s *StateKeyFrame) SerializeStringSet(vmap map[string]struct{}, w io.Writer) (err error)

+ func (s *StateKeyFrame) SerializeVotesMap(vmap map[string]*types.Output, w io.Writer) (err error)

v0.3.2-e935

Jun 10, 2019

v0.3.1

Apr 12, 2019

v0.3.0

Mar 28, 2019

Changes in this version

+ func DisableLog()

+ func NewArbitrators(chainParams *config.Params, bestHeight func() uint32) (*arbitrators, error)

+ func UseLogger(logger elalog.Logger)

+ type Arbitrators interface

+ DumpInfo func()

+ GetArbitersCount func() int

+ GetArbitersMajorityCount func() int

+ GetArbitrators func() [][]byte

+ GetCRCArbitrators func() map[string]*Producer

+ GetCRCProducer func(publicKey []byte) *Producer

+ GetCandidateOwnerProgramHashes func() []*common.Uint168

+ GetCandidates func() [][]byte

+ GetCurrentOwnerProgramHashes func() []*common.Uint168

+ GetDutyIndex func() int

+ GetDutyIndexByHeight func(height uint32) int

+ GetNeedConnectArbiters func(height uint32) map[string]*p2p.PeerAddr

+ GetNextArbitrators func() [][]byte

+ GetNextCandidates func() [][]byte

+ GetNextOnDutyArbitrator func(offset uint32) []byte

+ GetOnDutyArbitrator func() []byte

+ GetOwnerVotes func(programHash *common.Uint168) common.Fixed64

+ GetTotalVotesInRound func() common.Fixed64

+ HasArbitersMajorityCount func(num int) bool

+ HasArbitersMinorityCount func(num int) bool

+ IsArbitrator func(pk []byte) bool

+ IsCRCArbitrator func(pk []byte) bool

+ IsCRCArbitratorNodePublicKey func(nodePublicKeyHex string) bool

+ IsCRCArbitratorProgramHash func(hash *common.Uint168) bool

+ ProcessBlock func(block *types.Block, confirm *payload.Confirm)

+ ProcessSpecialTxPayload func(p types.Payload, height uint32) error

+ RollbackTo func(height uint32) error

+ type ArbitratorsMock struct

+ CandidateOwnerProgramHashes []*common.Uint168

+ CurrentArbitrators [][]byte

+ CurrentCandidates [][]byte

+ CurrentOwnerProgramHashes []*common.Uint168

+ DutyChangedCount int

+ MajorityCount int

+ NextArbitrators [][]byte

+ NextCandidates [][]byte

+ OwnerVotesInRound map[common.Uint168]common.Fixed64

+ TotalVotesInRound common.Fixed64

+ func NewArbitratorsMock(arbitersByte [][]byte, changeCount, majorityCount int) *ArbitratorsMock

+ func (a *ArbitratorsMock) DumpInfo()

+ func (a *ArbitratorsMock) GetArbitersCount() int

+ func (a *ArbitratorsMock) GetArbitersMajorityCount() int

+ func (a *ArbitratorsMock) GetArbitrators() [][]byte

+ func (a *ArbitratorsMock) GetCRCArbitrators() map[string]*Producer

+ func (a *ArbitratorsMock) GetCRCProducer(publicKey []byte) *Producer

+ func (a *ArbitratorsMock) GetCandidateOwnerProgramHashes() []*common.Uint168

+ func (a *ArbitratorsMock) GetCandidates() [][]byte

+ func (a *ArbitratorsMock) GetCurrentOwnerProgramHashes() []*common.Uint168

+ func (a *ArbitratorsMock) GetDutyChangeCount() int

+ func (a *ArbitratorsMock) GetDutyChangedCount() int

+ func (a *ArbitratorsMock) GetDutyIndex() int

+ func (a *ArbitratorsMock) GetDutyIndexByHeight(height uint32) int

+ func (a *ArbitratorsMock) GetLastConfirmedBlockTimeStamp() uint32

+ func (a *ArbitratorsMock) GetNeedConnectArbiters(height uint32) map[string]*p2p.PeerAddr

+ func (a *ArbitratorsMock) GetNextArbitrators() [][]byte

+ func (a *ArbitratorsMock) GetNextCandidates() [][]byte

+ func (a *ArbitratorsMock) GetNextOnDutyArbitrator(offset uint32) []byte

+ func (a *ArbitratorsMock) GetNormalArbitrators() ([][]byte, error)

+ func (a *ArbitratorsMock) GetOnDutyArbitrator() []byte

+ func (a *ArbitratorsMock) GetOwnerVotes(programHash *common.Uint168) common.Fixed64

+ func (a *ArbitratorsMock) GetTotalVotesInRound() common.Fixed64

+ func (a *ArbitratorsMock) HasArbitersMajorityCount(num int) bool

+ func (a *ArbitratorsMock) HasArbitersMinorityCount(num int) bool

+ func (a *ArbitratorsMock) IsArbitrator(pk []byte) bool

+ func (a *ArbitratorsMock) IsCRCArbitrator(pk []byte) bool

+ func (a *ArbitratorsMock) IsCRCArbitratorNodePublicKey(nodePublicKeyHex string) bool

+ func (a *ArbitratorsMock) IsCRCArbitratorProgramHash(hash *common.Uint168) bool

+ func (a *ArbitratorsMock) ProcessBlock(block *types.Block, confirm *payload.Confirm)

+ func (a *ArbitratorsMock) ProcessSpecialTxPayload(p types.Payload, height uint32) error

+ func (a *ArbitratorsMock) RollbackTo(height uint32) error

+ func (a *ArbitratorsMock) SetArbitrators(ar [][]byte)

+ func (a *ArbitratorsMock) SetCandidates(ca [][]byte)

+ func (a *ArbitratorsMock) SetDutyChangeCount(count int)

+ func (a *ArbitratorsMock) SetDutyChangedCount(count int)

+ func (a *ArbitratorsMock) SetNextArbitrators(ar [][]byte)

+ func (a *ArbitratorsMock) SetNextCandidates(ca [][]byte)

+ func (a *ArbitratorsMock) TryEnterEmergency(blockTime uint32) bool

+ type ChangeType byte

+ type Producer struct

+ func (p *Producer) CancelHeight() uint32

+ func (p *Producer) IllegalHeight() uint32

+ func (p *Producer) InactiveSince() uint32

+ func (p *Producer) Info() payload.ProducerInfo

+ func (p *Producer) NodePublicKey() []byte

+ func (p *Producer) OwnerPublicKey() []byte

+ func (p *Producer) Penalty() common.Fixed64

+ func (p *Producer) RegisterHeight() uint32

+ func (p *Producer) State() ProducerState

+ func (p *Producer) Votes() common.Fixed64

+ type ProducerState byte

+ const Activate

+ const Canceled

+ const FoundBad

+ const Inactivate

+ const Pending

+ const ReturnedDeposit

+ func (ps ProducerState) String() string

+ type State struct

+ func NewState(chainParams *config.Params, getArbiters func() [][]byte) *State

+ func (s *State) GetActiveProducers() []*Producer

+ func (s *State) GetCanceledProducers() []*Producer

+ func (s *State) GetHistory(height uint32) (*State, error)

+ func (s *State) GetIllegalProducers() []*Producer

+ func (s *State) GetInactiveProducers() []*Producer

+ func (s *State) GetPendingProducers() []*Producer

+ func (s *State) GetProducer(publicKey []byte) *Producer

+ func (s *State) GetProducers() []*Producer

+ func (s *State) GetSnapshot(height uint32) *State

+ func (s *State) IsActiveProducer(publicKey []byte) bool

+ func (s *State) IsCanceledProducer(publicKey []byte) bool

+ func (s *State) IsDPOSTransaction(tx *types.Transaction) bool

+ func (s *State) IsIllegalProducer(publicKey []byte) bool

+ func (s *State) IsInactiveProducer(publicKey []byte) bool

+ func (s *State) IsPendingProducer(publicKey []byte) bool

+ func (s *State) NicknameExists(nickname string) bool

+ func (s *State) ProcessBlock(block *types.Block, confirm *payload.Confirm)

+ func (s *State) ProcessSpecialTxPayload(p types.Payload)

+ func (s *State) ProducerExists(publicKey []byte) bool

+ func (s *State) RollbackTo(height uint32) error

+ func (s *State) SpecialTxExists(hash *common.Uint256) bool

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