postgres

Nov 15, 2024

Changes in this version

type Rollup

+ func (r *Rollup) RollupStatsGrouping(ctx context.Context, fltrs storage.RollupGroupStatsFilters) (results []storage.RollupGroupedStats, err error)

Nov 4, 2024

Changes in this version

type Tx

+ func (tx *Tx) IdAndTimeByHash(ctx context.Context, hash []byte) (id uint64, t time.Time, err error)

Sep 9, 2024

Changes in this version

type Address

+ func (a *Address) IdByAddress(ctx context.Context, address string, ids ...uint64) (id uint64, err error)

Sep 8, 2024

Changes in this version

type BlobLog

+ func (bl *BlobLog) ListBlobs(ctx context.Context, fltrs storage.ListBlobLogFilters) (logs []storage.BlobLog, err error)

Aug 23, 2024

Changes in this version

type Rollup

+ func (r *Rollup) AllSeries(ctx context.Context) (items []storage.RollupHistogramItem, err error)

+ func (r *Rollup) LeaderboardDay(ctx context.Context, sortField string, sort sdk.SortOrder, limit, offset int) (rollups []storage.RollupWithDayStats, err error)

Aug 13, 2024

Changes in this version

type Rollup

+ func (r *Rollup) ById(ctx context.Context, rollupId uint64) (rollup storage.RollupWithStats, err error)

Jul 14, 2024

Changes in this version

type Stats

+ func (s Stats) Change24hBlockStats(ctx context.Context) (response storage.Change24hBlockStats, err error)

+ func (s Stats) MessagesCount24h(ctx context.Context) (response []storage.CountItem, err error)

+ func (s Stats) RollupStats24h(ctx context.Context) (response []storage.RollupStats24h, err error)

Jul 8, 2024

Changes in this version

type Stats

+ func (s Stats) SquareSize(ctx context.Context, from, to *time.Time) (result map[int][]storage.SeriesItem, err error)

Jul 3, 2024

Changes in this version

type Transaction

+ func (tx Transaction) RefreshLeaderboard(ctx context.Context) error

Jun 30, 2024

Changes in this version

type Stats

+ func (s Stats) CumulativeSeries(ctx context.Context, timeframe storage.Timeframe, name string, ...) (response []storage.SeriesItem, err error)

Jun 9, 2024

Changes in this version

type Tx

+ func (tx *Tx) IdByHash(ctx context.Context, hash []byte) (id uint64, err error)

May 29, 2024

Changes in this version

type BlobLog

+ func (bl *BlobLog) Blob(ctx context.Context, height types.Level, nsId uint64, commitment string) (l storage.BlobLog, err error)

May 28, 2024

Changes in this version

type Address

+ func (a *Address) IdByHash(ctx context.Context, hash []byte) (id uint64, err error)

+ func (a *Address) Series(ctx context.Context, addressId uint64, timeframe storage.Timeframe, ...) (items []storage.HistogramItem, err error)

Apr 1, 2024

Changes in this version

type BlobLog

+ func (bl *BlobLog) ExportByProviders(ctx context.Context, providers []storage.RollupProvider, from, to time.Time, ...) (err error)

+ type Grant struct

+ func NewGrant(db *database.Bun) *Grant

+ func (g *Grant) ByGrantee(ctx context.Context, id uint64, limit, offset int) (grants []storage.Grant, err error)

+ func (g *Grant) ByGranter(ctx context.Context, id uint64, limit, offset int) (grants []storage.Grant, err error)

+ type SentryHook struct

+ func NewSentryHook(dbName string, tracer trace.Tracer, formatQueries bool) *SentryHook

+ func (h *SentryHook) AfterQuery(ctx context.Context, event *bun.QueryEvent)

+ func (h *SentryHook) BeforeQuery(ctx context.Context, event *bun.QueryEvent) context.Context

+ func (h *SentryHook) Init(db *bun.DB)

+ type StakingLog struct

+ func NewStakingLog(db *database.Bun) *StakingLog

+ func (d *StakingLog) ByValidator(ctx context.Context, id uint64, limit, offset int) (logs []storage.StakingLog, err error)

type Storage

+ Grants models.IGrant

+ StakingLogs models.IStakingLog

+ VestingAccounts models.IVestingAccount

+ VestingPeriods models.IVestingPeriod

+ func (s Storage) SetTracer(tp trace.TracerProvider)

type Transaction

