vote

Documentation

Index

• Constants
• func AggregateSignatureAndValidatorBitSet(votes []*model.Vote, validators []*tmtypes.Validator) ([]byte, *bitset.BitSet, error)
• func CalculateEventHash(event *model.Event, chainId string) []byte
• func DtoToEntity(v *model.Vote) (*votepool.Vote, error)
• func EntityToDto(from *votepool.Vote, challengeId uint64) *model.Vote
• type DataHandler
  • func NewDataHandler(daoManager *dao.DaoManager, executor *executor.Executor) *DataHandler
  • func (h *DataHandler) FetchEventsForCollate(currentHeight uint64) ([]*model.Event, error)
  • func (h *DataHandler) FetchEventsForSelfVote(currentHeight uint64) ([]*model.Event, uint64, error)
  • func (h *DataHandler) FetchVotesForCollate(eventHash string) ([]*model.Vote, error)
  • func (h *DataHandler) IsVoteExists(eventHash string, pubKey string) (bool, error)
  • func (h *DataHandler) SaveVote(vote *model.Vote) error
  • func (h *DataHandler) SaveVoteAndUpdateEventStatus(vote *model.Vote, challengeId uint64) error
  • func (h *DataHandler) UpdateEventStatus(challengeId uint64, status model.EventStatus) error
• type DataProvider
• type VoteBroadcaster
  • func NewVoteBroadcaster(cfg *config.Config, signer *VoteSigner, executor *executor.Executor, ...) *VoteBroadcaster
  • func (p *VoteBroadcaster) BroadcastVotesLoop()
• type VoteCollator
  • func NewVoteCollator(cfg *config.Config, signer *VoteSigner, executor *executor.Executor, ...) *VoteCollator
  • func (p *VoteCollator) CollateVotesLoop()
• type VoteCollector
  • func NewVoteCollector(cfg *config.Config, executor *executor.Executor, ...) *VoteCollector
  • func (p *VoteCollector) CollectVotesLoop()
• type VoteSigner
  • func NewVoteSigner(pk []byte) *VoteSigner
  • func (signer *VoteSigner) SignVote(vote *votepool.Vote, data []byte)

Constants

const (
	ValidatorsCapacity = 256

	RetryInterval        = 1 * time.Second
	BroadcastInterval    = 10 * time.Second
	CollectVotesInterval = 5 * time.Second
	CollateVotesInterval = 2 * time.Second
	BatchSize            = 20 // to fetch records from database in batch
)

Functions

func AggregateSignatureAndValidatorBitSet

func AggregateSignatureAndValidatorBitSet(votes []*model.Vote, validators []*tmtypes.Validator) ([]byte, *bitset.BitSet, error)

AggregateSignatureAndValidatorBitSet aggregates signature from multiple votes, and marks the bitset of validators who contribute votes

func CalculateEventHash

func CalculateEventHash(event *model.Event, chainId string) []byte

func DtoToEntity

func DtoToEntity(v *model.Vote) (*votepool.Vote, error)

func EntityToDto

func EntityToDto(from *votepool.Vote, challengeId uint64) *model.Vote

Types

type DataHandler

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

func NewDataHandler

func NewDataHandler(daoManager *dao.DaoManager, executor *executor.Executor) *DataHandler

func (*DataHandler) FetchEventsForCollate

func (h *DataHandler) FetchEventsForCollate(currentHeight uint64) ([]*model.Event, error)

func (*DataHandler) FetchEventsForSelfVote

func (h *DataHandler) FetchEventsForSelfVote(currentHeight uint64) ([]*model.Event, uint64, error)

func (*DataHandler) FetchVotesForCollate

func (h *DataHandler) FetchVotesForCollate(eventHash string) ([]*model.Vote, error)

func (*DataHandler) IsVoteExists

func (h *DataHandler) IsVoteExists(eventHash string, pubKey string) (bool, error)

func (*DataHandler) SaveVote

func (h *DataHandler) SaveVote(vote *model.Vote) error

func (*DataHandler) SaveVoteAndUpdateEventStatus

func (h *DataHandler) SaveVoteAndUpdateEventStatus(vote *model.Vote, challengeId uint64) error

func (*DataHandler) UpdateEventStatus

func (h *DataHandler) UpdateEventStatus(challengeId uint64, status model.EventStatus) error

type DataProvider

type DataProvider interface {
	FetchEventsForSelfVote(currentHeight uint64) ([]*model.Event, uint64, error)
	FetchEventsForCollate(currentHeight uint64) ([]*model.Event, error)
	FetchVotesForCollate(eventHash string) ([]*model.Vote, error)
	UpdateEventStatus(challengeId uint64, status model.EventStatus) error
	SaveVote(vote *model.Vote) error
	SaveVoteAndUpdateEventStatus(vote *model.Vote, challengeId uint64) error
	IsVoteExists(eventHash string, pubKey string) (bool, error)
}

type VoteBroadcaster

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

func NewVoteBroadcaster

func NewVoteBroadcaster(cfg *config.Config, signer *VoteSigner,
	executor *executor.Executor, broadcasterDataProvider DataProvider, metricService *metrics.MetricService,
) *VoteBroadcaster

func (*VoteBroadcaster) BroadcastVotesLoop

func (p *VoteBroadcaster) BroadcastVotesLoop()

type VoteCollator

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

func NewVoteCollator

func NewVoteCollator(cfg *config.Config, signer *VoteSigner,
	executor *executor.Executor, collatorDataProvider DataProvider, metricService *metrics.MetricService,
) *VoteCollator

func (*VoteCollator) CollateVotesLoop

func (p *VoteCollator) CollateVotesLoop()

type VoteCollector

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

func NewVoteCollector

func NewVoteCollector(cfg *config.Config, executor *executor.Executor, collectorDataProvider DataProvider, metricService *metrics.MetricService) *VoteCollector

func (*VoteCollector) CollectVotesLoop

func (p *VoteCollector) CollectVotesLoop()

type VoteSigner

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

func NewVoteSigner

func NewVoteSigner(pk []byte) *VoteSigner

func (*VoteSigner) SignVote

func (signer *VoteSigner) SignVote(vote *votepool.Vote, data []byte)

SignVote sign a vote, data is used to sign and generate the signature