postgres

package

Go to main page

Versions in this module

v1

v1.4.0

Apr 21, 2025

Changes in this version

+ type ListenerFactory struct

+ func NewListenerFactory(cfg config.Database, db *postgres.Storage) *ListenerFactory

+ func (factory *ListenerFactory) CreateListener() storage.Listener

+ type Price struct

+ func NewPrice(db *postgres.Storage) *Price

+ func (p *Price) All(ctx context.Context, limit, offset int) (prices []storage.Price, err error)

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

+ func (p *Price) Series(ctx context.Context, currencyPair string, timeframe storage.Timeframe) (prices []storage.Candle, err error)

type Transaction

+ func (tx Transaction) SavePrices(ctx context.Context, prices ...models.Price) error

v1.3.0

Dec 16, 2024

Changes in this version

type App

+ func (app *App) ByRollupId(ctx context.Context, rollupId uint64) (result storage.AppWithStats, err error)

+ type Asset struct

+ func NewAsset(db *database.Bun) *Asset

+ func (a *Asset) List(ctx context.Context, limit int, offset int, sortBy string, order sdk.SortOrder) (assets []storage.Asset, err error)

type Fee

+ func (f *Fee) FullTxFee(ctx context.Context, id uint64) (fees []storage.Fee, err error)

type Storage

+ Asset models.IAsset

v1.2.0

Nov 9, 2024

Changes in this version

+ type App struct

+ func NewApp(db *database.Bun) *App

+ func (app *App) BySlug(ctx context.Context, slug string) (result storage.AppWithStats, err error)

+ func (app *App) Leaderboard(ctx context.Context, fltrs storage.LeaderboardFilters) (rollups []storage.AppWithStats, err error)

type Storage

+ App models.IApp

type Transaction

+ func (tx Transaction) DeleteApp(ctx context.Context, appId uint64) error

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

+ func (tx Transaction) SaveApp(ctx context.Context, app *models.App) error

+ func (tx Transaction) UpdateApp(ctx context.Context, app *models.App) error

v1.1.0

Oct 27, 2024

Changes in this version

type Bridge

+ func (b *Bridge) ById(ctx context.Context, id uint64) (bridge storage.Bridge, err error)

+ func (b *Bridge) ListWithAddress(ctx context.Context, limit, offset int) (result []storage.Bridge, err error)

+ type Deposit struct

+ func NewDeposit(db *database.Bun) *Deposit

+ func (d *Deposit) ByBridgeId(ctx context.Context, bridgeId uint64, limit, offset int, sort sdk.SortOrder) (deposits []storage.Deposit, err error)

+ func (d *Deposit) ByRollupId(ctx context.Context, rollupId uint64, limit, offset int, sort sdk.SortOrder) (deposits []storage.Deposit, err error)

type Fee

+ func (f *Fee) ByPayerId(ctx context.Context, id uint64, limit, offset int, sort sdk.SortOrder) (fees []storage.Fee, err error)

+ func (f *Fee) ByTxId(ctx context.Context, id uint64, limit, offset int) (fees []storage.Fee, err error)

type Stats

+ func (s Stats) ActiveAddressesCount(ctx context.Context) (val int64, err error)

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

+ func (s Stats) TokenTransferDistribution(ctx context.Context, limit int) (items []storage.TokenTransferDistributionItem, err error)

type Storage

+ Deposit models.IDeposit

+ Transfers models.ITransfer

type Transaction

+ func (tx Transaction) GetAddressId(ctx context.Context, hash string) (addrId uint64, err error)

+ func (tx Transaction) GetBridgeIdByAddressId(ctx context.Context, id uint64) (bridgeId uint64, err error)

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

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

+ func (tx Transaction) SaveDeposits(ctx context.Context, deposits ...*models.Deposit) error

+ func (tx Transaction) SaveTransfers(ctx context.Context, transfers ...*models.Transfer) error

+ type Transfer struct

+ func NewTransfer(db *database.Bun) *Transfer

v1.0.0

Sep 14, 2024

Changes in this version

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

+ type Action struct

+ func NewAction(db *database.Bun) *Action

+ func (a *Action) ByAddress(ctx context.Context, addressId uint64, filters storage.AddressActionsFilter) (actions []storage.AddressAction, err error)

+ func (a *Action) ByBlock(ctx context.Context, height types.Level, limit, offset int) (actions []storage.ActionWithTx, err error)

+ func (a *Action) ByRollup(ctx context.Context, rollupId uint64, limit, offset int, sort sdk.SortOrder) (actions []storage.RollupAction, err error)

+ func (a *Action) ByRollupAndBridge(ctx context.Context, rollupId uint64, ...) (actions []storage.ActionWithTx, err error)

+ func (a *Action) ByTxId(ctx context.Context, txId uint64, limit, offset int) (actions []storage.Action, err error)

+ type Address struct

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

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

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

+ 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 BlockStats struct

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

+ func (b *BlockStats) ByHeight(ctx context.Context, height types.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, withStats bool) (block storage.Block, err error)

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