+ func (tx Transaction) RollbackGrants(ctx context.Context, height types.Level) (err error)

+ func (tx Transaction) RollbackVestingAccounts(ctx context.Context, height types.Level) (err error)

+ func (tx Transaction) RollbackVestingPeriods(ctx context.Context, height types.Level) (err error)

+ func (tx Transaction) SaveGrants(ctx context.Context, grants ...models.Grant) error

+ func (tx Transaction) SaveVestingAccounts(ctx context.Context, accs ...*models.VestingAccount) error

+ func (tx Transaction) SaveVestingPeriods(ctx context.Context, periods ...models.VestingPeriod) error

+ type VestingAccount struct

+ func NewVestingAccount(db *database.Bun) *VestingAccount

+ func (v *VestingAccount) ByAddress(ctx context.Context, addressId uint64, limit, offset int, showEnded bool) (accs []storage.VestingAccount, err error)

+ type VestingPeriod struct

+ func NewVestingPeriod(db *database.Bun) *VestingPeriod

+ func (v *VestingPeriod) ByVesting(ctx context.Context, id uint64, limit, offset int) (periods []storage.VestingPeriod, err error)

Mar 12, 2024

Changes in this version

type Transaction

+ func (tx Transaction) Delegation(ctx context.Context, validatorId, addressId uint64) (val models.Delegation, err error)

+ func (tx Transaction) Validator(ctx context.Context, id uint64) (val models.Validator, err error)

Mar 10, 2024

Changes in this version

type Rollup

+ func (r *Rollup) Distribution(ctx context.Context, rollupId uint64, series, groupBy string) (items []storage.DistributionItem, err error)

Mar 3, 2024

Changes in this version

+ type Delegation struct

+ func NewDelegation(db *database.Bun) *Delegation

+ func (d *Delegation) ByAddress(ctx context.Context, addressId uint64, limit, offset int) (delegations []storage.Delegation, err error)

+ func (d *Delegation) ByValidator(ctx context.Context, validatorId uint64, limit, offset int) (delegations []storage.Delegation, err error)

+ type DelegationLog struct

+ func NewDelegationLog(db *database.Bun) *DelegationLog

+ func (d *DelegationLog) ByValidator(ctx context.Context, id uint64, limit, offset int) (logs []storage.StakingLog, err error)

+ type Jail struct

+ func NewJail(db *database.Bun) *Jail

+ func (j *Jail) ByValidator(ctx context.Context, id uint64, limit, offset int) (jails []storage.Jail, err error)

+ type Redelegation struct

+ func NewRedelegation(db *database.Bun) *Redelegation

+ func (d *Redelegation) ByAddress(ctx context.Context, addressId uint64, limit, offset int) (redelegations []storage.Redelegation, err error)

type Stats

+ func (s Stats) StakingSeries(ctx context.Context, timeframe storage.Timeframe, name string, ...) (response []storage.SeriesItem, err error)

type Storage

+ Delegation models.IDelegation

+ DelegationLogs models.IStakingLog

+ Jails models.IJail

+ Redelegation models.IRedelegation

+ Undelegation models.IUndelegation

type Transaction

+ func (tx Transaction) CancelUnbondings(ctx context.Context, cancellations ...models.Undelegation) error

+ func (tx Transaction) DeleteDelegationsByValidator(ctx context.Context, ids ...uint64) error

+ func (tx Transaction) Jail(ctx context.Context, validators ...*models.Validator) error

+ func (tx Transaction) RetentionCompletedRedelegations(ctx context.Context, blockTime time.Time) error

+ func (tx Transaction) RetentionCompletedUnbondings(ctx context.Context, blockTime time.Time) error

+ func (tx Transaction) RollbackJails(ctx context.Context, height types.Level) (jails []models.Jail, err error)

+ func (tx Transaction) RollbackRedelegations(ctx context.Context, height types.Level) (err error)

+ func (tx Transaction) RollbackStakingLogs(ctx context.Context, height types.Level) (logs []models.StakingLog, err error)

+ func (tx Transaction) RollbackUndelegations(ctx context.Context, height types.Level) (err error)

+ func (tx Transaction) SaveDelegations(ctx context.Context, delegations ...models.Delegation) error

+ func (tx Transaction) SaveJails(ctx context.Context, jails ...models.Jail) error

+ func (tx Transaction) SaveRedelegations(ctx context.Context, redelegations ...models.Redelegation) error

