store

package

Go to main page

Versions in this module

v0

v0.10.3

Feb 4, 2022

v0.10.2

Jan 13, 2022

v0.10.2-rc5

Dec 29, 2021

v0.10.2-rc4

Dec 29, 2021

v0.10.2-rc3

Dec 29, 2021

v0.10.2-rc2

Dec 29, 2021

v0.10.2-rc1

Dec 28, 2021

v0.10.1

Nov 12, 2021

v0.10.0

Oct 27, 2021

v0.9.0

Jun 28, 2021

v0.8.9

Jun 12, 2021

v0.8.8

May 28, 2021

Changes in this version

type ValidatorSummaryStore

+ FindAllByTimePeriod func(start, end *types.Time, addresses ...string) ([]model.ValidatorSummary, error)

v0.8.7

Apr 12, 2021

v0.8.6

Mar 29, 2021

Changes in this version

type BalanceSummaryStore

+ GetSummariesByInterval func(interval types.SummaryInterval, address string, start, end *types.Time) ([]model.BalanceSummary, error)

v0.8.5

Mar 3, 2021

v0.8.4

Mar 3, 2021

Changes in this version

type SyncablesStore

+ GetSyncableForMinTime func(time time.Time) (result *model.Syncable, err error)

v0.8.3

Oct 21, 2020

v0.8.2

Oct 21, 2020

v0.8.1

Oct 21, 2020

v0.8.0

Oct 16, 2020

v0.7.1

Oct 16, 2020

v0.7.0

Oct 16, 2020

v0.6.0

Sep 18, 2020

Changes in this version

+ func NewBalanceEventsStore(db *gorm.DB) *balanceEventsStore

+ func NewBalanceSummaryStore(db *gorm.DB) *balanceSummaryStore

+ type BalanceEventsStore interface

+ CreateOrUpdate func(*model.BalanceEvent) error

+ DeleteOlderThan func(time.Time) (*int64, error)

+ GetLastEventTime func() (types.Time, error)

+ Summarize func(types.SummaryInterval, []ActivityPeriodRow) ([]model.BalanceSummary, error)

+ type BalanceSummaryStore interface

+ Find func(*model.BalanceSummary) (*model.BalanceSummary, error)

+ FindActivityPeriods func(types.SummaryInterval, int64) ([]ActivityPeriodRow, error)

+ GetDailySummaries func(address, start, end string) ([]model.BalanceSummary, error)

type Store

+ BalanceEvents BalanceEventsStore

+ BalanceSummary BalanceSummaryStore

v0.5.2

Aug 19, 2020

v0.5.1

Aug 8, 2020

v0.5.0

Jul 31, 2020

Changes in this version

+ func NewSystemEventsStore(db *gorm.DB) *systemEventsStore

+ type BaseStore interface

+ Create func(record interface{}) error

+ Save func(record interface{}) error

+ Update func(record interface{}) error

+ type FindSystemEventByActorQuery struct

+ Kind *model.SystemEventKind

+ MinHeight *int64

type ReportsStore

+ DeleteByKinds func([]model.ReportKind) error

type Store

+ SystemEvents SystemEventsStore

type SyncablesStore

+ FindSmallestIndexVersion func() (*int64, error)

+ ResetProcessedAtForRange func(int64, int64) error

+ type SystemEventsStore interface

+ CreateOrUpdate func(*model.SystemEvent) error

+ DeleteOlderThan func(time.Time) (*int64, error)

+ FindByActor func(string, FindSystemEventByActorQuery) ([]model.SystemEvent, error)

+ FindByHeight func(int64) ([]model.SystemEvent, error)

+ FindMostRecent func() (*model.SystemEvent, error)

+ FindUnique func(int64, string, model.SystemEventKind) (*model.SystemEvent, error)

type ValidatorSeqSummary

+ ActiveEscrowBalanceAvg types.Quantity

+ ActiveEscrowBalanceMax types.Quantity

+ ActiveEscrowBalanceMin types.Quantity

+ CommissionAvg types.Quantity

+ CommissionMax types.Quantity

+ CommissionMin types.Quantity

type ValidatorSummaryRow

+ ActiveEscrowBalanceAvg types.Quantity

+ ActiveEscrowBalanceMax types.Quantity

+ ActiveEscrowBalanceMin types.Quantity

+ CommissionAvg types.Quantity

+ CommissionMax types.Quantity

+ CommissionMin types.Quantity

v0.4.4

Jun 25, 2020

v0.4.3

Jun 20, 2020

