committee

package

Go to main page

Versions in this module

v0

v0.3.6

Sep 7, 2023

v0.3.5

Oct 2, 2022

v0.3.4

Aug 10, 2020

v0.3.2

Jul 14, 2020

v0.2.18

May 14, 2020

v0.2.17

Apr 24, 2020

Changes in this version

type Config

+ GravityChainCeilingHeight uint64

v0.2.16

Feb 22, 2020

v0.2.15

Feb 22, 2020

v0.2.14

Feb 21, 2020

Changes in this version

+ func InsertDeltaBuckets(tableName string, driverName DRIVERTYPE, records interface{}, tx *sql.Tx) (frequencies map[hash.Hash256]int, indexes map[int64]hash.Hash256, err error)

+ type BucketArchive struct

+ func NewBucketArchive(dbPath string, numOfRetries uint8, startHeight uint64, interval uint64) (*BucketArchive, error)

+ func (arch *BucketArchive) Buckets(height uint64) ([]*types.Bucket, error)

+ func (arch *BucketArchive) MintTime(height uint64) (time.Time, error)

+ func (arch *BucketArchive) PutDelta(height uint64, ts time.Time, updatedBuckets []*pyggBucket) (err error)

+ func (arch *BucketArchive) Start(ctx context.Context) (err error)

+ func (arch *BucketArchive) Stop(_ context.Context) (err error)

+ func (arch *BucketArchive) TipHeight() (uint64, error)

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

+ type NativeCommittee struct

+ func NewNativeStakingCommittee(archive *BucketArchive, cfg NativeCommitteeConfig) (*NativeCommittee, error)

+ func (nc *NativeCommittee) DataByHeight(height uint64) (time.Time, []*types.Bucket, error)

+ func (nc *NativeCommittee) Start(ctx context.Context) error

+ func (nc *NativeCommittee) Status() STATUS

+ func (nc *NativeCommittee) Stop(ctx context.Context) error

+ func (nc *NativeCommittee) TipHeight() uint64

+ type NativeCommitteeConfig struct

+ Interval uint64

+ IoTeXAPI string

+ StakingContractAddress string

+ StartHeight uint64

type Operator

+ func NewDeltaBucketTableOperator(tableName string, driverName DRIVERTYPE) (Operator, error)

+ func NewDeltaRecordTableOperator(tableName string, driverName DRIVERTYPE, ...) (Operator, error)

+ TipHeight func(*sql.DB, *sql.Tx) (uint64, error)

v0.2.11

Nov 14, 2019

v0.2.10

Oct 31, 2019

v0.2.9

Oct 29, 2019

v0.2.8

Oct 23, 2019

Changes in this version

+ const EthHardForkHeight

+ const InsertBucketsQueryMySQL

+ const InsertBucketsQuerySQLITE

+ const InsertRegistrationQueryMySQL

+ const InsertRegistrationQuerySQLITE

v0.2.7

Oct 8, 2019

v0.2.6

Oct 8, 2019

Changes in this version

+ const InsertBucketsQueryMySql

+ const InsertRegistrationQueryMySql

+ type DRIVERTYPE uint8

+ const MYSQL

+ const SQLITE

v0.2.5

Oct 2, 2019

v0.2.4

Sep 30, 2019

v0.2.3

Sep 30, 2019

Changes in this version

+ const BucketRecordQuery

+ const InsertBucketsQuery

+ const InsertRegistrationQuery

+ const RegistrationQuery

+ func InsertBuckets(tableName string, records interface{}, tx *sql.Tx) (frequencies map[hash.Hash256]int, err error)

+ func InsertRegistrations(tableName string, records interface{}, tx *sql.Tx) (frequencies map[hash.Hash256]int, err error)

+ func QueryBuckets(tableName string, frequencies map[int64]int, sdb *sql.DB, tx *sql.Tx) (interface{}, error)

+ func QueryRegistrations(tableName string, frequencies map[int64]int, sdb *sql.DB, tx *sql.Tx) (interface{}, error)

type Committee

+ NativeBucketsByEpoch func(uint64) ([]*types.Bucket, error)

+ PutNativePollByEpoch func(uint64, time.Time, []*types.Bucket) error

+ RawDataByHeight func(uint64) ([]*types.Bucket, []*types.Registration, time.Time, error)

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

+ type Operator interface

+ CreateTables func(*sql.Tx) error

+ Get func(uint64, *sql.DB, *sql.Tx) (interface{}, error)

+ Put func(uint64, interface{}, *sql.Tx) error

+ func NewBucketTableOperator(tableName string, interval uint64) (Operator, error)

+ func NewRecordTableOperator(tableName string, interval uint64, insertRecordsFunc InsertRecordsFunc, ...) (Operator, error)

