postgres

package

Go to main page

Versions in this module

v1

v1.17.2

Oct 21, 2025

Changes in this version

type Upgrade

+ func (t *Upgrade) ByVersion(ctx context.Context, version uint64) (upgrade storage.Upgrade, err error)

v1.17.1

Oct 10, 2025

Changes in this version

+ type HLGasPayment struct

+ func NewHLGasPayment(conn *database.Bun) *HLGasPayment

+ func (hl *HLGasPayment) List(ctx context.Context, limit, offset int) (payments []storage.HLGasPayment, err error)

+ type HLIGP struct

+ func NewHLIGP(conn *database.Bun) *HLIGP

+ func (hl *HLIGP) ByHash(ctx context.Context, hash []byte) (igp storage.HLIGP, err error)

+ func (hl *HLIGP) List(ctx context.Context, limit, offset int) (igp []storage.HLIGP, err error)

+ type HLIGPConfig struct

+ func NewHLIGPConfig(conn *database.Bun) *HLIGPConfig

+ func (hl *HLIGPConfig) List(ctx context.Context, limit, offset int) (config []storage.HLIGPConfig, err error)

+ type RollupProvider struct

+ func NewRollupProvider(db *database.Bun) *RollupProvider

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

type Stats

+ func (s Stats) StakingDistribution(ctx context.Context, req storage.SeriesRequest) (response []storage.StakingDistributionItem, err error)

type Storage

+ HLGasPayment models.IHLGasPayment

+ HLIGP models.IHLIGP

+ HLIGPConfig models.IHLIGPConfig

+ RollupProvider models.IRollupProvider

type Transaction

+ func (tx Transaction) HyperlaneIgp(ctx context.Context, id []byte) (igp models.HLIGP, err error)

+ func (tx Transaction) HyperlaneIgpConfig(ctx context.Context, id uint64) (config models.HLIGPConfig, err error)

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

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

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

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

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

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

+ func (tx Transaction) SaveHyperlaneGasPayments(ctx context.Context, payments ...*models.HLGasPayment) error

+ func (tx Transaction) SaveHyperlaneIgpConfigs(ctx context.Context, configs ...models.HLIGPConfig) error

+ func (tx Transaction) SaveHyperlaneIgps(ctx context.Context, igps ...*models.HLIGP) error

+ func (tx Transaction) SaveMsgValidator(ctx context.Context, valMsgs ...models.MsgValidator) error

+ func (tx Transaction) UpdateSignalsAfterUpgrade(ctx context.Context, version uint64) error

type Validator

+ func (v *Validator) Messages(ctx context.Context, id uint64, fltrs storage.ValidatorMessagesFilters) ([]storage.MsgValidator, error)

+ func (v *Validator) Metrics(ctx context.Context, id uint64) (metrics storage.ValidatorMetrics, err error)

+ func (v *Validator) TopNMetrics(ctx context.Context, n int) (metrics storage.ValidatorMetrics, err error)

v1.15.30

Sep 15, 2025

v1.15.29

Sep 11, 2025

v1.15.28

Sep 10, 2025

Changes in this version

+ type SignalVersion struct

+ func NewSignalVersion(db *database.Bun) *SignalVersion

+ func (t *SignalVersion) List(ctx context.Context, filters storage.ListSignalsFilter) (signals []storage.SignalVersion, err error)

type Storage

+ SignalVersion models.ISignalVersion

+ Upgrade models.IUpgrade

type Transaction

+ func (tx Transaction) SaveSignals(ctx context.Context, signals ...*models.SignalVersion) error

+ func (tx Transaction) SaveUpgrades(ctx context.Context, upgrades ...*models.Upgrade) error

+ func (tx Transaction) SignalVersions(ctx context.Context) (signals []models.Signal, err error)

+ type Upgrade struct

+ func NewUpgrade(db *database.Bun) *Upgrade

+ func (t *Upgrade) List(ctx context.Context, filters storage.ListUpgradesFilter) (upgrades []storage.Upgrade, err error)

v1.15.27

Aug 29, 2025

v1.15.25

Aug 20, 2025

Changes in this version

