stakingindex

type Bucket struct {
	Candidate    address.Address
	Owner        address.Address
	StakedAmount *big.Int

	// Timestamped indicates whether the bucket time is in block height or timestamp
	Timestamped bool

	// these fields value are determined by the timestamped field
	StakedDuration uint64 // in seconds if timestamped, in block number if not
	CreatedAt      uint64 // in unix timestamp if timestamped, in block height if not
	UnlockedAt     uint64 // in unix timestamp if timestamped, in block height if not
	UnstakedAt     uint64 // in unix timestamp if timestamped, in block height if not

	// Muted indicates whether the bucket is vote weight muted
	Muted bool
}

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

type IndexerOption func(*Indexer)

type StakingIndexer interface {
	lifecycle.StartStopper
	Height() (uint64, error)
	StartHeight() uint64
	ContractAddress() string
	Buckets(height uint64) ([]*VoteBucket, error)
	Bucket(id uint64, height uint64) (*VoteBucket, bool, error)
	BucketsByIndices(indices []uint64, height uint64) ([]*VoteBucket, error)
	BucketsByCandidate(candidate address.Address, height uint64) ([]*VoteBucket, error)
	TotalBucketCount(height uint64) (uint64, error)
	PutBlock(ctx context.Context, blk *block.Block) error
}

type VoteBucket = staking.VoteBucket