v0.4.2

Jun 20, 2020

Changes in this version

+ type ActivityPeriodRow struct

+ Max types.Time

+ Min types.Time

+ Period int64

type BlockSummaryStore

+ func (s *BlockSummaryStore) FindActivityPeriods(interval types.SummaryInterval, indexVersion int64) ([]ActivityPeriodRow, error)

type ReportsStore

+ func (s *ReportsStore) DeleteReindexing() error

+ func (s ReportsStore) FindNotCompletedByIndexVersion(indexVersion int64, kinds ...model.ReportKind) (*model.Report, error)

+ func (s ReportsStore) FindNotCompletedByKind(kinds ...model.ReportKind) (*model.Report, error)

type SyncablesStore

+ func (s SyncablesStore) FindFirstByDifferentIndexVersion(indexVersion int64) (*model.Syncable, error)

+ func (s SyncablesStore) FindMostRecentByDifferentIndexVersion(indexVersion int64) (*model.Syncable, error)

+ func (s SyncablesStore) SetProcessedAtForRange(reportID types.ID, startHeight int64, endHeight int64) error

type ValidatorAggStore

+ func (s *ValidatorAggStore) FindByAddress(address string) (*model.ValidatorAgg, error)

type ValidatorSeqStore

+ func (s ValidatorSeqStore) CreateOrUpdate(val *model.ValidatorSeq) error

+ func (s ValidatorSeqStore) FindByHeightAndEntityUID(h int64, key string) (*model.ValidatorSeq, error)

+ func (s ValidatorSeqStore) FindLastByAddress(address string, limit int64) ([]model.ValidatorSeq, error)

type ValidatorSeqSummary

+ Address string

type ValidatorSummaryStore

+ func (s *ValidatorSummaryStore) FindActivityPeriods(interval types.SummaryInterval, indexVersion int64) ([]ActivityPeriodRow, error)

+ func (s *ValidatorSummaryStore) FindSummaryByAddress(address string, interval types.SummaryInterval, period string) ([]model.ValidatorSummary, error)

v0.4.0

Jun 9, 2020

Changes in this version

type BlockSeqStore

+ func (s *BlockSeqStore) DeleteOlderThan(purgeThreshold time.Time) (*int64, error)

+ func (s *BlockSeqStore) FindMostRecent() (*model.BlockSeq, error)

+ func (s *BlockSeqStore) Summarize(interval types.SummaryInterval, last *model.BlockSummary) ([]BlockSeqSummary, error)

+ type BlockSeqSummary struct

+ BlockTimeAvg float64

+ Count int64

+ TimeBucket types.Time

+ type BlockSummaryStore struct

+ func NewBlockSummaryStore(db *gorm.DB) *BlockSummaryStore

+ func (s *BlockSummaryStore) DeleteOlderThan(interval types.SummaryInterval, purgeThreshold time.Time) (*int64, error)

+ func (s *BlockSummaryStore) FindMostRecent() (*model.BlockSummary, error)

+ func (s *BlockSummaryStore) FindMostRecentByInterval(interval types.SummaryInterval) (*model.BlockSummary, error)

+ func (s *BlockSummaryStore) FindSummary(interval types.SummaryInterval, period string) ([]model.BlockSummary, error)

+ func (s BlockSummaryStore) Create(record interface{}) error

+ func (s BlockSummaryStore) DeleteByHeight(height int64) error

+ func (s BlockSummaryStore) Find(query *model.BlockSummary) (*model.BlockSummary, error)

+ func (s BlockSummaryStore) Save(record interface{}) error

+ func (s BlockSummaryStore) Truncate() error

+ func (s BlockSummaryStore) Update(record interface{}) error

+ type DatabaseStore struct

+ func NewDatabaseStore(db *gorm.DB) *DatabaseStore

+ func (s *DatabaseStore) GetTotalSize() (*GetTotalSizeResult, error)

+ type GetTotalSizeResult struct

+ Size float64

type Store

+ BlockSummary *BlockSummaryStore

+ Database *DatabaseStore

+ ValidatorSummary *ValidatorSummaryStore

type ValidatorSeqStore

+ func (s *ValidatorSeqStore) DeleteOlderThan(purgeThreshold time.Time) (*int64, error)

+ func (s *ValidatorSeqStore) FindMostRecent() (*model.ValidatorSeq, error)

+ func (s *ValidatorSeqStore) Summarize(interval types.SummaryInterval, last *model.ValidatorSummary) ([]ValidatorSeqSummary, error)