type HLTransfer

+ func (t *HLTransfer) TotalSeries(ctx context.Context, timeframe storage.Timeframe, column string, ...) (items []storage.HistogramItem, err error)

v1.15.24

Aug 14, 2025

Changes in this version

type HLTransfer

+ func (t *HLTransfer) Series(ctx context.Context, domainId uint64, timeframe storage.Timeframe, ...) (items []storage.HistogramItem, err error)

+ func (t *HLTransfer) StatsByDomain(ctx context.Context, limit, offset int) (stats []storage.DomainStats, err error)

v1.15.22

Jul 31, 2025

Changes in this version

type HLTransfer

+ func (t *HLTransfer) ById(ctx context.Context, id uint64) (transfer storage.HLTransfer, err error)

type IbcTransfer

+ func (c *IbcTransfer) ById(ctx context.Context, id uint64) (transfer storage.IbcTransfer, err error)

v1.15.21

Jul 25, 2025

Changes in this version

type IbcChannel

+ func (c *IbcChannel) BusiestChannel1m(ctx context.Context) (channel storage.BusiestChannel, err error)

type IbcTransfer

+ func (c *IbcTransfer) LargestTransfer24h(ctx context.Context) (transfer storage.IbcTransfer, err error)

v1.15.20

Jul 21, 2025

v1.15.19

Jul 21, 2025

v1.15.18

Jul 18, 2025

v1.15.17

Jul 18, 2025

Changes in this version

type IbcClient

+ func (c *IbcClient) ByChainId(ctx context.Context, chainId string) (res []string, err error)

type IbcConnection

+ func (c *IbcConnection) IdsByClients(ctx context.Context, clientIds ...string) (res []string, err error)

v1.15.16

Jul 17, 2025

v1.15.15

Jul 17, 2025

v1.15.14

Jul 13, 2025

v1.15.13

Jul 11, 2025

v1.15.12

Jul 11, 2025

v1.15.11

Jul 9, 2025

v1.15.10

Jul 7, 2025

v1.15.9

Jul 7, 2025

v1.15.8

Jul 7, 2025

v1.15.7

Jul 2, 2025

v1.15.6

Jul 2, 2025

v1.15.5

Jul 2, 2025

v1.15.4

Jul 2, 2025

v1.15.3

Jun 30, 2025

v1.15.2

Jun 30, 2025

v1.15.1

Jun 25, 2025

v1.15.0

Jun 18, 2025

Changes in this version

+ type HLMailbox struct

+ func NewHLMailbox(conn *database.Bun) *HLMailbox

+ func (hl *HLMailbox) ByHash(ctx context.Context, hash []byte) (mailbox storage.HLMailbox, err error)

+ func (hl *HLMailbox) List(ctx context.Context, limit, offset int) (mailbox []storage.HLMailbox, err error)

+ type HLToken struct

+ func NewHLToken(db *database.Bun) *HLToken

+ func (t *HLToken) ByHash(ctx context.Context, id []byte) (token storage.HLToken, err error)

+ func (t *HLToken) List(ctx context.Context, filters storage.ListHyperlaneTokens) (tokens []storage.HLToken, err error)

+ type HLTransfer struct

+ func NewHLTransfer(db *database.Bun) *HLTransfer

+ func (t *HLTransfer) List(ctx context.Context, filters storage.ListHyperlaneTransfers) (transfers []storage.HLTransfer, err error)

type Storage

+ HLMailbox models.IHLMailbox

+ HLToken models.IHLToken

+ HLTransfer models.IHLTransfer

type Transaction

+ func (tx Transaction) HyperlaneMailbox(ctx context.Context, id []byte) (mailbox models.HLMailbox, err error)

+ func (tx Transaction) HyperlaneToken(ctx context.Context, id []byte) (token models.HLToken, err error)

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

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

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

+ func (tx Transaction) SaveHyperlaneMailbox(ctx context.Context, mailbox ...*models.HLMailbox) error

+ func (tx Transaction) SaveHyperlaneTokens(ctx context.Context, tokens ...*models.HLToken) error