+ func (tx Transaction) SaveStakingLogs(ctx context.Context, logs ...models.StakingLog) error

+ func (tx Transaction) SaveUndelegations(ctx context.Context, undelegations ...models.Undelegation) error

+ func (tx Transaction) UpdateSlashedDelegations(ctx context.Context, validatorId uint64, fraction decimal.Decimal) (balances []models.Balance, err error)

+ func (tx Transaction) UpdateValidators(ctx context.Context, validators ...*models.Validator) error

+ type Undelegation struct

+ func NewUndelegation(db *database.Bun) *Undelegation

+ func (d *Undelegation) ByAddress(ctx context.Context, addressId uint64, limit, offset int) (undelegations []storage.Undelegation, err error)

type Validator

+ func (v *Validator) JailedCount(ctx context.Context) (int, error)

+ func (v *Validator) ListByPower(ctx context.Context, fltrs storage.ValidatorFilters) (validators []storage.Validator, err error)

+ func (v *Validator) TotalVotingPower(ctx context.Context) (decimal.Decimal, error)

Feb 16, 2024

Changes in this version

type Blocks

+ func (b *Blocks) Time(ctx context.Context, height pkgTypes.Level) (response time.Time, err error)

+ type Export struct

+ func NewExport(cfg config.Database) *Export

+ func (e *Export) Close() error

+ func (e *Export) ToCsv(ctx context.Context, writer io.Writer, query string) error

type Rollup

+ func (r *Rollup) RollupsByNamespace(ctx context.Context, namespaceId uint64, limit, offset int) (rollups []storage.Rollup, err error)

type Storage

+ Export models.Export

+ func (s Storage) Close() error

Feb 12, 2024

Changes in this version

+ type BlockSignature struct

+ func NewBlockSignature(db *database.Bun) *BlockSignature

+ func (bs *BlockSignature) LevelsByValidator(ctx context.Context, validatorId uint64, startHeight types.Level) (levels []types.Level, err error)

type Blocks

+ func (b *Blocks) ByProposer(ctx context.Context, proposerId uint64, limit, offset int) (blocks []storage.Block, err error)

type Rollup

+ func (r *Rollup) BySlug(ctx context.Context, slug string) (rollup storage.Rollup, err error)

+ type Search struct

+ func NewSearch(db *database.Bun) *Search

+ func (s *Search) Search(ctx context.Context, query []byte) (results []storage.SearchResult, err error)

+ func (s *Search) SearchText(ctx context.Context, text string) (results []storage.SearchResult, err error)

type Storage

+ BlockSignatures models.IBlockSignature

+ Search models.ISearch

type Transaction

+ func (tx Transaction) RetentionBlockSignatures(ctx context.Context, height types.Level) error

+ func (tx Transaction) RollbackBlockSignatures(ctx context.Context, height types.Level) (err error)

+ func (tx Transaction) SaveBlockSignatures(ctx context.Context, signs ...models.BlockSignature) error

+ func (tx Transaction) Validators(ctx context.Context) (validators []models.Validator, err error)

Jan 29, 2024

Changes in this version

type BlobLog

+ func (bl *BlobLog) ByHeight(ctx context.Context, height types.Level, fltrs storage.BlobLogFilters) (logs []storage.BlobLog, err error)

+ func (bl *BlobLog) ByTxId(ctx context.Context, txId uint64, fltrs storage.BlobLogFilters) (logs []storage.BlobLog, err error)

+ func (bl *BlobLog) CountByHeight(ctx context.Context, height types.Level) (int, error)

+ func (bl *BlobLog) CountByTxId(ctx context.Context, txId uint64) (int, error)

type Rollup

+ func (r *Rollup) Count(ctx context.Context) (int64, error)

+ func (r *Rollup) Series(ctx context.Context, rollupId uint64, timeframe, column string, ...) (items []storage.HistogramItem, err error)

Dec 31, 2023

Changes in this version

+ type BlobLog struct

+ func NewBlobLog(db *database.Bun) *BlobLog

+ func (bl *BlobLog) ByNamespace(ctx context.Context, nsId uint64, fltrs storage.BlobLogFilters) (logs []storage.BlobLog, err error)

+ func (bl *BlobLog) ByProviders(ctx context.Context, providers []storage.RollupProvider, ...) (logs []storage.BlobLog, err error)

+ func (bl *BlobLog) BySigner(ctx context.Context, signerId uint64, fltrs storage.BlobLogFilters) (logs []storage.BlobLog, err error)