+ func (s ValidatorSeqStore) FindLastByEntityUID(key string, limit int64) ([]model.ValidatorSeq, error)

+ type ValidatorSeqSummary struct

+ EntityUID string

+ NotValidatedSum int64

+ ProposedSum int64

+ TimeBucket types.Time

+ TotalSharesAvg types.Quantity

+ TotalSharesMax types.Quantity

+ TotalSharesMin types.Quantity

+ UptimeAvg float64

+ ValidatedSum int64

+ VotingPowerAvg float64

+ VotingPowerMax float64

+ VotingPowerMin float64

+ type ValidatorSummaryRow struct

+ NotValidatedSum int64

+ ProposedSum int64

+ TimeBucket string

+ TimeInterval string

+ TotalSharesAvg types.Quantity

+ TotalSharesMax types.Quantity

+ TotalSharesMin types.Quantity

+ UptimeAvg float64

+ ValidatedSum int64

+ VotingPowerAvg float64

+ VotingPowerMax float64

+ VotingPowerMin float64

+ type ValidatorSummaryStore struct

+ func NewValidatorSummaryStore(db *gorm.DB) *ValidatorSummaryStore

+ func (s *ValidatorSummaryStore) DeleteOlderThan(interval types.SummaryInterval, purgeThreshold time.Time) (*int64, error)

+ func (s *ValidatorSummaryStore) FindMostRecent() (*model.ValidatorSummary, error)

+ func (s *ValidatorSummaryStore) FindMostRecentByInterval(interval types.SummaryInterval) (*model.ValidatorSummary, error)

+ func (s *ValidatorSummaryStore) FindSummary(interval types.SummaryInterval, period string) ([]ValidatorSummaryRow, error)

+ func (s *ValidatorSummaryStore) FindSummaryByEntityUID(key string, interval types.SummaryInterval, period string) ([]model.ValidatorSummary, error)

+ func (s ValidatorSummaryStore) Create(record interface{}) error

+ func (s ValidatorSummaryStore) DeleteByHeight(height int64) error

+ func (s ValidatorSummaryStore) Find(query *model.ValidatorSummary) (*model.ValidatorSummary, error)

+ func (s ValidatorSummaryStore) FindByEntityUID(key string) ([]model.ValidatorSummary, error)

+ func (s ValidatorSummaryStore) Save(record interface{}) error

+ func (s ValidatorSummaryStore) Truncate() error

+ func (s ValidatorSummaryStore) Update(record interface{}) error

v0.3.3

May 28, 2020

v0.3.2

May 28, 2020

v0.3.1

May 27, 2020

v0.3.0

May 27, 2020

Changes in this version

+ var ErrNotFound = errors.New("record not found")

+ type AccountAggStore struct

+ func NewAccountAggStore(db *gorm.DB) *AccountAggStore

+ func (s AccountAggStore) All() ([]model.AccountAgg, error)

+ func (s AccountAggStore) Create(record interface{}) error

+ func (s AccountAggStore) CreateOrUpdate(acc *model.AccountAgg) error

+ func (s AccountAggStore) DeleteByHeight(height int64) error

+ func (s AccountAggStore) FindBy(key string, value interface{}) (*model.AccountAgg, error)

+ func (s AccountAggStore) FindByID(id int64) (*model.AccountAgg, error)

+ func (s AccountAggStore) FindByPublicKey(key string) (*model.AccountAgg, error)

+ func (s AccountAggStore) Save(record interface{}) error

+ func (s AccountAggStore) Truncate() error

+ func (s AccountAggStore) Update(record interface{}) error

+ type AvgForTimeIntervalRow struct

+ Avg float64

+ TimeInterval string

+ type AvgQuantityForTimeIntervalRow struct

+ Avg types.Quantity

+ TimeInterval string

+ type BlockSeqStore struct

+ func NewBlockSeqStore(db *gorm.DB) *BlockSeqStore

+ func (s *BlockSeqStore) GetAvgRecentTimes(limit int64) GetAvgRecentTimesResult

+ func (s *BlockSeqStore) GetAvgTimesForInterval(interval string, period string) ([]GetAvgTimesForIntervalRow, error)

+ func (s BlockSeqStore) Create(record interface{}) error

+ func (s BlockSeqStore) CreateIfNotExists(block *model.BlockSeq) error

+ func (s BlockSeqStore) DeleteByHeight(height int64) error

+ func (s BlockSeqStore) FindBy(key string, value interface{}) (*model.BlockSeq, error)