+ func (tx Transaction) SaveHyperlaneTransfers(ctx context.Context, transfers ...*models.HLTransfer) error

v1.14.0

Jun 8, 2025

Changes in this version

type Proposal

+ func (p *Proposal) ById(ctx context.Context, id uint64) (proposal storage.Proposal, err error)

v1.13.0

May 26, 2025

Changes in this version

+ type IbcChannel struct

+ func NewIbcChannel(conn *database.Bun) *IbcChannel

+ func (c *IbcChannel) ById(ctx context.Context, id string) (channel storage.IbcChannel, err error)

+ func (c *IbcChannel) List(ctx context.Context, fltrs storage.ListChannelFilters) (channels []storage.IbcChannel, err error)

+ func (c *IbcChannel) StatsByChain(ctx context.Context, limit, offset int) (stats []storage.ChainStats, err error)

+ type IbcClient struct

+ func NewIbcClient(conn *database.Bun) *IbcClient

+ func (c *IbcClient) ById(ctx context.Context, id string) (client storage.IbcClient, err error)

+ func (c *IbcClient) List(ctx context.Context, limit, offset int, sort sdk.SortOrder) (clients []storage.IbcClient, err error)

+ type IbcConnection struct

+ func NewIbcConnection(conn *database.Bun) *IbcConnection

+ func (c *IbcConnection) ById(ctx context.Context, id string) (conn storage.IbcConnection, err error)

+ func (c *IbcConnection) List(ctx context.Context, fltrs storage.ListConnectionFilters) (conns []storage.IbcConnection, err error)

+ type IbcTransfer struct

+ func NewIbcTransfer(conn *database.Bun) *IbcTransfer

+ func (c *IbcTransfer) List(ctx context.Context, fltrs storage.ListIbcTransferFilters) (transfers []storage.IbcTransfer, err error)

+ func (c *IbcTransfer) Series(ctx context.Context, channelId string, timeframe storage.Timeframe, ...) (items []storage.HistogramItem, err error)

type Storage

+ IbcChannels models.IIbcChannel

+ IbcClients models.IIbcClient

+ IbcConnections models.IIbcConnection

+ IbcTransfers models.IIbcTransfer

type Transaction

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

+ func (tx Transaction) IbcConnection(ctx context.Context, id string) (conn models.IbcConnection, err error)

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

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

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

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

+ func (tx Transaction) SaveIbcChannels(ctx context.Context, channels ...*models.IbcChannel) error

+ func (tx Transaction) SaveIbcClients(ctx context.Context, clients ...*models.IbcClient) (int64, error)

+ func (tx Transaction) SaveIbcConnections(ctx context.Context, conns ...*models.IbcConnection) error

+ func (tx Transaction) SaveIbcTransfers(ctx context.Context, transfers ...*models.IbcTransfer) error

v1.12.1

May 16, 2025

v1.12.0

May 7, 2025

Changes in this version

+ type Proposal struct

+ func NewProposal(db *database.Bun) *Proposal

+ func (p *Proposal) ListWithFilters(ctx context.Context, filters storage.ListProposalFilters) (proposals []storage.Proposal, err error)

type Storage

+ Proposals models.IProposal

+ Votes models.IVote

type Transaction

+ func (tx Transaction) ActiveProposals(ctx context.Context) (proposals []models.Proposal, err error)

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

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

+ func (tx Transaction) ProposalVotes(ctx context.Context, proposalId uint64, limit, offset int) (votes []models.Vote, err error)

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

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

+ func (tx Transaction) SaveProposals(ctx context.Context, proposals ...*models.Proposal) (int64, error)

+ func (tx Transaction) SaveVotes(ctx context.Context, votes ...*models.Vote) error

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

+ type Vote struct

+ func NewVote(db *database.Bun) *Vote

+ func (v *Vote) ByProposalId(ctx context.Context, proposalId uint64, fltrs storage.VoteFilters) (votes []storage.Vote, err error)

+ func (v *Vote) ByValidatorId(ctx context.Context, validatorId uint64, fltrs storage.VoteFilters) (votes []storage.Vote, err error)

