committee

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

type CalcGravityChainHeight func(uint64) (uint64, error)

type Committee interface {
	// Start starts the committee service
	Start(context.Context) error
	// Stop stops the committee service
	Stop(context.Context) error
	// ResultByHeight returns the result on a specific ethereum height
	ResultByHeight(uint64) (*types.ElectionResult, error)
	//RawDataByHeight returns the bucket list and registration list and mintTime
	RawDataByHeight(uint64) ([]*types.Bucket, []*types.Registration, time.Time, error)
	// HeightByTime returns the nearest result before time
	HeightByTime(time.Time) (uint64, error)
	// LatestHeight returns the height with latest result
	LatestHeight() uint64
	// Status returns the committee status
	Status() STATUS
	// PutNativePollByEpoch puts one native poll record on IoTeX chain
	PutNativePollByEpoch(uint64, time.Time, []*types.Bucket) error
	// NativeBucketsByEpoch returns a list of Bucket of a given epoch number
	NativeBucketsByEpoch(uint64) ([]*types.Bucket, error)
}

type Config struct {
	NumOfRetries               uint8    `yaml:"numOfRetries"`
	GravityChainAPIs           []string `yaml:"gravityChainAPIs"`
	GravityChainHeightInterval uint64   `yaml:"gravityChainHeightInterval"`
	GravityChainStartHeight    uint64   `yaml:"gravityChainStartHeight"`
	GravityChainCeilingHeight  uint64   `yaml:"gravityChainCeilingHeight"`
	RegisterContractAddress    string   `yaml:"registerContractAddress"`
	StakingContractAddress     string   `yaml:"stakingContractAddress"`
	PaginationSize             uint8    `yaml:"paginationSize"`
	VoteThreshold              string   `yaml:"voteThreshold"`
	ScoreThreshold             string   `yaml:"scoreThreshold"`
	SelfStakingThreshold       string   `yaml:"selfStakingThreshold"`
	CacheSize                  uint32   `yaml:"cacheSize"`
	NumOfFetchInParallel       uint8    `yaml:"numOfFetchInParallel"`
	SkipManifiedCandidate      bool     `yaml:"skipManifiedCandidate"`
	GravityChainBatchSize      uint64   `yaml:"gravityChainBatchSize"`
}

type DRIVERTYPE uint8

type InsertDeltaRecordsFunc func(string, DRIVERTYPE, interface{}, *sql.Tx) (
	map[hash.Hash256]int,
	map[int64]hash.Hash256,
	error,
)

type InsertRecordsFunc func(string, DRIVERTYPE, interface{}, *sql.Tx) (map[hash.Hash256]int, error)

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

type NativeCommitteeConfig struct {
	StakingContractAddress string `yaml:"stakingContractAddress"`
	IoTeXAPI               string `yaml:"iotexAPI"`
	StartHeight            uint64 `yaml:"startHeight"`
	Interval               uint64 `yaml:"interval"`
}

type Operator interface {
	// CreateTables prepares the tables for the operator
	CreateTables(*sql.Tx) error
	// Get returns the value by height
	Get(uint64, *sql.DB, *sql.Tx) (interface{}, error)
	// Put writes value for height
	Put(uint64, interface{}, *sql.Tx) error
	// TipHeight returns the tip height
	TipHeight(*sql.DB, *sql.Tx) (uint64, error)
}

type PollArchive interface {
	HeightBefore(time.Time) (uint64, error)
	// Buckets returns a list of Bucket of a given height
	Buckets(uint64) ([]*types.Bucket, error)
	// NativeBuckets returns a list of Bucket of a given epoch number
	NativeBuckets(uint64) ([]*types.Bucket, error)
	// Registrations returns a list of Registration of a given height
	Registrations(uint64) ([]*types.Registration, error)
	// MintTime returns the mint time of a given height
	MintTime(uint64) (time.Time, error)
	// NativeMintTime returns the mint time of a given epoch number
	NativeMintTime(uint64) (time.Time, error)
	// PutPoll puts one poll record
	PutPoll(uint64, time.Time, []*types.Registration, []*types.Bucket) error
	// PutNativePoll puts one native poll record on IoTeX chain
	PutNativePoll(uint64, time.Time, []*types.Bucket) error
	// TipHeight returns the tip height stored in archive
	TipHeight() (uint64, error)
	// Start starts the archive
	Start(context.Context) error
	// Stop stops the archive
	Stop(context.Context) error
}

type QueryRecordsFunc func(string, map[int64]int, *sql.DB, *sql.Tx) (interface{}, error)

type Record interface {
	Hash() (hash.Hash256, error)
}

type STATUS uint8

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