vote

package

v1.1.0 Latest Latest Go to latest Published: Nov 14, 2023 License: AGPL-3.0 Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bnb-chain/greenfield-challenger

Links

Open Source Insights

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 ¶

View Source

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
)

Variables ¶

This section is empty.

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 ¶ added in v0.0.2

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 ¶ added in v0.0.2

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

Source Files ¶

View all Source files

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