+ func NewRegistrationTableOperator(tableName string, interval uint64) (Operator, error)

+ type PollArchive interface

+ Buckets func(uint64) ([]*types.Bucket, error)

+ HeightBefore func(time.Time) (uint64, error)

+ MintTime func(uint64) (time.Time, error)

+ NativeBuckets func(uint64) ([]*types.Bucket, error)

+ NativeMintTime func(uint64) (time.Time, error)

+ PutNativePoll func(uint64, time.Time, []*types.Bucket) error

+ PutPoll func(uint64, time.Time, []*types.Registration, []*types.Bucket) error

+ Registrations func(uint64) ([]*types.Registration, error)

+ Start func(context.Context) error

+ Stop func(context.Context) error

+ TipHeight func() (uint64, error)

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

+ type Record interface

+ Hash func() (hash.Hash256, error)

+ type TimeTableOperator struct

+ func NewTimeTableOperator(tableName string) *TimeTableOperator

+ func (operator *TimeTableOperator) CreateTables(tx *sql.Tx) (err error)

+ func (operator *TimeTableOperator) Get(height uint64, sdb *sql.DB, tx *sql.Tx) (interface{}, error)

+ func (operator *TimeTableOperator) HeightBefore(ts time.Time, sdb *sql.DB, tx *sql.Tx) (height uint64, err error)

+ func (operator *TimeTableOperator) Put(height uint64, value interface{}, tx *sql.Tx) error

+ func (operator *TimeTableOperator) TipHeight(sdb *sql.DB, tx *sql.Tx) (uint64, error)

v0.2.2

Sep 20, 2019

v0.2.1

Sep 20, 2019

Changes in this version

+ type Archive interface

+ Buckets func(uint64) ([]*types.Bucket, error)

+ HeightBefore func(time.Time) (uint64, error)

+ MintTime func(uint64) (time.Time, error)

+ PutPoll func(uint64, time.Time, []*types.Registration, []*types.Bucket) error

+ PutPolls func([]uint64, []time.Time, [][]*types.Registration, [][]*types.Bucket) error

+ Registrations func(uint64) ([]*types.Registration, error)

+ Start func(context.Context) error

+ Stop func(context.Context) error

+ TipHeight func() (uint64, error)

+ func NewArchive(newDB *sql.DB, startHeight uint64, interval uint64, ...) (Archive, error)

v0.2.0

Sep 18, 2019

v0.1.18

Sep 12, 2019

v0.1.17

Jun 19, 2019

Changes in this version

type Config

+ GravityChainBatchSize uint64

v0.1.14

Jun 10, 2019

v0.1.13

Jun 10, 2019

v0.1.11

Jun 7, 2019

v0.1.10

May 22, 2019

v0.1.9

May 14, 2019

v0.1.8

Apr 30, 2019

v0.1.7

Apr 22, 2019

Changes in this version

type Config

+ SkipManifiedCandidate bool

v0.1.6

Apr 2, 2019

v0.1.5

Apr 2, 2019

Changes in this version

+ type CalcGravityChainHeight func(uint64) (uint64, error)

type Config

+ GravityChainAPIs []string

+ GravityChainHeightInterval uint64

+ GravityChainStartHeight uint64

v0.1.4

Mar 29, 2019

Changes in this version

type Committee

+ Status func() STATUS

type Config

+ NumOfFetchInParallel uint8

+ type STATUS uint8

+ const ACTIVE

+ const INACTIVE

+ const STARTING

v0.1.3

Mar 25, 2019

v0.1.2

Mar 25, 2019

Changes in this version

type Committee

+ FetchResultByHeight func(height uint64) (*types.ElectionResult, error)

v0.1.1

Mar 16, 2019

v0.1.0

Mar 14, 2019

Changes in this version

+ const Namespace

+ type CalcBeaconChainHeight func(uint64) (uint64, error)

+ type Committee interface

+ HeightByTime func(timestamp time.Time) (uint64, error)

+ LatestHeight func() uint64

+ ResultByHeight func(height uint64) (*types.ElectionResult, error)

+ Start func(context.Context) error

+ Stop func(context.Context) error

+ func NewCommittee(kvstore db.KVStore, cfg Config) (Committee, error)

+ func NewCommitteeWithKVStoreWithNamespace(kvstore db.KVStoreWithNamespace, cfg Config) (Committee, error)

+ type Config struct

+ BeaconChainAPIs []string

+ BeaconChainHeightInterval uint64

+ BeaconChainStartHeight uint64

+ CacheSize uint32

+ NumOfRetries uint8

+ PaginationSize uint8

+ RegisterContractAddress string

+ ScoreThreshold string

+ SelfStakingThreshold string

+ StakingContractAddress string

+ VoteThreshold string

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