psql

May 7, 2021

Changes in this version

type AccountEraSeqStore

+ func (s AccountEraSeqStore) GetAllByTime(stash string, start, end types.Time) ([]model.AccountEraSeq, error)

type RewardEraSeqStore

+ func (s RewardEraSeqStore) GetAllByTime(stash string, start, end types.Time) ([]model.RewardEraSeq, error)

Apr 2, 2021

Changes in this version

type RewardEraSeqStore

+ func (s *RewardEraSeqStore) GetByStashAndEra(validatorStash, stash string, era int64) (model.RewardEraSeq, error)

Mar 12, 2021

Changes in this version

type TransactionSeqStore

+ func (s TransactionSeqStore) GetTransactionsByTransactionKind(kind model.TransactionKind) ([]model.TransactionSeq, error)

Mar 10, 2021

Changes in this version

type EventSeqStore

+ func (s *EventSeqStore) FindRewardsForTimePeriod(address string, start, end time.Time) ([]model.EventSeq, error)

type TransactionSeqStore

+ func (s TransactionSeqStore) GetTransactionByTransactionKind(kind model.TransactionKind) ([]model.TransactionSeq, error)

Dec 11, 2020

Changes in this version

+ type RewardEraSeqStore struct

+ func NewRewardEraSeqStore(db *gorm.DB) *RewardEraSeqStore

+ func (s RewardEraSeqStore) BulkUpsert(records []model.RewardEraSeq) error

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

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

+ func (s RewardEraSeqStore) GetAll(stash string, start, end int64) ([]model.RewardEraSeq, error)

+ func (s RewardEraSeqStore) GetCount(validatorStash string, era int64) (int64, error)

+ func (s RewardEraSeqStore) Import(query string, rows int, fn bulk.RowFunc) error

+ func (s RewardEraSeqStore) MarkAllClaimed(validatorStash string, era int64) error

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

+ func (s RewardEraSeqStore) Truncate() error

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

type Store

+ func (s *Store) GetRewards() *rewards

Nov 26, 2020

Changes in this version

type AccountEraSeqStore

+ func (s AccountEraSeqStore) BulkUpsert(records []model.AccountEraSeq) error

+ func (s AccountEraSeqStore) Import(query string, rows int, fn bulk.RowFunc) error

type BlockSeqStore

+ func (s BlockSeqStore) Import(query string, rows int, fn bulk.RowFunc) error

type BlockSummaryStore

+ func (s BlockSummaryStore) Import(query string, rows int, fn bulk.RowFunc) error

type EventSeqStore

+ func (s EventSeqStore) BulkUpsert(records []model.EventSeq) error

+ func (s EventSeqStore) Import(query string, rows int, fn bulk.RowFunc) error

type ReportsStore

+ func (s ReportsStore) Import(query string, rows int, fn bulk.RowFunc) error

type Store

+ func (s *Store) GetSystemEvents() *systemEvents

type SyncablesStore

+ func (s SyncablesStore) FindAllByLastInSessionOrEra(indexVersion int64, isLastInSession, isLastInEra bool) ([]model.Syncable, error)

+ func (s SyncablesStore) Import(query string, rows int, fn bulk.RowFunc) error

+ type SystemEventStore struct

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

+ func (s SystemEventStore) BulkUpsert(records []model.SystemEvent) error

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

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

+ func (s SystemEventStore) FindByActor(actorAddress string, kind *model.SystemEventKind, minHeight *int64) ([]model.SystemEvent, error)

+ func (s SystemEventStore) Import(query string, rows int, fn bulk.RowFunc) error

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

+ func (s SystemEventStore) Truncate() error

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

type TransactionSeqStore

+ func (s TransactionSeqStore) BulkUpsert(records []model.TransactionSeq) error

+ func (s TransactionSeqStore) Import(query string, rows int, fn bulk.RowFunc) error

type ValidatorAggStore

+ func (s ValidatorAggStore) Import(query string, rows int, fn bulk.RowFunc) error

type ValidatorEraSeqStore

+ func (s ValidatorEraSeqStore) BulkUpsertEraSeqs(records []model.ValidatorEraSeq) error

+ func (s ValidatorEraSeqStore) Import(query string, rows int, fn bulk.RowFunc) error

+ type ValidatorSeqStore struct

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

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

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

+ func (s ValidatorSeqStore) BulkUpsertSeqs(records []model.ValidatorSeq) error

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

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

+ func (s ValidatorSeqStore) FindAllByHeight(height int64) ([]model.ValidatorSeq, error)

+ func (s ValidatorSeqStore) Import(query string, rows int, fn bulk.RowFunc) error

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

+ func (s ValidatorSeqStore) Truncate() error

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

type ValidatorSessionSeqStore