type Message

+ func (m *Message) ByAddress(ctx context.Context, addressId uint64, filters storage.AddressMsgsFilter) (msgs []storage.AddressMessageWithTx, err error)

type Namespace

+ func (n *Namespace) GetByIds(ctx context.Context, ids ...uint64) (ns []storage.Namespace, err error)

+ type Price struct

+ func NewPrice(db *database.Bun) *Price

+ func (p *Price) Get(ctx context.Context, timeframe string, start, end int64, limit int) (price []storage.Price, err error)

+ func (p *Price) Last(ctx context.Context) (price storage.Price, err error)

+ func (p *Price) Save(ctx context.Context, price *storage.Price) error

+ type Rollup struct

+ func NewRollup(db *database.Bun) *Rollup

+ func (r *Rollup) Leaderboard(ctx context.Context, sortField string, sort sdk.SortOrder, limit, offset int) (rollups []storage.RollupWithStats, err error)

+ func (r *Rollup) Namespaces(ctx context.Context, rollupId uint64, limit, offset int) (namespaceIds []uint64, err error)

+ func (r *Rollup) Providers(ctx context.Context, rollupId uint64) (providers []storage.RollupProvider, err error)

+ func (r *Rollup) Stats(ctx context.Context, rollupId uint64, timeframe, column string, ...) (items []storage.HistogramItem, err error)

type Storage

+ BlobLogs models.IBlobLog

+ Price models.IPrice

+ Rollup models.IRollup

type Transaction

+ func (tx Transaction) DeleteProviders(ctx context.Context, rollupId uint64) error

+ func (tx Transaction) DeleteRollup(ctx context.Context, rollupId uint64) error

+ func (tx Transaction) RollbackBlobLog(ctx context.Context, height types.Level) (err error)

+ func (tx Transaction) SaveBlobLogs(ctx context.Context, logs ...models.BlobLog) error

+ func (tx Transaction) SaveProviders(ctx context.Context, providers ...models.RollupProvider) error

+ func (tx Transaction) SaveRollup(ctx context.Context, rollup *models.Rollup) error

+ func (tx Transaction) UpdateRollup(ctx context.Context, rollup *models.Rollup) error

Dec 17, 2023

Changes in this version

type Namespace

+ func (n *Namespace) CountMessagesByTxId(ctx context.Context, txId uint64) (int, error)

+ func (n *Namespace) MessagesByTxId(ctx context.Context, txId uint64, limit, offset int) (msgs []storage.NamespaceMessage, err error)

Dec 7, 2023

Changes in this version

type Namespace

+ func (n *Namespace) ListWithSort(ctx context.Context, sortField string, sort sdk.SortOrder, limit, offset int) (ns []storage.Namespace, err error)

Nov 25, 2023

Changes in this version

type BlockStats

+ func (b *BlockStats) LastFrom(ctx context.Context, head pkgTypes.Level, limit int) (stats []storage.BlockStats, err error)

type Stats

+ func (s Stats) NamespaceSeries(ctx context.Context, timeframe storage.Timeframe, name string, nsId uint64, ...) (response []storage.SeriesItem, err error)

+ func (s Stats) Series(ctx context.Context, timeframe storage.Timeframe, name string, ...) (response []storage.SeriesItem, err error)

+ func (s Stats) TPS(ctx context.Context) (response storage.TPS, err error)

+ func (s Stats) TxCountForLast24h(ctx context.Context) (response []storage.TxCountForLast24hItem, err error)

type Transaction

+ func (tx Transaction) GetProposerId(ctx context.Context, address string) (id uint64, err error)

+ func (tx Transaction) LastNamespaceMessage(ctx context.Context, nsId uint64) (msg models.NamespaceMessage, err error)

type Tx

+ func (tx *Tx) Gas(ctx context.Context, height types.Level) (response []storage.Gas, err error)

Nov 4, 2023

Changes in this version

type Message

+ func (m *Message) ListWithTx(ctx context.Context, filters storage.MessageListWithTxFilters) (msgs []storage.MessageWithTx, err error)

Oct 31, 2023

Changes in this version

+ func BeginTransaction(ctx context.Context, tx storage.Transactable) (models.Transaction, error)

+ type Address struct

+ func NewAddress(db *database.Bun) *Address

+ func (a *Address) ByHash(ctx context.Context, hash []byte) (address storage.Address, err error)

