votesync

Documentation

Index

• Constants
• func NewAgentContract(cli iotex.AuthedClient, addr address.Address) (*agentContract, error)
• func NewBrokerContract(cli iotex.AuthedClient, addr address.Address, batchSize uint8) (*brokerContract, error)
• func NewClerkContract(cli iotex.AuthedClient, addr address.Address) (*clerkContract, error)
• func NewIoTeXClient(client iotexapi.APIServiceClient) *iotexClient
• func NewRotatableWeightedVPS(cli iotex.AuthedClient, addr address.Address, batchSize uint8) (*rwvps, error)
• func NewVitaContract(cli iotex.AuthedClient, addr address.Address) (*vitaContract, error)
• type Config
• type VoteFetcher
  • func (fetcher *VoteFetcher) FetchBucketsByHeight(ctx context.Context, h uint64) (*iotextypes.VoteBucketList, *iotextypes.CandidateListV2, error)
• type VoteSync
  • func NewVoteSync(cfg Config) (*VoteSync, error)
  • func (vc *VoteSync) ProofForAccount(acct address.Address) (*big.Int, *big.Int, []byte, error)
  • func (vc *VoteSync) Start(ctx context.Context)
  • func (vc *VoteSync) Stop(ctx context.Context)
• type VotingPowers
  • func (vp *VotingPowers) Total() *big.Int
  • func (vp *VotingPowers) Update(cycle *big.Int, total *big.Int, votingPowers map[common.Address]*big.Int)
  • func (vp *VotingPowers) VotingPower(acct common.Address) (*big.Int, *big.Int)
• type WeightedVote

Constants

const (
	// PollProtocolID is ID of poll protocol
	PollProtocolID = "poll"
)

Functions

func NewAgentContract

func NewAgentContract(cli iotex.AuthedClient, addr address.Address) (*agentContract, error)

func NewBrokerContract

func NewBrokerContract(cli iotex.AuthedClient, addr address.Address, batchSize uint8) (*brokerContract, error)

func NewClerkContract

func NewClerkContract(cli iotex.AuthedClient, addr address.Address) (*clerkContract, error)

func NewIoTeXClient

func NewIoTeXClient(client iotexapi.APIServiceClient) *iotexClient

func NewRotatableWeightedVPS

func NewRotatableWeightedVPS(cli iotex.AuthedClient, addr address.Address, batchSize uint8) (*rwvps, error)

func NewVitaContract

func NewVitaContract(cli iotex.AuthedClient, addr address.Address) (*vitaContract, error)

Types

type Config

type Config struct {
	GravityChainAPIs          []string      `yaml:"gravityChainAPIs"`
	GravityChainTimeInterval  time.Duration `yaml:"gravityChainTimeInterval"`
	OperatorPrivateKey        string        `yaml:"operatorPrivateKey"`
	IoTeXAPI                  string        `yaml:"ioTeXAPI"`
	IoTeXAPISecure            bool          `yaml:"ioTeXAPISecure"`
	RegisterContractAddress   string        `yaml:"registerContractAddress"`
	StakingContractAddress    string        `yaml:"stakingContractAddress"`
	PaginationSize            uint8         `yaml:"paginationSize"`
	BrokerPaginationSize      uint8         `yaml:"brokerPaginationSize"`
	VitaContractAddress       string        `yaml:"vitaContractAddress"`
	DiscordBotToken           string        `yaml:"discordBotToken"`
	DiscordChannelID          string        `yaml:"discordChannelID"`
	DiscordMsg                string        `yaml:"discordMsg"`
	DiscordReminder           string        `yaml:"discordReminder"`
	DardanellesHeight         uint64        `yaml:"dardanellesHeight"`
	FairBankHeight            uint64        `yaml:"fairbankHeight"`
	NativeCommitteeInitHeight uint64        `yaml:"nativeCommitteeInitHeight"`
	EnableAgentMode           bool          `yaml:"enableAgentMode"`
	AgentContractAddress      string        `yaml:"agentContractAddress"`
}

Config defines the configs for VoteSync

type VoteFetcher

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

VoteFetcher defines fields used to fetch votes

func (*VoteFetcher) FetchBucketsByHeight

func (fetcher *VoteFetcher) FetchBucketsByHeight(ctx context.Context, h uint64) (*iotextypes.VoteBucketList, *iotextypes.CandidateListV2, error)

type VoteSync

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

VoteSync defines fields used in VoteSync

func NewVoteSync

func NewVoteSync(cfg Config) (*VoteSync, error)

NewVoteSync instantiates new VoteSync

func (*VoteSync) ProofForAccount

func (vc *VoteSync) ProofForAccount(acct address.Address) (*big.Int, *big.Int, []byte, error)

func (*VoteSync) Start

func (vc *VoteSync) Start(ctx context.Context)

Start starts voteSync

func (*VoteSync) Stop

func (vc *VoteSync) Stop(ctx context.Context)

Stop stops voteSync

type VotingPowers

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

func (*VotingPowers) Total

func (vp *VotingPowers) Total() *big.Int

func (*VotingPowers) Update

func (vp *VotingPowers) Update(cycle *big.Int, total *big.Int, votingPowers map[common.Address]*big.Int)

func (*VotingPowers) VotingPower

func (vp *VotingPowers) VotingPower(acct common.Address) (*big.Int, *big.Int)

type WeightedVote

type WeightedVote struct {
	Voter string
	Votes *big.Int
}

WeightedVote defines voter and votes for weighted vote