election

Documentation

Index

• Variables
• type Config
• type Election
  • func NewElection(fastBlockChain *core.BlockChain, config Config) *Election
  • func NewFakeElection() *Election
  • func (e *Election) GenerateFakeSigns(fb *types.Block) ([]*types.PbftSign, error)
  • func (e *Election) GetCommittee(fastNumber *big.Int) []*types.CommitteeMember
  • func (e *Election) GetCommitteeById(id *big.Int) map[string]interface{}
  • func (e *Election) GetCurrentCommittee() *committee
  • func (e *Election) GetGenesisCommittee() []*types.CommitteeMember
  • func (e *Election) GetMemberByPubkey(members []*types.CommitteeMember, pubKey []byte) *types.CommitteeMember
  • func (e *Election) GetMemberFlag(members []*types.CommitteeMember, publickey []byte) uint32
  • func (e *Election) IsCommitteeMember(members []*types.CommitteeMember, publickey []byte) bool
  • func (e *Election) Start() error
  • func (e *Election) SubscribeElectionEvent(ch chan<- types.ElectionEvent) event.Subscription
  • func (e *Election) VerifyPublicKey(fastHeight *big.Int, pubKeyByte []byte) (*types.CommitteeMember, error)
  • func (e *Election) VerifySign(sign *types.PbftSign) (*types.CommitteeMember, error)
  • func (e *Election) VerifySigns(signs []*types.PbftSign) ([]*types.CommitteeMember, []error)
  • func (e *Election) VerifySwitchInfo(fastNumber *big.Int, info []*types.CommitteeMember) error

Variables

var (
	ErrCommittee     = errors.New("get committee failed")
	ErrInvalidMember = errors.New("invalid committee member")
	ErrInvalidSwitch = errors.New("invalid switch block info")
)

Types

type Config

type Config interface {
	GetNodeType() bool
}

type Election

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

func NewElection

func NewElection(fastBlockChain *core.BlockChain, config Config) *Election

NewElection create election processor and load genesis committee

func NewFakeElection

func NewFakeElection() *Election

NewFakeElection create fake mode election only for testing

func (*Election) GenerateFakeSigns

func (e *Election) GenerateFakeSigns(fb *types.Block) ([]*types.PbftSign, error)

func (*Election) GetCommittee

func (e *Election) GetCommittee(fastNumber *big.Int) []*types.CommitteeMember

GetCommittee gets committee members propose this fast block

func (*Election) GetCommitteeById

func (e *Election) GetCommitteeById(id *big.Int) map[string]interface{}

GetCommitteeById return committee info sepecified by Committee ID

func (*Election) GetCurrentCommittee

func (e *Election) GetCurrentCommittee() *committee

func (*Election) GetGenesisCommittee

func (e *Election) GetGenesisCommittee() []*types.CommitteeMember

func (*Election) GetMemberByPubkey

func (e *Election) GetMemberByPubkey(members []*types.CommitteeMember, pubKey []byte) *types.CommitteeMember

GetMemberByPubkey returns committeeMember specified by public key bytes

func (*Election) GetMemberFlag

func (e *Election) GetMemberFlag(members []*types.CommitteeMember, publickey []byte) uint32

IsCommitteeMember reports whether the provided public key is in committee

func (*Election) IsCommitteeMember

func (e *Election) IsCommitteeMember(members []*types.CommitteeMember, publickey []byte) bool

func (*Election) Start

func (e *Election) Start() error

Start load current committ and starts election processing

func (*Election) SubscribeElectionEvent

func (e *Election) SubscribeElectionEvent(ch chan<- types.ElectionEvent) event.Subscription

SubscribeElectionEvent adds a channel to feed on committee change event

func (*Election) VerifyPublicKey

func (e *Election) VerifyPublicKey(fastHeight *big.Int, pubKeyByte []byte) (*types.CommitteeMember, error)

VerifyPublicKey get the committee member by public key

func (*Election) VerifySign

func (e *Election) VerifySign(sign *types.PbftSign) (*types.CommitteeMember, error)

VerifySign lookup the pbft sign and return the committee member who signs it

func (*Election) VerifySigns

func (e *Election) VerifySigns(signs []*types.PbftSign) ([]*types.CommitteeMember, []error)

VerifySigns verify signatures of bft committee in batches

func (*Election) VerifySwitchInfo

func (e *Election) VerifySwitchInfo(fastNumber *big.Int, info []*types.CommitteeMember) error

VerifySwitchInfo verify committee members and it's state