+ func (a *Address) ListWithBalance(ctx context.Context, filters storage.AddressListFilter) (result []storage.Address, err error)

+ func (a *Address) Messages(ctx context.Context, id uint64, filters storage.AddressMsgsFilter) (msgs []storage.MsgAddress, err error)

+ type BlockStats struct

+ func NewBlockStats(db *database.Bun) *BlockStats

+ func (b *BlockStats) ByHeight(ctx context.Context, height pkgTypes.Level) (stats storage.BlockStats, err error)

+ type Blocks struct

+ func NewBlocks(db *database.Bun) *Blocks

+ func (b *Blocks) ByHash(ctx context.Context, hash []byte) (block storage.Block, err error)

+ func (b *Blocks) ByHeight(ctx context.Context, height types.Level) (block storage.Block, err error)

+ func (b *Blocks) ByHeightWithStats(ctx context.Context, height types.Level) (block storage.Block, err error)

+ func (b *Blocks) ByIdWithRelations(ctx context.Context, id uint64) (block storage.Block, err error)

+ func (b *Blocks) Last(ctx context.Context) (block storage.Block, err error)

+ func (b *Blocks) ListWithStats(ctx context.Context, limit, offset uint64, order sdk.SortOrder) (blocks []*storage.Block, err error)

+ type Constant struct

+ func NewConstant(db *database.Bun) *Constant

+ func (constant *Constant) All(ctx context.Context) (c []storage.Constant, err error)

+ func (constant *Constant) ByModule(ctx context.Context, module types.ModuleName) (c []storage.Constant, err error)

+ func (constant *Constant) Get(ctx context.Context, module types.ModuleName, name string) (c storage.Constant, err error)

+ type DenomMetadata struct

+ func NewDenomMetadata(db *database.Bun) *DenomMetadata

+ func (dm *DenomMetadata) All(ctx context.Context) (metadata []storage.DenomMetadata, err error)

+ type Event struct

+ func NewEvent(db *database.Bun) *Event

+ func (e *Event) ByBlock(ctx context.Context, height pkgTypes.Level) (events []storage.Event, err error)

+ func (e *Event) ByTxId(ctx context.Context, txId uint64) (events []storage.Event, err error)

+ type Message struct

+ func NewMessage(db *database.Bun) *Message

+ func (m *Message) ByTxId(ctx context.Context, txId uint64) (messages []storage.Message, err error)

+ type Namespace struct

+ func NewNamespace(db *database.Bun) *Namespace

+ func (n *Namespace) Active(ctx context.Context, top int) (ns []storage.ActiveNamespace, err error)

+ func (n *Namespace) ByNamespaceId(ctx context.Context, namespaceId []byte) (namespace []storage.Namespace, err error)

+ func (n *Namespace) ByNamespaceIdAndVersion(ctx context.Context, namespaceId []byte, version byte) (namespace storage.Namespace, err error)

+ func (n *Namespace) CountMessagesByHeight(ctx context.Context, height pkgTypes.Level) (int, error)

+ func (n *Namespace) Messages(ctx context.Context, id uint64, limit, offset int) (msgs []storage.NamespaceMessage, err error)

+ func (n *Namespace) MessagesByHeight(ctx context.Context, height pkgTypes.Level, limit, offset int) (msgs []storage.NamespaceMessage, err error)

+ type Notificator struct

+ func NewNotificator(cfg config.Database, db *bun.DB) *Notificator

+ func (n *Notificator) Close() error

+ func (n *Notificator) Listen() chan *pq.Notification

+ func (n *Notificator) Notify(ctx context.Context, channel string, payload string) error

+ func (n *Notificator) Subscribe(ctx context.Context, channels ...string) error

+ type State struct

+ func NewState(db *database.Bun) *State

+ func (s *State) ByName(ctx context.Context, name string) (state storage.State, err error)

+ type Stats struct

+ func NewStats(conn *database.Bun) Stats

+ func (s Stats) Count(ctx context.Context, req storage.CountRequest) (string, error)

+ func (s Stats) Histogram(ctx context.Context, req storage.HistogramRequest) (response []storage.HistogramItem, err error)

+ func (s Stats) HistogramCount(ctx context.Context, req storage.HistogramCountRequest) (response []storage.HistogramItem, err error)

+ func (s Stats) Summary(ctx context.Context, req storage.SummaryRequest) (string, error)