+ func (s BlockSeqStore) FindByHeight(height int64) (*model.BlockSeq, error)

+ func (s BlockSeqStore) FindByID(id int64) (*model.BlockSeq, error)

+ func (s BlockSeqStore) Save(record interface{}) error

+ func (s BlockSeqStore) Truncate() error

+ func (s BlockSeqStore) Update(record interface{}) error

+ type DebondingDelegationSeqStore struct

+ func NewDebondingDelegationSeqStore(db *gorm.DB) *DebondingDelegationSeqStore

+ func (s *DebondingDelegationSeqStore) FindRecentByDelegatorUID(key string, limit int64) ([]model.DebondingDelegationSeq, error)

+ func (s *DebondingDelegationSeqStore) FindRecentByValidatorUID(key string, limit int64) ([]model.DebondingDelegationSeq, error)

+ func (s DebondingDelegationSeqStore) Create(record interface{}) error

+ func (s DebondingDelegationSeqStore) CreateIfNotExists(debondingDelegation *model.DebondingDelegationSeq) error

+ func (s DebondingDelegationSeqStore) DeleteByHeight(height int64) error

+ func (s DebondingDelegationSeqStore) FindByHeight(h int64) ([]model.DebondingDelegationSeq, error)

+ func (s DebondingDelegationSeqStore) Save(record interface{}) error

+ func (s DebondingDelegationSeqStore) Truncate() error

+ func (s DebondingDelegationSeqStore) Update(record interface{}) error

+ type DelegationSeqStore struct

+ func NewDelegationSeqStore(db *gorm.DB) *DelegationSeqStore

+ func (s *DelegationSeqStore) FindCurrentByDelegatorUID(key string) ([]model.DelegationSeq, error)

+ func (s *DelegationSeqStore) FindLastByValidatorUID(key string) ([]model.DelegationSeq, error)

+ func (s DelegationSeqStore) Create(record interface{}) error

+ func (s DelegationSeqStore) CreateIfNotExists(delegation *model.DelegationSeq) error

+ func (s DelegationSeqStore) DeleteByHeight(height int64) error

+ func (s DelegationSeqStore) FindByHeight(h int64) ([]model.DelegationSeq, error)

+ func (s DelegationSeqStore) Save(record interface{}) error

+ func (s DelegationSeqStore) Truncate() error

+ func (s DelegationSeqStore) Update(record interface{}) error

+ type GetAvgRecentTimesResult struct

+ Avg float64

+ Count int64

+ Diff float64

+ EndHeight int64

+ EndTime string

+ StartHeight int64

+ StartTime string

+ type GetAvgTimesForIntervalRow struct

+ Avg float64

+ Count int64

+ TimeInterval string

+ type ReportsStore struct

+ func NewReportsStore(db *gorm.DB) *ReportsStore

+ func (s ReportsStore) Create(record interface{}) error

+ func (s ReportsStore) DeleteByHeight(height int64) error

+ func (s ReportsStore) Last() (*model.Report, error)

+ func (s ReportsStore) Save(record interface{}) error

+ func (s ReportsStore) Truncate() error

+ func (s ReportsStore) Update(record interface{}) error

+ type StakingSeqStore struct

+ func NewStakingSeqStore(db *gorm.DB) *StakingSeqStore

+ func (s StakingSeqStore) Create(record interface{}) error

+ func (s StakingSeqStore) CreateIfNotExists(staking *model.StakingSeq) error

+ func (s StakingSeqStore) DeleteByHeight(height int64) error

+ func (s StakingSeqStore) FindBy(key string, value interface{}) (*model.StakingSeq, error)

+ func (s StakingSeqStore) FindByHeight(height int64) (*model.StakingSeq, error)

+ func (s StakingSeqStore) FindByID(id int64) (*model.StakingSeq, error)

+ func (s StakingSeqStore) Recent() (*model.StakingSeq, error)

+ func (s StakingSeqStore) Save(record interface{}) error

+ func (s StakingSeqStore) Truncate() error

+ func (s StakingSeqStore) Update(record interface{}) error

+ type Store struct

+ AccountAgg *AccountAggStore

+ BlockSeq *BlockSeqStore

+ DebondingDelegationSeq *DebondingDelegationSeqStore

+ DelegationSeq *DelegationSeqStore

+ Reports *ReportsStore

+ StakingSeq *StakingSeqStore

+ Syncables *SyncablesStore

+ TransactionSeq *TransactionSeqStore

+ ValidatorAgg *ValidatorAggStore