+ func (s ValidatorSessionSeqStore) BulkUpsertSessionSeqs(records []model.ValidatorSessionSeq) error

+ func (s ValidatorSessionSeqStore) Import(query string, rows int, fn bulk.RowFunc) error

type ValidatorSummaryStore

+ func (s ValidatorSummaryStore) Import(query string, rows int, fn bulk.RowFunc) error

Nov 2, 2020

Changes in this version

+ type AccountEraSeqStore struct

+ func NewAccountEraSeqStore(db *gorm.DB) *AccountEraSeqStore

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

+ func (s *AccountEraSeqStore) FindMostRecent() (*model.AccountEraSeq, error)

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

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

+ func (s AccountEraSeqStore) FindByEra(era int64) ([]model.AccountEraSeq, error)

+ func (s AccountEraSeqStore) FindByEraAndStashAccount(era int64, stash string) (*model.AccountEraSeq, error)

+ func (s AccountEraSeqStore) FindByEraAndStashAccounts(era int64, stash string, validatorStash string) (*model.AccountEraSeq, error)

+ func (s AccountEraSeqStore) FindByHeight(h int64) ([]model.AccountEraSeq, error)

+ func (s AccountEraSeqStore) FindByHeightAndStashAccounts(height int64, stash string, validatorStash string) (*model.AccountEraSeq, error)

+ func (s AccountEraSeqStore) FindLastByStashAccount(stashAccount string) ([]model.AccountEraSeq, error)

+ func (s AccountEraSeqStore) FindLastByValidatorStashAccount(validatorStashAccount string) ([]model.AccountEraSeq, error)

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

+ func (s AccountEraSeqStore) Truncate() error

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

+ type BlockSeqStore struct

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

+ func (s *BlockSeqStore) DeleteSeqOlderThan(purgeThreshold time.Time, activityPeriods []store.ActivityPeriodRow) (*int64, error)

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

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

+ func (s *BlockSeqStore) Summarize(interval types.SummaryInterval, activityPeriods []store.ActivityPeriodRow) ([]model.BlockSeqSummary, error)

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

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

+ func (s BlockSeqStore) CreateSeq(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) FindByID(id int64) (*model.BlockSeq, error)

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

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

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

+ func (s BlockSeqStore) Truncate() error

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

+ type BlockSummaryStore struct

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

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

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

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

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

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

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

+ func (s BlockSummaryStore) CreateSummary(val *model.BlockSummary) error

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

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

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

+ func (s BlockSummaryStore) SaveSummary(val *model.BlockSummary) 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() (*store.GetTotalSizeResult, error)

+ type EventSeqStore struct

+ func NewEventSeqStore(db *gorm.DB) *EventSeqStore

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

+ func (s *EventSeqStore) FindMostRecent() (*model.EventSeq, error)

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

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

+ func (s EventSeqStore) FindAllByHeightAndIndex(height int64, indexes []int64) (map[int64]*model.EventSeq, error)

+ func (s EventSeqStore) FindBalanceDeposits(address string) ([]model.EventSeqWithTxHash, error)

+ func (s EventSeqStore) FindBalanceTransfers(address string) ([]model.EventSeqWithTxHash, error)

+ func (s EventSeqStore) FindBonded(address string) ([]model.EventSeqWithTxHash, error)

+ func (s EventSeqStore) FindByHeight(height int64) ([]model.EventSeq, error)

+ func (s EventSeqStore) FindByHeightAndIndex(height int64, index int64) (*model.EventSeq, error)

+ func (s EventSeqStore) FindUnbonded(address string) ([]model.EventSeqWithTxHash, error)

+ func (s EventSeqStore) FindWithdrawn(address string) ([]model.EventSeqWithTxHash, error)

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

+ func (s EventSeqStore) Truncate() error

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

+ type GetAvgTimesForIntervalRow struct

+ Avg float64

+ Count int64

+ TimeInterval string

+ type ReportsStore struct

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

+ func (s *ReportsStore) DeleteByKinds(kinds []model.ReportKind) error

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

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

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

+ func (s ReportsStore) FindNotCompletedByKind(kinds ...model.ReportKind) (*model.Report, 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 Store struct

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

+ func (s *Store) Close() error

+ func (s *Store) GetAccounts() *accounts

+ func (s *Store) GetBlocks() *blocks

+ func (s *Store) GetDatabase() *database

+ func (s *Store) GetEvents() *events

+ func (s *Store) GetReports() *reports

+ func (s *Store) GetSyncables() *syncables

+ func (s *Store) GetTransactions() *transactions

+ func (s *Store) GetValidators() *validators

+ 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) FindFirstByDifferentIndexVersion(indexVersion int64) (*model.Syncable, error)

+ func (s SyncablesStore) FindLastEndOfEra() (syncable *model.Syncable, err error)