+ type Storage struct

+ Address models.IAddress

+ BlockStats models.IBlockStats

+ Blocks models.IBlock

+ Constants models.IConstant

+ DenomMetadata models.IDenomMetadata

+ Event models.IEvent

+ Message models.IMessage

+ Namespace models.INamespace

+ Notificator *Notificator

+ State models.IState

+ Stats models.IStats

+ Tx models.ITx

+ Validator models.IValidator

+ func Create(ctx context.Context, cfg config.Database) (Storage, error)

+ func (s Storage) CreateListener() models.Listener

+ type Transaction struct

+ func (tx Transaction) DeleteBalances(ctx context.Context, ids []uint64) error

+ func (tx Transaction) LastAddressAction(ctx context.Context, address []byte) (uint64, error)

+ func (tx Transaction) LastBlock(ctx context.Context) (block models.Block, err error)

+ func (tx Transaction) Namespace(ctx context.Context, id uint64) (ns models.Namespace, err error)

+ func (tx Transaction) RollbackAddresses(ctx context.Context, height types.Level) (address []models.Address, err error)

+ func (tx Transaction) RollbackBlock(ctx context.Context, height types.Level) error

+ func (tx Transaction) RollbackBlockStats(ctx context.Context, height types.Level) (stats models.BlockStats, err error)

+ func (tx Transaction) RollbackEvents(ctx context.Context, height types.Level) (events []models.Event, err error)

+ func (tx Transaction) RollbackMessageAddresses(ctx context.Context, msgIds []uint64) (err error)

+ func (tx Transaction) RollbackMessages(ctx context.Context, height types.Level) (msgs []models.Message, err error)

+ func (tx Transaction) RollbackNamespaceMessages(ctx context.Context, height types.Level) (msgs []models.NamespaceMessage, err error)

+ func (tx Transaction) RollbackNamespaces(ctx context.Context, height types.Level) (ns []models.Namespace, err error)

+ func (tx Transaction) RollbackSigners(ctx context.Context, txIds []uint64) (err error)

+ func (tx Transaction) RollbackTxs(ctx context.Context, height types.Level) (txs []models.Tx, err error)

+ func (tx Transaction) RollbackValidators(ctx context.Context, height types.Level) (err error)

+ func (tx Transaction) SaveAddresses(ctx context.Context, addresses ...*models.Address) (int64, error)

+ func (tx Transaction) SaveBalances(ctx context.Context, balances ...models.Balance) error

+ func (tx Transaction) SaveConstants(ctx context.Context, constants ...models.Constant) error

+ func (tx Transaction) SaveEvents(ctx context.Context, events ...models.Event) error

+ func (tx Transaction) SaveMessages(ctx context.Context, msgs ...*models.Message) error

+ func (tx Transaction) SaveMsgAddresses(ctx context.Context, addresses ...models.MsgAddress) error

+ func (tx Transaction) SaveNamespaceMessage(ctx context.Context, nsMsgs ...models.NamespaceMessage) error

+ func (tx Transaction) SaveNamespaces(ctx context.Context, namespaces ...*models.Namespace) (int64, error)

+ func (tx Transaction) SaveSigners(ctx context.Context, addresses ...models.Signer) error

+ func (tx Transaction) SaveTransactions(ctx context.Context, txs ...models.Tx) error

+ func (tx Transaction) SaveValidators(ctx context.Context, validators ...*models.Validator) error

+ func (tx Transaction) State(ctx context.Context, name string) (state models.State, err error)

+ type Tx struct

+ func NewTx(db *database.Bun) *Tx

+ func (tx *Tx) ByAddress(ctx context.Context, addressId uint64, fltrs storage.TxFilter) ([]storage.Tx, error)

+ func (tx *Tx) ByHash(ctx context.Context, hash []byte) (transaction storage.Tx, err error)

+ func (tx *Tx) ByIdWithRelations(ctx context.Context, id uint64) (transaction storage.Tx, err error)

+ func (tx *Tx) Filter(ctx context.Context, fltrs storage.TxFilter) (txs []storage.Tx, err error)

+ func (tx *Tx) Genesis(ctx context.Context, limit, offset int, sortOrder sdk.SortOrder) (txs []storage.Tx, err error)

+ type Validator struct

+ func NewValidator(db *database.Bun) *Validator

+ func (v *Validator) ByAddress(ctx context.Context, address string) (validator storage.Validator, err error)