+ func (v *Vote) ByVoterId(ctx context.Context, voterId uint64, fltrs storage.VoteFilters) (votes []storage.Vote, err error)

v1.11.4

May 2, 2025

v1.11.3

Apr 16, 2025

Changes in this version

type Stats

+ func (s Stats) SizeGroups(ctx context.Context, timeFilter *time.Time) (groups []storage.SizeGroup, err error)

v1.11.2

Apr 14, 2025

v1.11.1

Mar 19, 2025

v1.11.0

Mar 3, 2025

v1.10.21

Feb 18, 2025

v1.10.20

Feb 18, 2025

v1.10.19

Feb 18, 2025

v1.10.18

Feb 12, 2025

v1.10.17

Feb 6, 2025

Changes in this version

+ type ApiKey struct

+ func NewApiKey(db *database.Bun) *ApiKey

+ func (ak *ApiKey) Get(ctx context.Context, key string) (apikey storage.ApiKey, err error)

type Rollup

+ func (r *Rollup) Tags(ctx context.Context) (arr []string, err error)

+ func (r *Rollup) Unverified(ctx context.Context) (rollups []storage.Rollup, err error)

type Storage

+ ApiKeys models.IApiKey

+ CelestialState celestials.ICelestialState

+ Celestials celestials.ICelestial

v1.10.16

Dec 17, 2024

v1.10.15

Dec 17, 2024

v1.10.14

Dec 16, 2024

v1.10.13

Dec 16, 2024

v1.10.12

Dec 14, 2024

v1.10.11

Dec 13, 2024

v1.10.10

Dec 12, 2024

v1.10.9

Nov 20, 2024

v1.10.8

Nov 15, 2024

Changes in this version

type Rollup

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

v1.10.7

Nov 4, 2024

v1.10.6

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)

v1.10.5

Oct 25, 2024

v1.10.4

Oct 16, 2024

v1.10.3

Sep 24, 2024

v1.10.2

Sep 12, 2024

v1.10.1

Sep 9, 2024

Changes in this version

type Address

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

v1.10.0

Sep 8, 2024

Changes in this version

type BlobLog

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

v1.9.10

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)

v1.9.9

Aug 13, 2024

Changes in this version

type Rollup

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

v1.9.8

Jul 18, 2024

v1.9.7

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)

v1.9.6

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)

v1.9.5

Jul 4, 2024

v1.9.4

Jul 4, 2024

v1.9.3

Jul 3, 2024

v1.9.2

Jul 3, 2024

Changes in this version

type Transaction

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

v1.9.1

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)

v1.9.0

Jun 26, 2024

v1.8.4

Jun 17, 2024

v1.8.3

Jun 9, 2024

v1.8.2

Jun 9, 2024

v1.8.1

Jun 9, 2024

Changes in this version

type Tx

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

v1.8.0

Jun 3, 2024

v1.7.5

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)

v1.7.4

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)

v1.7.3

May 6, 2024

v1.7.2

May 6, 2024

v1.7.1

May 1, 2024

v1.7.0

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)

v1.6.4

Mar 12, 2024

v1.6.3

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)

v1.6.2

Mar 10, 2024

v1.6.1

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)

v1.6.0

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)

v1.5.2

Feb 23, 2024

v1.5.1

Feb 19, 2024

v1.5.0

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

v1.4.0

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)

v1.3.2

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)

v1.3.1

Jan 14, 2024

v1.3.0

Jan 13, 2024

v1.2.2

Jan 4, 2024

v1.2.1

Dec 31, 2023

v1.2.0

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

v1.1.7

Dec 19, 2023

v1.1.6

Dec 17, 2023

v1.1.5

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)

v1.1.4

Dec 11, 2023

v1.1.3

Dec 9, 2023

v1.1.2

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)

v1.1.1

Nov 27, 2023

v1.1.0

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)

v1.1.0-rc1

Nov 3, 2023

v1.0.5

Nov 6, 2023

v1.0.4

Nov 4, 2023

Changes in this version

type Message

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

v1.0.3

Nov 1, 2023

v1.0.2

Oct 31, 2023

v1.0.1

Oct 31, 2023

v1.0.0

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)

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