+ ValidatorSeq *ValidatorSeqStore

+ func New(connStr string) (*Store, error)

+ func (s *Store) Close() error

+ func (s *Store) SetDebugMode(enabled bool)

+ func (s *Store) Test() error

+ type SyncablesStore struct

+ func NewSyncablesStore(db *gorm.DB) *SyncablesStore

+ func (s SyncablesStore) Create(record interface{}) error

+ func (s SyncablesStore) CreateOrUpdate(val *model.Syncable) error

+ func (s SyncablesStore) DeleteByHeight(height int64) error

+ func (s SyncablesStore) FindByHeight(height int64) (syncable *model.Syncable, err error)

+ func (s SyncablesStore) FindMostRecent() (*model.Syncable, error)

+ func (s SyncablesStore) Save(record interface{}) error

+ func (s SyncablesStore) Truncate() error

+ func (s SyncablesStore) Update(record interface{}) error

+ type TransactionSeqStore struct

+ func NewTransactionSeqStore(db *gorm.DB) *TransactionSeqStore

+ func (s TransactionSeqStore) Create(record interface{}) error

+ func (s TransactionSeqStore) CreateIfNotExists(transaction *model.TransactionSeq) error

+ func (s TransactionSeqStore) DeleteByHeight(height int64) error

+ func (s TransactionSeqStore) FindByHeight(h int64) ([]model.TransactionSeq, error)

+ func (s TransactionSeqStore) Save(record interface{}) error

+ func (s TransactionSeqStore) Truncate() error

+ func (s TransactionSeqStore) Update(record interface{}) error

+ type ValidatorAggStore struct

+ func NewValidatorAggStore(db *gorm.DB) *ValidatorAggStore

+ func (s *ValidatorAggStore) FindByEntityUID(key string) (*model.ValidatorAgg, error)

+ func (s *ValidatorAggStore) GetAllForHeightGreaterThan(height int64) ([]model.ValidatorAgg, error)

+ func (s ValidatorAggStore) All() ([]model.ValidatorAgg, error)

+ func (s ValidatorAggStore) Create(record interface{}) error

+ func (s ValidatorAggStore) CreateOrUpdate(val *model.ValidatorAgg) error

+ func (s ValidatorAggStore) DeleteByHeight(height int64) error

+ func (s ValidatorAggStore) FindBy(key string, value interface{}) (*model.ValidatorAgg, error)

+ func (s ValidatorAggStore) FindByID(id int64) (*model.ValidatorAgg, error)

+ func (s ValidatorAggStore) Save(record interface{}) error

+ func (s ValidatorAggStore) Truncate() error

+ func (s ValidatorAggStore) Update(record interface{}) error

+ type ValidatorSeqStore struct

+ func NewValidatorSeqStore(db *gorm.DB) *ValidatorSeqStore

+ func (s *ValidatorSeqStore) GetTotalMissedByEntityUID(key string) (*int64, error)

+ func (s *ValidatorSeqStore) GetTotalProposedByEntityUID(key string) (*int64, error)

+ func (s *ValidatorSeqStore) GetTotalSharesForInterval(interval string, period string) ([]AvgQuantityForTimeIntervalRow, error)

+ func (s *ValidatorSeqStore) GetTotalValidatedByEntityUID(key string) (*int64, error)

+ func (s *ValidatorSeqStore) GetTotalVotingPowerForInterval(interval string, period string) ([]AvgForTimeIntervalRow, error)

+ func (s *ValidatorSeqStore) GetValidatorSharesForInterval(key string, interval string, period string) ([]AvgQuantityForTimeIntervalRow, error)

+ func (s *ValidatorSeqStore) GetValidatorUptimeForInterval(key string, interval string, period string) ([]AvgForTimeIntervalRow, error)

+ func (s *ValidatorSeqStore) GetValidatorVotingPowerForInterval(key string, interval string, period string) ([]AvgForTimeIntervalRow, error)

+ func (s ValidatorSeqStore) Create(record interface{}) error

+ func (s ValidatorSeqStore) CreateIfNotExists(validator *model.ValidatorSeq) error

+ func (s ValidatorSeqStore) DeleteByHeight(height int64) error

+ func (s ValidatorSeqStore) FindByHeight(h int64) ([]model.ValidatorSeq, error)

+ func (s ValidatorSeqStore) Save(record interface{}) error

+ func (s ValidatorSeqStore) Truncate() error

+ func (s ValidatorSeqStore) Update(record interface{}) error

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