+ func (b *Blocks) ByProposer(ctx context.Context, proposerId uint64, limit, offset int, order sdk.SortOrder) (blocks []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 Bridge struct

+ func NewBridge(db *database.Bun) *Bridge

+ func (b *Bridge) ByAddress(ctx context.Context, addressId uint64) (bridge storage.Bridge, err error)

+ func (b *Bridge) ByRoles(ctx context.Context, addressId uint64, limit, offset int) (result []storage.Bridge, err error)

+ func (b *Bridge) ByRollup(ctx context.Context, rollupId uint64, limit, offset int) (bridge []storage.Bridge, 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)

+ func (constant *Constant) IsNoRows(err error) bool

+ type Fee struct

+ func NewFee(db *database.Bun) *Fee

+ 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 Rollup struct

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

+ func (r *Rollup) ActionsByHeight(ctx context.Context, height types.Level, limit, offset int) (actions []storage.RollupAction, err error)

+ func (r *Rollup) ActionsByTxId(ctx context.Context, txId uint64, limit, offset int) (actions []storage.RollupAction, err error)

+ func (r *Rollup) Addresses(ctx context.Context, rollupId uint64, limit, offset int, sort sdk.SortOrder) (addresses []storage.RollupAddress, err error)

+ func (r *Rollup) ByHash(ctx context.Context, hash []byte) (rollup storage.Rollup, err error)

+ func (r *Rollup) CountActionsByHeight(ctx context.Context, height types.Level) (int64, error)

+ func (r *Rollup) CountActionsByTxId(ctx context.Context, txId uint64) (int64, error)

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

+ func (r *Rollup) ListRollupsByAddress(ctx context.Context, addressId uint64, limit, offset int, sort sdk.SortOrder) (addresses []storage.RollupAddress, err error)

+ type Search struct

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

+ func (s *Search) Search(ctx context.Context, query string) (results []storage.SearchResult, 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 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) RollupSeries(ctx context.Context, rollupId uint64, timeframe storage.Timeframe, name string, ...) (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) Summary(ctx context.Context) (summary storage.NetworkSummary, err error)

+ func (s Stats) SummaryTimeframe(ctx context.Context, timeframe storage.Timeframe) (summary storage.NetworkSummaryWithChange, err error)

+ type Storage struct

+ Action models.IAction

+ Address models.IAddress

+ BlockSignatures models.IBlockSignature

+ BlockStats models.IBlockStats

+ Blocks models.IBlock

+ Bridges models.IBridge

+ Constants models.IConstant

+ Fee models.IFee

+ Notificator *Notificator

+ Rollup models.IRollup

+ Search models.ISearch

+ State models.IState

+ Stats models.IStats

+ Tx models.ITx

+ Validator models.IValidator

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

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

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

+ type Transaction struct

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

+ func (tx Transaction) GetRollup(ctx context.Context, rollupId []byte) (rollup models.Rollup, err error)

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

+ func (tx Transaction) LastNonce(ctx context.Context, id uint64) (uint32, error)

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

+ func (tx Transaction) RollbackActions(ctx context.Context, height types.Level) (actions []models.Action, err error)

+ func (tx Transaction) RollbackAddressActions(ctx context.Context, height types.Level) (addrActions []models.AddressAction, err error)

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

+ func (tx Transaction) RollbackBalanceUpdates(ctx context.Context, height types.Level) (updates []models.BalanceUpdate, err error)

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

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

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

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

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

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

+ func (tx Transaction) RollbackRollupActions(ctx context.Context, height types.Level) (rActions []models.RollupAction, err error)

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

+ func (tx Transaction) RollbackRollups(ctx context.Context, height types.Level) (rollups []models.Rollup, 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) SaveActions(ctx context.Context, actions ...*models.Action) error

+ func (tx Transaction) SaveAddressActions(ctx context.Context, actions ...*models.AddressAction) error

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

+ func (tx Transaction) SaveBalanceUpdates(ctx context.Context, updates ...models.BalanceUpdate) error

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

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

+ func (tx Transaction) SaveBridges(ctx context.Context, bridges ...*models.Bridge) error

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

+ func (tx Transaction) SaveFees(ctx context.Context, fees ...*models.Fee) error

+ func (tx Transaction) SaveRollupActions(ctx context.Context, actions ...*models.RollupAction) error

+ func (tx Transaction) SaveRollupAddresses(ctx context.Context, addresses ...*models.RollupAddress) error

+ func (tx Transaction) SaveRollups(ctx context.Context, rollups ...*models.Rollup) (int64, 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)

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

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

+ func (tx Transaction) UpdateRollups(ctx context.Context, rollups ...*models.Rollup) error

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

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

+ type Tx struct

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

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

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

+ func (tx *Tx) ByHeight(ctx context.Context, height types.Level, limit, offset int) (txs []storage.Tx, err error)

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

+ type Validator struct

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

+ func (v *Validator) ListByPower(ctx context.Context, limit, offset int, order sdk.SortOrder) (validators []storage.Validator, err error)

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