+ func (s SyncablesStore) FindLastEndOfSession() (syncable *model.Syncable, err error)

+ func (s SyncablesStore) FindLastInEra(era int64) (syncable *model.Syncable, err error)

+ func (s SyncablesStore) FindLastInSession(session int64) (syncable *model.Syncable, err error)

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

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

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

+ func (s SyncablesStore) FindSmallestIndexVersion() (*int64, error)

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

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

+ func (s SyncablesStore) SetProcessedAtForRange(reportID types.ID, startHeight int64, endHeight int64) 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) CreateTransactionSeq(val *model.TransactionSeq) error

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

+ func (s TransactionSeqStore) FindAllByHeightAndIndex(height int64, indexes []int64) (map[int64]*model.TransactionSeq, error)

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

+ func (s TransactionSeqStore) SaveTransactionSeq(val *model.TransactionSeq) 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) FindAggByStashAccount(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) CreateAgg(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) SaveAgg(val *model.ValidatorAgg) error

+ func (s ValidatorAggStore) Truncate() error

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

+ type ValidatorEraSeqStore struct

+ func NewValidatorEraSeqStore(db *gorm.DB) *ValidatorEraSeqStore

+ func (s *ValidatorEraSeqStore) DeleteEraSeqsOlderThan(purgeThreshold time.Time) (*int64, error)

+ func (s *ValidatorEraSeqStore) FindMostRecentEraSeq() (*model.ValidatorEraSeq, error)

+ func (s *ValidatorEraSeqStore) SummarizeEraSeqs(interval types.SummaryInterval, activityPeriods []store.ActivityPeriodRow) ([]model.ValidatorEraSeqSummary, error)

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

+ func (s ValidatorEraSeqStore) CreateEraSeq(val *model.ValidatorEraSeq) error

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

+ func (s ValidatorEraSeqStore) FindByEra(era int64) ([]model.ValidatorEraSeq, error)

+ func (s ValidatorEraSeqStore) FindByEraAndStashAccount(era int64, stash string) (*model.ValidatorEraSeq, error)

+ func (s ValidatorEraSeqStore) FindByHeightAndStashAccount(height int64, stash string) (*model.ValidatorEraSeq, error)

+ func (s ValidatorEraSeqStore) FindEraSeqsByHeight(h int64) ([]model.ValidatorEraSeq, error)

+ func (s ValidatorEraSeqStore) FindLastEraSeqByStashAccount(stashAccount string, limit int64) ([]model.ValidatorEraSeq, error)

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

+ func (s ValidatorEraSeqStore) SaveEraSeq(val *model.ValidatorEraSeq) error

+ func (s ValidatorEraSeqStore) Truncate() error

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

+ type ValidatorSessionSeqStore struct

+ func NewValidatorSessionSeqStore(db *gorm.DB) *ValidatorSessionSeqStore

+ func (s *ValidatorSessionSeqStore) DeleteSessionSeqsOlderThan(purgeThreshold time.Time) (*int64, error)

+ func (s *ValidatorSessionSeqStore) FindMostRecentSessionSeq() (*model.ValidatorSessionSeq, error)

+ func (s *ValidatorSessionSeqStore) SummarizeSessionSeqs(interval types.SummaryInterval, activityPeriods []store.ActivityPeriodRow) ([]model.ValidatorSessionSeqSummary, error)

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

+ func (s ValidatorSessionSeqStore) CreateSessionSeq(val *model.ValidatorSessionSeq) error

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

+ func (s ValidatorSessionSeqStore) FindByHeightAndStashAccount(height int64, stash string) (*model.ValidatorSessionSeq, error)

+ func (s ValidatorSessionSeqStore) FindBySession(session int64) ([]model.ValidatorSessionSeq, error)

+ func (s ValidatorSessionSeqStore) FindBySessionAndStashAccount(session int64, stash string) (*model.ValidatorSessionSeq, error)

+ func (s ValidatorSessionSeqStore) FindLastSessionSeqByStashAccount(stashAccount string, limit int64) ([]model.ValidatorSessionSeq, error)

+ func (s ValidatorSessionSeqStore) FindSessionSeqsByHeight(h int64) ([]model.ValidatorSessionSeq, error)

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

+ func (s ValidatorSessionSeqStore) SaveSessionSeq(val *model.ValidatorSessionSeq) error

+ func (s ValidatorSessionSeqStore) Truncate() error

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

+ type ValidatorSummaryStore struct

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

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

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

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

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

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

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

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

+ func (s ValidatorSummaryStore) CreateSummary(val *model.ValidatorSummary) error

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

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

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

+ func (s ValidatorSummaryStore) SaveSummary(val *model.ValidatorSummary) error

+ func (s ValidatorSummaryStore) Truncate() error

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