Documentation
¶
Index ¶
- Constants
- Variables
- type Address
- type AddressListFilter
- type AddressMessageWithTx
- type AddressMsgsFilter
- type AddressWithType
- type ApiKey
- type Balance
- type BlobLog
- type BlobLogFilters
- type Block
- type BlockSignature
- type BlockStats
- type BusiestChannel
- type ByGasPrice
- type ChainStats
- type Change24hBlockStats
- type Constant
- type CountItem
- type CountRequest
- type DAChange
- type Delegation
- type DenomMetadata
- type DistributionItem
- type DomainStats
- type Event
- type EventFilter
- type Export
- type Gas
- type Grant
- type HLMailbox
- type HLToken
- type HLTransfer
- type HistogramCountRequest
- type HistogramItem
- type HistogramRequest
- type IAddress
- type IApiKey
- type IBalance
- type IBlobLog
- type IBlock
- type IBlockSignature
- type IBlockStats
- type IConstant
- type IDelegation
- type IDenomMetadata
- type IEvent
- type IGrant
- type IHLMailbox
- type IHLToken
- type IHLTransfer
- type IIbcChannel
- type IIbcClient
- type IIbcConnection
- type IIbcTransfer
- type IJail
- type IMessage
- type INamespace
- type IProposal
- type IRedelegation
- type IRollup
- type IRollupProvider
- type ISearch
- type IStakingLog
- type IState
- type IStats
- type ITx
- type IUndelegation
- type IValidator
- type IVestingAccount
- type IVestingPeriod
- type IVote
- type IbcChannel
- type IbcClient
- type IbcConnection
- type IbcTransfer
- type Jail
- type LeaderboardFilters
- type ListBlobLogFilters
- type ListChannelFilters
- type ListConnectionFilters
- type ListHyperlaneTokens
- type ListHyperlaneTransferFilters
- type ListIbcClientsFilters
- type ListIbcTransferFilters
- type ListProposalFilters
- type Listener
- type ListenerFactory
- type Message
- type MessageListWithTxFilters
- type MessageWithTx
- type MsgAddress
- type Namespace
- type NamespaceMessage
- type Notificator
- type Proposal
- type Redelegation
- type RolluDayStats
- type Rollup
- type RollupGroupStatsFilters
- type RollupGroupedStats
- type RollupHistogramItem
- type RollupProvider
- type RollupStats
- type RollupStats24h
- type RollupWithDayStats
- type RollupWithStats
- type SearchResult
- type SeriesItem
- type SeriesRequest
- type Signer
- type SizeGroup
- type StakingLog
- type State
- type SummaryRequest
- type TPS
- type Timeframe
- type Transaction
- type Tx
- type TxFilter
- type Undelegation
- type Validator
- type ValidatorFilters
- type VestingAccount
- type VestingPeriod
- type Vote
- type VoteFilters
Constants ¶
View Source
const ( ChannelHead = "head" ChannelBlock = "block" )
View Source
const ( SeriesBlobsSize = "blobs_size" SeriesBlobsCount = "blobs_count" SeriesBlobsFee = "blobs_fee" SeriesTPS = "tps" SeriesBPS = "bps" SeriesFee = "fee" SeriesSupplyChange = "supply_change" SeriesBlockTime = "block_time" SeriesTxCount = "tx_count" SeriesEventsCount = "events_count" SeriesGasPrice = "gas_price" SeriesGasUsed = "gas_used" SeriesGasLimit = "gas_limit" SeriesGasEfficiency = "gas_efficiency" SeriesNsPfbCount = "pfb_count" SeriesNsSize = "size" SeriesBytesInBlock = "bytes_in_block" SeriesRewards = "rewards" SeriesCommissions = "commissions" SeriesFlow = "flow" )
View Source
const ( ViewBlockStatsByMinute = "block_stats_by_minute" ViewBlockStatsByHour = "block_stats_by_hour" ViewBlockStatsByDay = "block_stats_by_day" ViewBlockStatsByWeek = "block_stats_by_week" ViewBlockStatsByMonth = "block_stats_by_month" ViewBlockStatsByYear = "block_stats_by_year" ViewNamespaceStatsByHour = "namespace_stats_by_hour" ViewNamespaceStatsByDay = "namespace_stats_by_day" ViewNamespaceStatsByWeek = "namespace_stats_by_week" ViewNamespaceStatsByMonth = "namespace_stats_by_month" ViewNamespaceStatsByYear = "namespace_stats_by_year" ViewStakingByHour = "staking_by_hour" ViewStakingByDay = "staking_by_day" ViewStakingByMonth = "staking_by_month" ViewLeaderboard = "leaderboard" ViewLeaderboardDay = "leaderboard_day" ViewSquareSize = "square_size" ViewRollupStatsByHour = "rollup_stats_by_hour" ViewRollupStatsByDay = "rollup_stats_by_day" ViewRollupStatsByMonth = "rollup_stats_by_month" ViewDAChange = "da_change" ViewIbcTransfersByHour = "ibc_transfers_by_hour" ViewIbcTransfersByDay = "ibc_transfers_by_day" ViewIbcTransfersByMonth = "ibc_transfers_by_month" ViewHlTransfersByHour = "hl_transfers_by_hour" ViewHlTransfersByDay = "hl_transfers_by_day" ViewHlTransfersByMonth = "hl_transfers_by_month" )
View Source
const DoNotModify = "[do-not-modify]"
Variables ¶
View Source
var (
ErrValidation = errors.New("validation error")
)
View Source
var Models = []any{ &State{}, &Constant{}, &DenomMetadata{}, &Balance{}, &Address{}, &VestingAccount{}, &VestingPeriod{}, &Block{}, &BlockStats{}, &BlockSignature{}, &Tx{}, &Message{}, &Event{}, &Namespace{}, &NamespaceMessage{}, &Signer{}, &MsgAddress{}, &Validator{}, &Delegation{}, &Redelegation{}, &Undelegation{}, &StakingLog{}, &Jail{}, &BlobLog{}, &Rollup{}, &RollupProvider{}, &Grant{}, &ApiKey{}, &celestials.Celestial{}, &celestials.CelestialState{}, &Proposal{}, &Vote{}, &IbcClient{}, &IbcConnection{}, &IbcChannel{}, &IbcTransfer{}, &HLMailbox{}, &HLToken{}, &HLTransfer{}, }
Functions ¶
This section is empty.
Types ¶
type Address ¶
type Address struct { bun.BaseModel `bun:"address" comment:"Table with celestia addresses."` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal identity"` Height types.Level `bun:"height" comment:"Block number of the first address occurrence."` LastHeight types.Level `bun:"last_height" comment:"Block number of the last address occurrence."` Hash []byte `bun:"hash" comment:"Address hash."` Address string `bun:"address,unique:address_idx" comment:"Human-readable address."` Name string `bun:"name,nullzero" comment:"Cosmos address name"` Balance Balance `bun:"rel:has-one,join:id=id"` Celestials *celestials.Celestial `bun:"rel:has-one,join:id=address_id"` }
Address -
type AddressListFilter ¶
type AddressMessageWithTx ¶ added in v1.2.0
type AddressMessageWithTx struct { bun.BaseModel `bun:"message,alias:message"` MsgAddress Msg *Message `bun:"rel:belongs-to,join:msg_id=id"` Tx *Tx }
type AddressMsgsFilter ¶
type AddressWithType ¶
type AddressWithType struct { Address Type types.MsgAddressType }
type ApiKey ¶ added in v1.10.17
type Balance ¶
type Balance struct { bun.BaseModel `bun:"balance" comment:"Table with account balances."` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal identity"` Currency string `bun:"currency,pk,notnull" comment:"Balance currency"` Spendable decimal.Decimal `bun:"spendable,type:numeric" comment:"Spendable balance"` Delegated decimal.Decimal `bun:"delegated,type:numeric" comment:"Delegated balance"` Unbonding decimal.Decimal `bun:"unbonding,type:numeric" comment:"Unbonding balance"` }
func EmptyBalance ¶
func EmptyBalance() Balance
type BlobLog ¶ added in v1.2.0
type BlobLog struct { bun.BaseModel `bun:"blob_log" comment:"Table with flatted blob entities."` Id uint64 `bun:"id,pk,autoincrement" comment:"Unique internal identity"` Time time.Time `bun:"time,notnull,pk" comment:"Message time"` Height types.Level `bun:"height" comment:"Message block height"` Size int64 `bun:"size" comment:"Blob size"` Commitment string `bun:"commitment" comment:"Blob commitment"` ContentType string `bun:"content_type" comment:"Blob content type"` Fee decimal.Decimal `bun:"fee,type:numeric" comment:"Fee per blob"` SignerId uint64 `bun:"signer_id" comment:"Blob signer identity"` NamespaceId uint64 `bun:"namespace_id" comment:"Namespace internal id"` MsgId uint64 `bun:"msg_id" comment:"Message id"` TxId uint64 `bun:"tx_id" comment:"Transaction id"` Message *Message `bun:"rel:belongs-to,join:msg_id=id"` Namespace *Namespace `bun:"rel:belongs-to,join:namespace_id=id"` Tx *Tx `bun:"rel:belongs-to,join:tx_id=id"` Signer *Address `bun:"rel:belongs-to,join:signer_id=id"` Rollup *Rollup `bun:"rel:belongs-to"` }
type BlobLogFilters ¶ added in v1.2.0
type Block ¶
type Block struct { bun.BaseModel `bun:"table:block" comment:"Table with celestia blocks."` Id uint64 `bun:",pk,notnull,autoincrement" comment:"Unique internal identity"` Height pkgTypes.Level `bun:"height" comment:"The number (height) of this block" stats:"func:min max,filterable"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block" stats:"func:min max,filterable"` VersionBlock uint64 `bun:"version_block" comment:"Block version"` VersionApp uint64 `bun:"version_app" comment:"App version"` MessageTypes types.MsgTypeBits `bun:"message_types,type:bit(104)" comment:"Bit mask with containing messages"` Hash pkgTypes.Hex `bun:"hash" comment:"Block hash"` ParentHash pkgTypes.Hex `bun:"parent_hash" comment:"Hash of parent block"` LastCommitHash pkgTypes.Hex `bun:"last_commit_hash" comment:"Last commit hash"` DataHash pkgTypes.Hex `bun:"data_hash" comment:"Data hash"` ValidatorsHash pkgTypes.Hex `bun:"validators_hash" comment:"Validators hash"` NextValidatorsHash pkgTypes.Hex `bun:"next_validators_hash" comment:"Next validators hash"` ConsensusHash pkgTypes.Hex `bun:"consensus_hash" comment:"Consensus hash"` AppHash pkgTypes.Hex `bun:"app_hash" comment:"App hash"` LastResultsHash pkgTypes.Hex `bun:"last_results_hash" comment:"Last results hash"` EvidenceHash pkgTypes.Hex `bun:"evidence_hash" comment:"Evidence hash"` ProposerId uint64 `bun:"proposer_id,nullzero" comment:"Proposer internal id"` ChainId string `bun:"-" json:"-"` // internal field for filling state ProposerAddress string `bun:"-" json:"-"` // internal field for proposer BlockSignatures []BlockSignature `bun:"-" json:"-"` // internal field for block signature Txs []Tx `bun:"rel:has-many" json:"-"` Events []Event `bun:"rel:has-many" json:"-"` Stats BlockStats `bun:"rel:has-one,join:height=height"` Proposer Validator `bun:"rel:belongs-to" json:"-"` }
Block -
type BlockSignature ¶ added in v1.4.0
type BlockSignature struct { bun.BaseModel `bun:"block_signature" comment:"Table with block signatures"` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal id"` Height types.Level `bun:",notnull" comment:"The number (height) of this block"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block"` ValidatorId uint64 `bun:"validator_id" comment:"Validator's internal identity"` Validator *Validator `bun:"rel:belongs-to"` }
func (BlockSignature) TableName ¶ added in v1.4.0
func (BlockSignature) TableName() string
type BlockStats ¶
type BlockStats struct { bun.BaseModel `bun:"table:block_stats" comment:"Table with celestia block stats."` Id uint64 `bun:",pk,notnull,autoincrement" comment:"Unique internal identity"` Height pkgTypes.Level `bun:"height" comment:"The number (height) of this block" stats:"func:min max,filterable"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block" stats:"func:min max,filterable"` TxCount int64 `` /* 135-byte string literal not displayed */ EventsCount int64 `` /* 135-byte string literal not displayed */ BlobsSize int64 `` /* 135-byte string literal not displayed */ BlobsCount int `` /* 135-byte string literal not displayed */ BlockTime uint64 `` /* 135-byte string literal not displayed */ GasLimit int64 `` /* 135-byte string literal not displayed */ GasUsed int64 `` /* 135-byte string literal not displayed */ SupplyChange decimal.Decimal `` /* 135-byte string literal not displayed */ InflationRate decimal.Decimal `` /* 131-byte string literal not displayed */ Fee decimal.Decimal `` /* 135-byte string literal not displayed */ Rewards decimal.Decimal `` /* 135-byte string literal not displayed */ Commissions decimal.Decimal `` /* 135-byte string literal not displayed */ BytesInBlock int64 `` /* 135-byte string literal not displayed */ SquareSize uint64 `bun:"square_size" comment:"Size of the square after splitting all the block data into shares"` }
func (BlockStats) TableName ¶
func (BlockStats) TableName() string
type BusiestChannel ¶ added in v1.15.21
type ByGasPrice ¶ added in v1.1.0
type ByGasPrice []Gas
func (ByGasPrice) Len ¶ added in v1.1.0
func (gp ByGasPrice) Len() int
func (ByGasPrice) Less ¶ added in v1.1.0
func (gp ByGasPrice) Less(i, j int) bool
func (ByGasPrice) Swap ¶ added in v1.1.0
func (gp ByGasPrice) Swap(i, j int)
type ChainStats ¶ added in v1.13.0
type Change24hBlockStats ¶ added in v1.9.7
type Constant ¶
type Constant struct { bun.BaseModel `bun:"table:constant" comment:"Table with celestia constants."` Module types.ModuleName `bun:"module,pk,type:module_name" comment:"Module name which declares constant"` Name string `bun:"name,pk,type:text" comment:"Constant name"` Value string `bun:"value,type:text" comment:"Constant value"` }
func (Constant) MustUint32 ¶ added in v1.7.0
func (Constant) MustUint64 ¶ added in v1.7.0
type CountRequest ¶
func (CountRequest) Validate ¶
func (req CountRequest) Validate() error
type Delegation ¶ added in v1.6.0
type Delegation struct { bun.BaseModel `bun:"delegation" comment:"Table with delegations"` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal id"` AddressId uint64 `bun:"address_id,unique:delegation_pair" comment:"Internal address id"` ValidatorId uint64 `bun:"validator_id,unique:delegation_pair" comment:"Internal validator id"` Amount decimal.Decimal `bun:"amount,type:numeric" comment:"Delegated amount"` Address *Address `bun:"rel:belongs-to,join:address_id=id"` Validator *Validator `bun:"rel:belongs-to,join:validator_id=id"` }
Delegation -
func (Delegation) String ¶ added in v1.6.0
func (d Delegation) String() string
type DenomMetadata ¶
type DenomMetadata struct { bun.BaseModel `bun:"table:denom_metadata" comment:"Table with celestia coins metadata."` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Internal unique identity"` Description string `bun:"description,type:text" comment:"Denom description"` Base string `bun:"base,type:text" comment:"Denom base"` Display string `bun:"display,type:text" comment:"Denom display"` Name string `bun:"name,type:text" comment:"Denom name"` Symbol string `bun:"symbol,type:text" comment:"Denom symbol"` Uri string `bun:"uri,type:text" comment:"Denom uri"` Units []byte `bun:"units,type:bytea" comment:"Denom units information"` }
func (DenomMetadata) TableName ¶
func (DenomMetadata) TableName() string
type DistributionItem ¶ added in v1.6.1
type DomainStats ¶ added in v1.15.24
type Event ¶
type Event struct { bun.BaseModel `bun:"event" comment:"Table with celestia events."` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal id"` Height pkgTypes.Level `bun:"height,notnull" comment:"The number (height) of this block" stats:"func:min max,filterable"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block" stats:"func:min max,filterable"` Position int64 `bun:"position" comment:"Position in transaction"` Type types.EventType `bun:",type:event_type" comment:"Event type" stats:"filterable"` TxId *uint64 `bun:"tx_id" comment:"Transaction id"` Data map[string]any `bun:"data,msgpack,type:bytea,nullzero" comment:"Event data"` }
Event -
type Grant ¶ added in v1.7.0
type Grant struct { bun.BaseModel `bun:"grant" comment:"Table with grants"` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal identity"` Height types.Level `bun:"height" comment:"Block height"` RevokeHeight *types.Level `bun:"revoke_height" comment:"Block height when grant was revoked"` Time time.Time `bun:"time" comment:"The time of block"` GranterId uint64 `bun:"granter_id,unique:grant_key" comment:"Granter internal identity"` GranteeId uint64 `bun:"grantee_id,unique:grant_key" comment:"Grantee internal identity"` Authorization string `bun:"authorization,unique:grant_key" comment:"Authorization type"` Expiration *time.Time `bun:"expiration" comment:"Expiration time"` Revoked bool `bun:"revoked" comment:"Is grant revoked"` Params map[string]any `bun:"params,type:jsonb,nullzero" comment:"Authorization parameters"` Granter *Address `bun:"rel:has-one"` Grantee *Address `bun:"rel:has-one"` }
type HLMailbox ¶ added in v1.15.0
type HLMailbox struct { bun.BaseModel `bun:"hl_mailbox" comment:"Table with hyperlane mailboxes"` Id uint64 `bun:"id,pk,autoincrement" comment:"Internal identity"` Height pkgTypes.Level `bun:"height,notnull" comment:"The number (height) of this block"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block"` TxId uint64 `bun:"tx_id" comment:"Internal creation transaction id"` Mailbox []byte `bun:"mailbox,unique" comment:"Mailbox address"` InternalId uint64 `bun:"internal_id,unique" comment:"Internal mailbox id"` OwnerId uint64 `bun:"owner_id" comment:"Owner identity"` DefaultIsm []byte `bun:"default_ism" comment:"Default ISM"` DefaultHook []byte `bun:"default_hook" comment:"Default hook"` RequiredHook []byte `bun:"required_hook" comment:"Required hook"` Domain uint64 `bun:"domain,nullzero" comment:"Domain"` SentMessages uint64 `bun:"sent_messages" comment:"Count of sent messages"` ReceivedMessages uint64 `bun:"received_messages" comment:"Count of received messages"` Owner *Address `bun:"rel:belongs-to,join:owner_id=id"` Tx *Tx `bun:"rel:belongs-to,join:tx_id=id"` }
type HLToken ¶ added in v1.15.0
type HLToken struct { bun.BaseModel `bun:"hl_token" comment:"Table with hyperlane tokens"` Id uint64 `bun:"id,pk,autoincrement" comment:"Internal identity"` Height pkgTypes.Level `bun:"height,notnull" comment:"The number (height) of this block"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block"` OwnerId uint64 `bun:"owner_id" comment:"Owner internal identity"` MailboxId uint64 `bun:"mailbox_id" comment:"Mailbox internal identity"` TxId uint64 `bun:"tx_id" comment:"Transaction identity"` Type types.HLTokenType `bun:",type:hyperlane_token_type" comment:"Token type: synthetic or collateral"` Denom string `bun:"denom" comment:"Denom"` TokenId []byte `bun:"token_id,type:bytea,unique" comment:"Token id"` SentTransfers uint64 `bun:"sent_transfers" comment:"Sent transfers"` ReceiveTransfers uint64 `bun:"received_transfers" comment:"Receive transfers"` Sent decimal.Decimal `bun:"sent,type:numeric" comment:"Sent tokens"` Received decimal.Decimal `bun:"received,type:numeric" comment:"Receive tokens"` Owner *Address `bun:"rel:belongs-to,join:owner_id=id"` Mailbox *HLMailbox `bun:"rel:belongs-to,join:mailbox_id=id"` Tx *Tx `bun:"rel:belongs-to,join:tx_id=id"` }
type HLTransfer ¶ added in v1.15.0
type HLTransfer struct { bun.BaseModel `bun:"hl_transfer" comment:"Table with hyperlane transfers"` Id uint64 `bun:"id,pk,autoincrement" comment:"Internal identity"` Height pkgTypes.Level `bun:"height,notnull" comment:"The number (height) of this block"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block"` TxId uint64 `bun:"tx_id" comment:"Transaction identity"` MailboxId uint64 `bun:"mailbox_id" comment:"Mailbox address"` RelayerId uint64 `bun:"relayer_id" comment:"Relayer address"` TokenId uint64 `bun:"token_id" comment:"Token id"` Counterparty uint64 `bun:"counterparty" comment:"Counterparty domain"` AddressId uint64 `bun:"address_id" comment:"Internal celestia address identity"` CounterpartyAddress string `bun:"counterparty_address" comment:"Counterparty address"` Version byte `bun:"version" comment:"Version"` Nonce uint32 `bun:"nonce" comment:"Nonce"` Body []byte `bun:"body,type:bytea,nullzero" comment:"Body"` Metadata []byte `bun:"metadata,type:bytea,nullzero" comment:"Metadata"` Type types.HLTransferType `bun:",type:hyperlane_transfer_type" comment:"Transfer type"` Amount decimal.Decimal `bun:"amount,type:numeric" comment:"Amount"` Denom string `bun:"denom" comment:"Denom"` Mailbox *HLMailbox `bun:"rel:belongs-to,join:mailbox_id=id"` Relayer *Address `bun:"rel:belongs-to,join:relayer_id=id"` Address *Address `bun:"rel:belongs-to,join:address_id=id"` Token *HLToken `bun:"rel:belongs-to,join:token_id=id"` Tx *Tx `bun:"rel:belongs-to,join:tx_id=id"` }
func (*HLTransfer) TableName ¶ added in v1.15.0
func (m *HLTransfer) TableName() string
type HistogramCountRequest ¶
type HistogramCountRequest struct { CountRequest Timeframe Timeframe }
func (HistogramCountRequest) Validate ¶
func (req HistogramCountRequest) Validate() error
type HistogramItem ¶
type HistogramRequest ¶
type HistogramRequest struct { SummaryRequest Timeframe Timeframe }
func (HistogramRequest) Validate ¶
func (req HistogramRequest) Validate() error
type IAddress ¶
type IAddress interface { storage.Table[*Address] ByHash(ctx context.Context, hash []byte) (Address, error) ListWithBalance(ctx context.Context, filters AddressListFilter) ([]Address, error) Series(ctx context.Context, addressId uint64, timeframe Timeframe, column string, req SeriesRequest) (items []HistogramItem, err error) IdByHash(ctx context.Context, hash ...[]byte) ([]uint64, error) IdByAddress(ctx context.Context, address string, ids ...uint64) (uint64, error) }
type IBlobLog ¶ added in v1.2.0
type IBlobLog interface { sdk.Table[*BlobLog] ByNamespace(ctx context.Context, nsId uint64, fltrs BlobLogFilters) ([]BlobLog, error) ByProviders(ctx context.Context, providers []RollupProvider, fltrs BlobLogFilters) ([]BlobLog, error) BySigner(ctx context.Context, signerId uint64, fltrs BlobLogFilters) ([]BlobLog, error) ByTxId(ctx context.Context, txId uint64, fltrs BlobLogFilters) ([]BlobLog, error) ByHeight(ctx context.Context, height types.Level, fltrs BlobLogFilters) ([]BlobLog, error) CountByTxId(ctx context.Context, txId uint64) (int, error) ExportByProviders(ctx context.Context, providers []RollupProvider, from, to time.Time, stream io.Writer) (err error) Blob(ctx context.Context, height types.Level, nsId uint64, commitment string) (BlobLog, error) ListBlobs(ctx context.Context, fltrs ListBlobLogFilters) ([]BlobLog, error) }
type IBlock ¶
type IBlock interface { storage.Table[*Block] Last(ctx context.Context) (Block, error) ByIdWithRelations(ctx context.Context, id uint64) (Block, error) ByHeight(ctx context.Context, height pkgTypes.Level) (Block, error) ByHeightWithStats(ctx context.Context, height pkgTypes.Level) (Block, error) ByHash(ctx context.Context, hash []byte) (Block, error) ByProposer(ctx context.Context, proposerId uint64, limit, offset int) ([]Block, error) ListWithStats(ctx context.Context, limit, offset uint64, order storage.SortOrder) ([]*Block, error) Time(ctx context.Context, height pkgTypes.Level) (time.Time, error) }
type IBlockSignature ¶ added in v1.4.0
type IBlockStats ¶
type IDelegation ¶ added in v1.6.0
type IDenomMetadata ¶
type IDenomMetadata interface {
All(ctx context.Context) ([]DenomMetadata, error)
}
type IHLMailbox ¶ added in v1.15.0
type IHLTransfer ¶ added in v1.15.0
type IHLTransfer interface { ById(ctx context.Context, id uint64) (HLTransfer, error) List(ctx context.Context, filters ListHyperlaneTransferFilters) ([]HLTransfer, error) Series(ctx context.Context, domainId uint64, timeframe Timeframe, column string, req SeriesRequest) (items []HistogramItem, err error) StatsByDomain(ctx context.Context, limit, offset int) ([]DomainStats, error) }
type IIbcChannel ¶ added in v1.13.0
type IIbcChannel interface { ById(ctx context.Context, id string) (IbcChannel, error) List(ctx context.Context, fltrs ListChannelFilters) ([]IbcChannel, error) StatsByChain(ctx context.Context, limit, offset int) ([]ChainStats, error) BusiestChannel1m(ctx context.Context) (BusiestChannel, error) }
type IIbcClient ¶ added in v1.13.0
type IIbcConnection ¶ added in v1.13.0
type IIbcConnection interface { ById(ctx context.Context, id string) (IbcConnection, error) IdsByClients(ctx context.Context, clientIds ...string) ([]string, error) List(ctx context.Context, fltrs ListConnectionFilters) ([]IbcConnection, error) }
type IIbcTransfer ¶ added in v1.13.0
type IIbcTransfer interface { ById(ctx context.Context, id uint64) (IbcTransfer, error) List(ctx context.Context, fltrs ListIbcTransferFilters) ([]IbcTransfer, error) Series(ctx context.Context, channelId string, timeframe Timeframe, column string, req SeriesRequest) (items []HistogramItem, err error) LargestTransfer24h(ctx context.Context) (IbcTransfer, error) }
type IMessage ¶
type IMessage interface { storage.Table[*Message] ByTxId(ctx context.Context, txId uint64, limit, offset int) ([]Message, error) ListWithTx(ctx context.Context, filters MessageListWithTxFilters) ([]MessageWithTx, error) ByAddress(ctx context.Context, id uint64, filters AddressMsgsFilter) ([]AddressMessageWithTx, error) }
type INamespace ¶
type INamespace interface { sdk.Table[*Namespace] ByNamespaceId(ctx context.Context, namespaceId []byte) ([]Namespace, error) ByNamespaceIdAndVersion(ctx context.Context, namespaceId []byte, version byte) (Namespace, error) Messages(ctx context.Context, id uint64, limit, offset int) ([]NamespaceMessage, error) ListWithSort(ctx context.Context, sortField string, sort sdk.SortOrder, limit, offset int) (ns []Namespace, err error) GetByIds(ctx context.Context, ids ...uint64) (ns []Namespace, err error) }
type IRedelegation ¶ added in v1.6.0
type IRedelegation interface { storage.Table[*Redelegation] ByAddress(ctx context.Context, addressId uint64, limit, offset int) ([]Redelegation, error) }
type IRollup ¶ added in v1.2.0
type IRollup interface { sdk.Table[*Rollup] Leaderboard(ctx context.Context, fltrs LeaderboardFilters) ([]RollupWithStats, error) LeaderboardDay(ctx context.Context, fltrs LeaderboardFilters) ([]RollupWithDayStats, error) Namespaces(ctx context.Context, rollupId uint64, limit, offset int) (namespaceIds []uint64, err error) Providers(ctx context.Context, rollupId uint64) (providers []RollupProvider, err error) RollupsByNamespace(ctx context.Context, namespaceId uint64, limit, offset int) (rollups []Rollup, err error) ById(ctx context.Context, rollupId uint64) (RollupWithStats, error) Series(ctx context.Context, rollupId uint64, timeframe Timeframe, column string, req SeriesRequest) (items []HistogramItem, err error) AllSeries(ctx context.Context, timeframe Timeframe) ([]RollupHistogramItem, error) Count(ctx context.Context) (int64, error) Distribution(ctx context.Context, rollupId uint64, series string, groupBy Timeframe) (items []DistributionItem, err error) BySlug(ctx context.Context, slug string) (RollupWithStats, error) RollupStatsGrouping(ctx context.Context, fltrs RollupGroupStatsFilters) ([]RollupGroupedStats, error) Tags(ctx context.Context) ([]string, error) Unverified(ctx context.Context) (rollups []Rollup, err error) }
type IRollupProvider ¶ added in v1.2.0
type IRollupProvider interface { storage.Table[*RollupProvider] }
type ISearch ¶ added in v1.4.0
type ISearch interface { Search(ctx context.Context, query []byte) ([]SearchResult, error) SearchText(ctx context.Context, text string) ([]SearchResult, error) }
type IStakingLog ¶ added in v1.6.0
type IStakingLog interface { storage.Table[*StakingLog] }
type IStats ¶
type IStats interface { Count(ctx context.Context, req CountRequest) (string, error) Summary(ctx context.Context, req SummaryRequest) (string, error) TPS(ctx context.Context) (TPS, error) Series(ctx context.Context, timeframe Timeframe, name string, req SeriesRequest) ([]SeriesItem, error) CumulativeSeries(ctx context.Context, timeframe Timeframe, name string, req SeriesRequest) ([]SeriesItem, error) NamespaceSeries(ctx context.Context, timeframe Timeframe, name string, nsId uint64, req SeriesRequest) (response []SeriesItem, err error) StakingSeries(ctx context.Context, timeframe Timeframe, name string, validatorId uint64, req SeriesRequest) (response []SeriesItem, err error) RollupStats24h(ctx context.Context) ([]RollupStats24h, error) SquareSize(ctx context.Context, from, to *time.Time) (map[int][]SeriesItem, error) Change24hBlockStats(ctx context.Context) (response Change24hBlockStats, err error) MessagesCount24h(ctx context.Context) ([]CountItem, error) SizeGroups(ctx context.Context, timeFilter *time.Time) ([]SizeGroup, error) }
type ITx ¶
type ITx interface { storage.Table[*Tx] ByHash(ctx context.Context, hash []byte) (Tx, error) IdAndTimeByHash(ctx context.Context, hash []byte) (uint64, time.Time, error) Filter(ctx context.Context, fltrs TxFilter) ([]Tx, error) ByIdWithRelations(ctx context.Context, id uint64) (Tx, error) ByAddress(ctx context.Context, addressId uint64, fltrs TxFilter) ([]Tx, error) Genesis(ctx context.Context, limit, offset int, sortOrder storage.SortOrder) ([]Tx, error) Gas(ctx context.Context, height pkgTypes.Level, ts time.Time) ([]Gas, error) }
type IUndelegation ¶ added in v1.6.0
type IUndelegation interface { storage.Table[*Undelegation] ByAddress(ctx context.Context, addressId uint64, limit, offset int) ([]Undelegation, error) }
type IValidator ¶
type IValidator interface { storage.Table[*Validator] ByAddress(ctx context.Context, address string) (Validator, error) TotalVotingPower(ctx context.Context) (decimal.Decimal, error) ListByPower(ctx context.Context, fltrs ValidatorFilters) ([]Validator, error) JailedCount(ctx context.Context) (int, error) }
type IVestingAccount ¶ added in v1.7.0
type IVestingAccount interface { storage.Table[*VestingAccount] ByAddress(ctx context.Context, addressId uint64, limit, offset int, showEnded bool) ([]VestingAccount, error) }
type IVestingPeriod ¶ added in v1.7.0
type IVestingPeriod interface { storage.Table[*VestingPeriod] ByVesting(ctx context.Context, id uint64, limit, offset int) ([]VestingPeriod, error) }
type IVote ¶ added in v1.12.0
type IVote interface { sdk.Table[*Vote] ByProposalId(ctx context.Context, proposalId uint64, fltrs VoteFilters) ([]Vote, error) ByVoterId(ctx context.Context, voterId uint64, fltrs VoteFilters) ([]Vote, error) ByValidatorId(ctx context.Context, validatorId uint64, fltrs VoteFilters) ([]Vote, error) }
type IbcChannel ¶ added in v1.13.0
type IbcChannel struct { bun.BaseModel `bun:"ibc_channel" comment:"Table with IBC channels."` Id string `bun:"id,pk" comment:"Channel identity"` ConnectionId string `bun:"connection_id" comment:"Connection identity"` PortId string `bun:"port_id" comment:"Port id"` CounterpartyPortId string `bun:"counterparty_port_id" comment:"Counterparty port identity"` CounterpartyChannelId string `bun:"counterparty_channel_id" comment:"Counterparty channel identity"` Version string `bun:"version" comment:"Version"` ClientId string `bun:"client_id" comment:"Client identity"` CreatedAt time.Time `bun:"created_at" comment:"Time whe channel was created"` ConfirmedAt time.Time `bun:"confirmed_at" comment:"Time whe channel was established"` Height pkgTypes.Level `bun:"height" comment:"Block number when channel was created"` ConfirmationHeight pkgTypes.Level `bun:"confirmation_height" comment:"Block number when channel was confirmed"` CreateTxId uint64 `bun:"create_tx_id" comment:"Transaction id of creation channel"` ConfirmationTxId uint64 `bun:"confirmation_tx_id" comment:"Transaction id of confirmation channel"` Ordering bool `bun:"ordering" comment:"Ordered or unordered packets in the channel"` CreatorId uint64 `bun:"creator_id" comment:"Internal creator identity"` Status types.IbcChannelStatus `bun:"status,type:ibc_channel_status" comment:"Channel status"` Received decimal.Decimal `bun:"received,type:numeric" comment:"Received value"` Sent decimal.Decimal `bun:"sent,type:numeric" comment:"Sent value"` TransfersCount int64 `bun:"transfers_count" comment:"Count transfers"` Connection *IbcConnection `bun:"rel:belongs-to,join:connection_id=connection_id"` Client *IbcClient `bun:"rel:belongs-to,join:client_id=id"` CreateTx *Tx `bun:"rel:belongs-to,join:create_tx_id=id"` ConfirmationTx *Tx `bun:"rel:belongs-to,join:confirmation_tx_id=id"` Creator *Address `bun:"rel:belongs-to,join:creator_id=id"` }
func (IbcChannel) TableName ¶ added in v1.13.0
func (IbcChannel) TableName() string
type IbcClient ¶ added in v1.13.0
type IbcClient struct { bun.BaseModel `bun:"ibc_client" comment:"Table with IBC clients."` Id string `bun:"id,pk,notnull" comment:"Client identity"` ChainId string `bun:"chain_id" comment:"Chain id"` Type string `bun:"type" comment:"Light client type"` CreatedAt time.Time `bun:"created_at" comment:"Creation time"` UpdatedAt time.Time `bun:"updated_at" comment:"Time of last update message"` Height pkgTypes.Level `bun:"height" comment:"Creation height"` TxId uint64 `bun:"tx_id" comment:"Internal transaction identity where client was created"` CreatorId uint64 `bun:"creator_id" comment:"Creator internal identity"` LatestRevisionHeight uint64 `bun:"latest_revision_height" comment:"Latest height the client was updated to"` LatestRevisionNumber uint64 `bun:"latest_revision_number" comment:"Revision number the client was updated to"` FrozenRevisionHeight uint64 `bun:"frozen_revision_height" comment:"Block height when the client was frozen due to a misbehaviour"` FrozenRevisionNumber uint64 `bun:"frozen_revision_number" comment:"Revision number when the client was frozen due to a misbehaviour"` TrustingPeriod time.Duration `` /* 146-byte string literal not displayed */ UnbondingPeriod time.Duration `bun:"unbonding_period" comment:"Duration of the staking unbonding period"` MaxClockDrift time.Duration `bun:"max_clock_drift" comment:"Defines how much new (untrusted) header's time can drift into the future"` TrustLevelDenominator uint64 `bun:"trust_level_denominator" comment:"Denominator of trust level"` TrustLevelNumerator uint64 `bun:"trust_level_numerator" comment:"Numerator of trust level"` ConnectionCount uint64 `bun:"connection_count" comment:"Count of connections which is associated with client"` Tx *Tx `bun:"rel:belongs-to,join:tx_id=id"` Creator *Address `bun:"rel:belongs-to,join:creator_id=id"` }
type IbcConnection ¶ added in v1.13.0
type IbcConnection struct { bun.BaseModel `bun:"ibc_connection" comment:"Table with IBC connections."` ConnectionId string `bun:"connection_id,pk" comment:"Connection identity"` ClientId string `bun:"client_id" comment:"Client identity"` CounterpartyConnectionId string `bun:"counterparty_connection_id" comment:"Counterparty connection identity"` CounterpartyClientId string `bun:"counterparty_client_id" comment:"Counterparty client identity"` CreatedAt time.Time `bun:"created_at" comment:"Time whe connection was created"` ConnectedAt time.Time `bun:"connected_at" comment:"Time whe connection was established"` Height pkgTypes.Level `bun:"height" comment:"Block number when connection was created"` ConnectionHeight pkgTypes.Level `bun:"connection_height" comment:"Block number when connection was established"` CreateTxId uint64 `bun:"create_tx_id" comment:"Transaction id of creation connection"` ConnectionTxId uint64 `bun:"connection_tx_id" comment:"Transaction id of establishing connection"` ChannelsCount int64 `bun:"channels_count" comment:"Count of channels which was opened in the connection"` Client *IbcClient `bun:"rel:belongs-to,join:client_id=id"` CreateTx *Tx `bun:"rel:belongs-to,join:create_tx_id=id"` ConnectionTx *Tx `bun:"rel:belongs-to,join:connection_tx_id=id"` }
func (IbcConnection) TableName ¶ added in v1.13.0
func (IbcConnection) TableName() string
type IbcTransfer ¶ added in v1.13.0
type IbcTransfer struct { bun.BaseModel `bun:"ibc_transfer" comment:"Table with IBC transfers."` Id uint64 `bun:"id,pk,autoincrement" comment:"Transfer internal identity"` Time time.Time `bun:"time,notnull,pk" comment:"Message time"` Height pkgTypes.Level `bun:"height" comment:"Block number"` Amount decimal.Decimal `bun:"amount,type:numeric" comment:"Transferred amount"` Denom string `bun:"denom" comment:"Currency"` Memo string `bun:"memo" comment:"Memo"` ReceiverAddress *string `bun:"receiver_address" comment:"Receiver string. It's not null if it's not celestia address."` ReceiverId *uint64 `bun:"receiver_id" comment:"Receiver id. It's not null if it's celestia address."` SenderAddress *string `bun:"sender_address" comment:"Sender string. It's not null if it's not celestia address."` SenderId *uint64 `bun:"sender_id" comment:"Sender id. It's not null if it's celestia address."` ConnectionId string `bun:"connection_id" comment:"Connection identity"` ChannelId string `bun:"channel_id" comment:"Channel identity"` Port string `bun:"port" comment:"Port"` Timeout *time.Time `bun:"timeout,nullzero" comment:"Date-time timeout"` HeightTimeout uint64 `bun:"height_timeout,nullzero" comment:"Height timeout"` Sequence uint64 `bun:"sequence" comment:"Sequence number of packet"` TxId uint64 `bun:"tx_id" comment:"Transaction id where transfer occurred"` Tx *Tx `bun:"rel:belongs-to,join:tx_id=id"` Receiver *Address `bun:"rel:belongs-to,join:receiver_id=id"` Sender *Address `bun:"rel:belongs-to,join:sender_id=id"` Connection *IbcConnection `bun:"rel:belongs-to,join:connection_id=connection_id"` }
func (IbcTransfer) TableName ¶ added in v1.13.0
func (IbcTransfer) TableName() string
type Jail ¶ added in v1.6.0
type Jail struct { bun.BaseModel `bun:"jail" comment:"Table with all jailed events."` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal id"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block"` Height pkgTypes.Level `bun:"height,notnull" comment:"The number (height) of this block"` ValidatorId uint64 `bun:"validator_id,notnull" comment:"Internal validator id"` Reason string `bun:"reason" comment:"Reason"` Burned decimal.Decimal `bun:"burned,type:numeric" comment:"Burned coins"` Validator *Validator `bun:"rel:belongs-to,join:validator_id=id"` }
Jail -
type LeaderboardFilters ¶ added in v1.10.4
type ListBlobLogFilters ¶ added in v1.10.0
type ListChannelFilters ¶ added in v1.13.0
type ListConnectionFilters ¶ added in v1.13.0
type ListHyperlaneTokens ¶ added in v1.15.0
type ListHyperlaneTransferFilters ¶ added in v1.15.22
type ListIbcClientsFilters ¶ added in v1.15.17
type ListIbcTransferFilters ¶ added in v1.13.0
type ListProposalFilters ¶ added in v1.12.0
type ListProposalFilters struct { Limit int Offset int ProposerId uint64 Sort sdk.SortOrder Status []types.ProposalStatus Type []types.ProposalType }
type ListenerFactory ¶
type ListenerFactory interface {
CreateListener() Listener
}
type Message ¶
type Message struct { bun.BaseModel `bun:"message" comment:"Table with celestia messages."` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal id"` Height pkgTypes.Level `bun:",notnull" comment:"The number (height) of this block" stats:"func:min max,filterable"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block" stats:"func:min max,filterable"` Position int64 `bun:"position" comment:"Position in transaction"` Type types.MsgType `bun:",type:msg_type" comment:"Message type" stats:"filterable"` TxId uint64 `bun:"tx_id" comment:"Parent transaction id"` Size int `bun:"size" comment:"Message size in bytes"` Data types.PackedBytes `bun:"data,type:bytea,nullzero" comment:"Message data"` Namespace []Namespace `bun:"m2m:namespace_message,join:Message=Namespace"` Addresses []AddressWithType `bun:"-"` BlobLogs []*BlobLog `bun:"-"` Grants []Grant `bun:"-"` InternalMsgs []string `bun:"-"` // field for parsing MsgExec internal messages VestingAccount *VestingAccount `bun:"-"` // internal field Proposal *Proposal `bun:"-"` // internal field IbcClient *IbcClient `bun:"-"` // internal field IbcConnection *IbcConnection `bun:"-"` // internal field IbcChannel *IbcChannel `bun:"-"` // internal field IbcTransfer *IbcTransfer `bun:"-"` // internal field HLMailbox *HLMailbox `bun:"-"` // internal field HLTransfer *HLTransfer `bun:"-"` // internal field HLToken *HLToken `bun:"-"` // internal field }
Message -
type MessageListWithTxFilters ¶ added in v1.0.4
type MessageWithTx ¶ added in v1.0.4
type MsgAddress ¶
type MsgAddress struct { bun.BaseModel `bun:"msg_address" comment:"Table with relation tx to address"` AddressId uint64 `bun:"address_id,pk" comment:"Address internal id"` MsgId uint64 `bun:"msg_id,pk" comment:"Message internal id"` Type types.MsgAddressType `bun:",pk,type:msg_address_type" comment:"The reason why address link to transaction"` Address *Address `bun:"rel:belongs-to,join:address_id=id"` Msg *Message `bun:"rel:belongs-to,join:msg_id=id"` }
func (MsgAddress) String ¶ added in v1.0.4
func (m MsgAddress) String() string
func (MsgAddress) TableName ¶
func (MsgAddress) TableName() string
type Namespace ¶
type Namespace struct { bun.BaseModel `bun:"namespace" comment:"Table with celestia namespaces."` Id uint64 `bun:"id,pk,autoincrement" comment:"Unique internal identity"` FirstHeight types.Level `bun:"first_height,notnull" comment:"Block height of the first message changing the namespace"` LastHeight types.Level `bun:"last_height,notnull" comment:"Block height of the last message changing the namespace"` Version byte `bun:"version,unique:namespace_id_version_idx" comment:"Namespace version"` NamespaceID []byte `bun:"namespace_id,unique:namespace_id_version_idx" comment:"Namespace identity"` Size int64 `bun:"size" comment:"Blobs size"` PfbCount int64 `bun:"pfb_count" comment:"Count of pay for blobs messages for the namespace"` BlobsCount int64 `bun:"blobs_count" comment:"Count of blobs sent to namespace"` Reserved bool `bun:"reserved,default:false" comment:"If namespace is reserved flag is true"` LastMessageTime time.Time `bun:"last_message_time" comment:"Time when last pay for blob was sent"` }
Namespace -
type NamespaceMessage ¶
type NamespaceMessage struct { bun.BaseModel `bun:"namespace_message" comment:"Table with relation messages to namespace."` NamespaceId uint64 `bun:"namespace_id,pk" comment:"Namespace internal id"` MsgId uint64 `bun:"msg_id,pk" comment:"Message id"` TxId uint64 `bun:"tx_id" comment:"Transaction id"` Time time.Time `bun:"time,notnull,pk" comment:"Message time"` Height types.Level `bun:"height" comment:"Message block height"` Size uint64 `bun:"size" comment:"Total namespace size change due to message"` Message *Message `bun:"rel:belongs-to,join:msg_id=id"` Namespace *Namespace `bun:"rel:belongs-to,join:namespace_id=id"` Tx *Tx `bun:"rel:belongs-to,join:tx_id=id"` }
func (NamespaceMessage) TableName ¶
func (NamespaceMessage) TableName() string
type Notificator ¶
type Proposal ¶ added in v1.12.0
type Proposal struct { bun.BaseModel `bun:"proposal" comment:"Table with proposals"` Id uint64 `bun:"id,pk" comment:"Unique identity"` Height pkgTypes.Level `bun:"height" comment:"The number (height) of this block"` ProposerId uint64 `bun:"proposer_id" comment:"Proposer address identity"` CreatedAt time.Time `bun:"created_at,notnull" comment:"Creation time"` DepositTime time.Time `bun:"deposit_time" comment:"Time to end of deposit period"` ActivationTime *time.Time `bun:"activation_time" comment:"Voting start time"` EndTime *time.Time `bun:"end_time" comment:"Voting end time"` Status types.ProposalStatus `bun:"status,type:proposal_status" comment:"Proposal status"` Type types.ProposalType `bun:"type,type:proposal_type" comment:"Proposal type"` Title string `bun:"title" comment:"Title"` Description string `bun:"description" comment:"Proposal description"` Deposit decimal.Decimal `bun:"deposit,type:numeric" comment:"Deposit"` Metadata string `bun:"metadata" comment:"Metadata"` Changes []byte `bun:"changes,type:bytea" comment:"JSON object with proposal changes"` VotesCount int64 `bun:"votes_count" comment:"Total votes count"` Yes int64 `bun:"yes" comment:"Count of yes votes"` No int64 `bun:"no" comment:"Count of no votes"` NoWithVeto int64 `bun:"no_with_veto" comment:"Count of no votes with veto"` Abstain int64 `bun:"abstain" comment:"Count of abstain votes"` YesValidators int64 `bun:"yes_vals" comment:"Count of yes votes by validators"` NoValidators int64 `bun:"no_vals" comment:"Count of no votes by validators"` NoWithVetoValidators int64 `bun:"no_with_veto_vals" comment:"Count of no votes with veto by validators"` AbstainValidators int64 `bun:"abstain_vals" comment:"Count of abstain votes by validators"` YesAddress int64 `bun:"yes_addrs" comment:"Count of yes votes by addresses"` NoAddress int64 `bun:"no_addrs" comment:"Count of no votes by addresses"` NoWithVetoAddress int64 `bun:"no_with_veto_addrs" comment:"Count of no votes with veto by addresses"` AbstainAddress int64 `bun:"abstain_addrs" comment:"Count of abstain votes by addresses"` VotingPower decimal.Decimal `bun:"voting_power,type:numeric" comment:"Summary voting power of all votes"` YesVotingPower decimal.Decimal `bun:"yes_voting_power,type:numeric" comment:"Yes voting power"` NoVotingPower decimal.Decimal `bun:"no_voting_power,type:numeric" comment:"No voting power"` NoWithVetoVotingPower decimal.Decimal `bun:"no_with_veto_voting_power,type:numeric" comment:"No with veto voting power"` AbstainVotingPower decimal.Decimal `bun:"abstain_voting_power,type:numeric" comment:"Abstain voting power"` TotalVotingPower decimal.Decimal `bun:"total_voting_power,type:numeric" comment:"Total voting power in the network"` Quorum string `` /* 129-byte string literal not displayed */ VetoQuorum string `bun:"veto_quorum" comment:"Minimum value of Veto votes to Total votes ratio for proposal to be vetoed"` Threshold string `bun:"threshold" comment:"Minimum proportion of Yes votes for proposal to pass"` MinDeposit string `bun:"min_deposit" comment:"Minimum deposit for a proposal to enter voting period"` Proposer *Address `bun:"rel:belongs-to,join:proposer_id=id"` }
func (Proposal) EmptyStatus ¶ added in v1.12.0
type Redelegation ¶ added in v1.6.0
type Redelegation struct { bun.BaseModel `bun:"redelegation" comment:"Table with redelegations"` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal id"` Time time.Time `bun:"time,notnull" comment:"The time of block"` Height pkgTypes.Level `bun:",notnull" comment:"The number (height) of this block"` AddressId uint64 `bun:"address_id" comment:"Internal address id"` SrcId uint64 `bun:"src_id" comment:"Internal source validator id"` DestId uint64 `bun:"dest_id" comment:"Internal destination validator id"` Amount decimal.Decimal `bun:"amount,type:numeric" comment:"Delegated amount"` CompletionTime time.Time `bun:"completion_time" comment:"Time when redelegation will be completed"` Address *Address `bun:"rel:belongs-to,join:address_id=id"` Source *Validator `bun:"rel:belongs-to,join:src_id=id"` Destination *Validator `bun:"rel:belongs-to,join:dest_id=id"` }
Redelegation -
type RolluDayStats ¶ added in v1.9.10
type RolluDayStats struct { AvgSize float64 `bun:"avg_size"` BlobsCount int64 `bun:"blobs_count"` TotalSize int64 `bun:"total_size"` Throghput int64 `bun:"throughput"` TotalFee decimal.Decimal `bun:"total_fee"` NamespaceCount int64 `bun:"namespace_count"` PfbCount int64 `bun:"pfb_count"` MBPrice decimal.Decimal `bun:"mb_price"` }
type Rollup ¶ added in v1.2.0
type Rollup struct { bun.BaseModel `bun:"rollup" comment:"Table with rollups."` Id uint64 `bun:"id,pk,autoincrement" comment:"Unique internal identity"` Name string `bun:"name" comment:"Rollup's name"` Description string `bun:"description" comment:"Rollup's description"` Website string `bun:"website" comment:"Website"` GitHub string `bun:"github" comment:"Github repository"` Twitter string `bun:"twitter" comment:"Twitter account"` Logo string `bun:"logo" comment:"Link to rollup logo"` Slug string `bun:"slug,unique:rollup_slug" comment:"Rollup slug"` BridgeContract string `bun:"bridge_contract" comment:"Link to bridge contract"` L2Beat string `bun:"l2_beat" comment:"Link to L2 Beat"` DeFiLama string `bun:"defi_lama" comment:"DeFi Lama chain name"` Explorer string `bun:"explorer" comment:"Link to chain explorer"` Stack string `bun:"stack" comment:"Underlaying stack"` Compression string `bun:"compression" comment:"Compression"` Provider string `bun:"provider" comment:"RaaS provider"` SettledOn string `bun:"settled_on" comment:"Settled on"` Type types.RollupType `bun:"type,type:rollup_type" comment:"Type of rollup: settled or sovereign"` Category types.RollupCategory `bun:"category,type:rollup_category" comment:"Category of rollup"` Tags []string `bun:"tags,array"` VM string `bun:"vm" comment:"Virtual machine"` Color string `bun:"color" comment:"Roolup brand color"` Links []string `bun:"links,array" comment:"Other links to rollup related sites"` Verified bool `bun:"verified"` Providers []*RollupProvider `bun:"rel:has-many,join:id=rollup_id"` }
Rollup -
type RollupGroupStatsFilters ¶ added in v1.10.8
type RollupGroupedStats ¶ added in v1.10.8
type RollupHistogramItem ¶ added in v1.9.10
type RollupProvider ¶ added in v1.2.0
type RollupProvider struct { bun.BaseModel `bun:"rollup_provider" comment:"Table with data providers for rollups."` RollupId uint64 `bun:"rollup_id,pk" comment:"Unique internal rollup identity"` NamespaceId uint64 `bun:"namespace_id,pk" comment:"Namespace identity. May be NULL"` AddressId uint64 `bun:"address_id,pk" comment:"Celestia address of data provider"` }
RollupProvider -
func (RollupProvider) TableName ¶ added in v1.2.0
func (RollupProvider) TableName() string
TableName -
type RollupStats ¶ added in v1.3.2
type RollupStats struct { Size int64 `bun:"size"` BlobsCount int64 `bun:"blobs_count"` LastActionTime time.Time `bun:"last_time"` FirstActionTime time.Time `bun:"first_time"` Fee decimal.Decimal `bun:"fee"` SizePct float64 `bun:"size_pct"` FeePct float64 `bun:"fee_pct"` BlobsCountPct float64 `bun:"blobs_count_pct"` IsActive bool `bun:"is_active"` }
type RollupStats24h ¶ added in v1.9.7
type RollupWithDayStats ¶ added in v1.9.10
type RollupWithDayStats struct { Rollup RolluDayStats }
type RollupWithStats ¶ added in v1.2.0
type RollupWithStats struct { Rollup RollupStats DAChange }
type SearchResult ¶ added in v1.4.0
type SeriesItem ¶ added in v1.1.0
type SeriesRequest ¶ added in v1.1.0
func NewSeriesRequest ¶ added in v1.3.2
func NewSeriesRequest(from, to int64) SeriesRequest
type Signer ¶
type Signer struct { bun.BaseModel `bun:"signer" comment:"Table with signers tx"` AddressId uint64 `bun:"address_id,pk" comment:"Address internal id"` TxId uint64 `bun:"tx_id,pk" comment:"Transaction internal id"` Address *Address `bun:"rel:belongs-to,join:address_id=id"` Tx *Tx `bun:"rel:belongs-to,join:tx_id=id"` }
type StakingLog ¶ added in v1.6.0
type StakingLog struct { bun.BaseModel `bun:"staking_log" comment:"Table with staking events log"` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal id"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block" stats:"func:min max,filterable"` Height pkgTypes.Level `bun:"height,notnull" comment:"The number (height) of this block" stats:"func:min max,filterable"` AddressId *uint64 `bun:"address_id" comment:"Internal address id"` ValidatorId uint64 `bun:"validator_id" comment:"Internal validator id"` Change decimal.Decimal `bun:"change,type:numeric" comment:"Change amount"` Type types.StakingLogType `bun:"type,type:staking_log_type" comment:"Staking log type"` Address *Address `bun:"rel:belongs-to,join:address_id=id"` Validator *Validator `bun:"rel:belongs-to,join:validator_id=id"` }
Delegation -
type State ¶
type State struct { bun.BaseModel `bun:"state" comment:"Current indexer state"` Id uint64 `bun:",pk,autoincrement" comment:"Unique internal identity"` Name string `bun:",unique:state_name" comment:"Indexer name"` LastHeight types.Level `bun:"last_height" comment:"Last block height"` LastHash []byte `bun:"last_hash" comment:"Last block hash"` LastTime time.Time `bun:"last_time" comment:"Time of last block"` ChainId string `bun:"chain_id" comment:"Celestia chain id"` TotalTx int64 `bun:"total_tx" comment:"Transactions count in celestia"` TotalAccounts int64 `bun:"total_accounts" comment:"Accounts count in celestia"` TotalNamespaces int64 `bun:"total_namespaces" comment:"Namespaces count in celestia"` TotalBlobsSize int64 `bun:"total_blobs_size" comment:"Total blobs size"` TotalProposals int64 `bun:"total_proposals" comment:"Total proposals count in celestia"` TotalIbcClients int64 `bun:"total_ibc_clients" comment:"Total count of IBC clients"` TotalValidators int `bun:"total_validators" comment:"Total validator's count"` TotalSupply decimal.Decimal `bun:"total_supply,type:numeric" comment:"Total supply in celestia"` TotalFee decimal.Decimal `bun:"total_fee,type:numeric" comment:"Total paid fee"` TotalStake decimal.Decimal `bun:"total_stake,type:numeric" comment:"Total stake"` TotalVotingPower decimal.Decimal `bun:"-"` }
State -
type SummaryRequest ¶
type SummaryRequest struct { CountRequest Column string Function string }
func (SummaryRequest) Validate ¶
func (req SummaryRequest) Validate() error
type Transaction ¶
type Transaction interface { sdk.Transaction SaveConstants(ctx context.Context, constants ...Constant) error SaveTransactions(ctx context.Context, txs ...Tx) error SaveNamespaces(ctx context.Context, namespaces ...*Namespace) (int64, error) SaveAddresses(ctx context.Context, addresses ...*Address) (int64, error) SaveVestingAccounts(ctx context.Context, accounts ...*VestingAccount) error SaveVestingPeriods(ctx context.Context, periods ...VestingPeriod) error SaveBalances(ctx context.Context, balances ...Balance) error SaveMessages(ctx context.Context, msgs ...*Message) error SaveSigners(ctx context.Context, addresses ...Signer) error SaveMsgAddresses(ctx context.Context, addresses ...MsgAddress) error SaveNamespaceMessage(ctx context.Context, nsMsgs ...NamespaceMessage) error SaveBlobLogs(ctx context.Context, logs ...BlobLog) error SaveValidators(ctx context.Context, validators ...*Validator) (int, error) SaveEvents(ctx context.Context, events ...Event) error SaveRollup(ctx context.Context, rollup *Rollup) error SaveGrants(ctx context.Context, grants ...Grant) error UpdateRollup(ctx context.Context, rollup *Rollup) error SaveProviders(ctx context.Context, providers ...RollupProvider) error SaveUndelegations(ctx context.Context, undelegations ...Undelegation) error SaveRedelegations(ctx context.Context, redelegations ...Redelegation) error SaveDelegations(ctx context.Context, delegations ...Delegation) error UpdateSlashedDelegations(ctx context.Context, validatorId uint64, fraction decimal.Decimal) ([]Balance, error) SaveStakingLogs(ctx context.Context, logs ...StakingLog) error SaveJails(ctx context.Context, jails ...Jail) error SaveBlockSignatures(ctx context.Context, signs ...BlockSignature) error SaveProposals(ctx context.Context, proposals ...*Proposal) (int64, error) SaveVotes(ctx context.Context, votes ...*Vote) error SaveIbcClients(ctx context.Context, clients ...*IbcClient) (int64, error) SaveIbcConnections(ctx context.Context, connections ...*IbcConnection) error SaveIbcChannels(ctx context.Context, channels ...*IbcChannel) error SaveIbcTransfers(ctx context.Context, transfers ...*IbcTransfer) error SaveHyperlaneMailbox(ctx context.Context, mailbox ...*HLMailbox) error SaveHyperlaneTokens(ctx context.Context, tokens ...*HLToken) error SaveHyperlaneTransfers(ctx context.Context, transfers ...*HLTransfer) error RetentionBlockSignatures(ctx context.Context, height types.Level) error CancelUnbondings(ctx context.Context, cancellations ...Undelegation) error RetentionCompletedUnbondings(ctx context.Context, blockTime time.Time) error RetentionCompletedRedelegations(ctx context.Context, blockTime time.Time) error Jail(ctx context.Context, validators ...*Validator) error RollbackBlock(ctx context.Context, height types.Level) error RollbackBlockStats(ctx context.Context, height types.Level) (stats BlockStats, err error) RollbackAddresses(ctx context.Context, height types.Level) (address []Address, err error) RollbackVestingAccounts(ctx context.Context, height types.Level) error RollbackVestingPeriods(ctx context.Context, height types.Level) error RollbackTxs(ctx context.Context, height types.Level) (txs []Tx, err error) RollbackEvents(ctx context.Context, height types.Level) (events []Event, err error) RollbackMessages(ctx context.Context, height types.Level) (msgs []Message, err error) RollbackNamespaceMessages(ctx context.Context, height types.Level) (msgs []NamespaceMessage, err error) RollbackNamespaces(ctx context.Context, height types.Level) (ns []Namespace, err error) RollbackValidators(ctx context.Context, height types.Level) ([]Validator, error) RollbackBlobLog(ctx context.Context, height types.Level) error RollbackGrants(ctx context.Context, height types.Level) error RollbackBlockSignatures(ctx context.Context, height types.Level) (err error) RollbackSigners(ctx context.Context, txIds []uint64) (err error) RollbackMessageAddresses(ctx context.Context, msgIds []uint64) (err error) RollbackUndelegations(ctx context.Context, height types.Level) (err error) RollbackRedelegations(ctx context.Context, height types.Level) (err error) RollbackStakingLogs(ctx context.Context, height types.Level) ([]StakingLog, error) RollbackJails(ctx context.Context, height types.Level) ([]Jail, error) RollbackProposals(ctx context.Context, height types.Level) error RollbackVotes(ctx context.Context, height types.Level) error RollbackIbcClients(ctx context.Context, height types.Level) error RollbackIbcConnections(ctx context.Context, height types.Level) error RollbackIbcChannels(ctx context.Context, height types.Level) error RollbackIbcTransfers(ctx context.Context, height types.Level) error RollbackHyperlaneMailbox(ctx context.Context, height types.Level) error RollbackHyperlaneTokens(ctx context.Context, height types.Level) error RollbackHyperlaneTransfers(ctx context.Context, height types.Level) error DeleteBalances(ctx context.Context, ids []uint64) error DeleteProviders(ctx context.Context, rollupId uint64) error DeleteRollup(ctx context.Context, rollupId uint64) error DeleteDelegationsByValidator(ctx context.Context, ids ...uint64) error UpdateValidators(ctx context.Context, validators ...*Validator) error State(ctx context.Context, name string) (state State, err error) LastBlock(ctx context.Context) (block Block, err error) Namespace(ctx context.Context, id uint64) (ns Namespace, err error) LastNamespaceMessage(ctx context.Context, nsId uint64) (msg NamespaceMessage, err error) LastAddressAction(ctx context.Context, address []byte) (uint64, error) GetProposerId(ctx context.Context, address string) (uint64, error) Validator(ctx context.Context, id uint64) (val Validator, err error) BondedValidators(ctx context.Context, limit int) ([]Validator, error) Delegation(ctx context.Context, validatorId, addressId uint64) (val Delegation, err error) AddressDelegations(ctx context.Context, addressId uint64) (val []Delegation, err error) ActiveProposals(ctx context.Context) ([]Proposal, error) ProposalVotes(ctx context.Context, proposalId uint64, limit, offset int) ([]Vote, error) Proposal(ctx context.Context, id uint64) (Proposal, error) RefreshLeaderboard(ctx context.Context) error IbcConnection(ctx context.Context, id string) (IbcConnection, error) HyperlaneMailbox(ctx context.Context, internalId uint64) (HLMailbox, error) HyperlaneToken(ctx context.Context, id []byte) (HLToken, error) }
type Tx ¶
type Tx struct { bun.BaseModel `bun:"tx" comment:"Table with celestia transactions."` Id uint64 `bun:"id,autoincrement,pk,notnull" comment:"Unique internal id"` Height pkgTypes.Level `bun:",notnull" comment:"The number (height) of this block" stats:"func:min max,filterable"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block" stats:"func:min max,filterable"` Position int64 `bun:"position" comment:"Position in block"` GasWanted int64 `bun:"gas_wanted" comment:"Gas wanted" stats:"func:min max sum avg"` GasUsed int64 `bun:"gas_used" comment:"Gas used" stats:"func:min max sum avg"` TimeoutHeight uint64 `bun:"timeout_height" comment:"Block height until which the transaction is valid" stats:"func:min max avg"` EventsCount int64 `bun:"events_count" comment:"Events count in transaction" stats:"func:min max sum avg"` MessagesCount int64 `bun:"messages_count" comment:"Messages count in transaction" stats:"func:min max sum avg"` Fee decimal.Decimal `bun:"fee,type:numeric" comment:"Paid fee" stats:"func:min max sum avg"` Status types.Status `bun:"status,type:status" comment:"Transaction status" stats:"filterable"` Error string `bun:"error,type:text" comment:"Error string if failed"` Codespace string `bun:"codespace,type:text" comment:"Codespace" stats:"filterable"` Hash []byte `bun:"hash" comment:"Transaction hash"` Memo string `bun:"memo,type:text" comment:"Note or comment to send with the transaction"` MessageTypes types.MsgTypeBits `bun:"message_types,type:bit(104)" comment:"Bit mask with containing messages" stats:"filterable"` Messages []Message `bun:"rel:has-many,join:id=tx_id"` Events []Event `bun:"rel:has-many"` Signers []Address `bun:"-"` BlobsSize int64 `bun:"-"` BytesSize int64 `bun:"-"` BlobsCount int `bun:"-"` }
Tx -
type Undelegation ¶ added in v1.6.0
type Undelegation struct { bun.BaseModel `bun:"undelegation" comment:"Table with undelegations"` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal id"` Time time.Time `bun:"time,notnull" comment:"The time of block"` Height pkgTypes.Level `bun:",notnull" comment:"The number (height) of this block"` AddressId uint64 `bun:"address_id" comment:"Internal address id"` ValidatorId uint64 `bun:"validator_id" comment:"Internal validator id"` Amount decimal.Decimal `bun:"amount,type:numeric" comment:"Delegated amount"` CompletionTime time.Time `bun:"completion_time" comment:"Time when undelegation will be completed"` Address *Address `bun:"rel:belongs-to,join:address_id=id"` Validator *Validator `bun:"rel:belongs-to,join:validator_id=id"` }
Undelegation -
type Validator ¶
type Validator struct { bun.BaseModel `bun:"validator" comment:"Table with celestia validators."` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal identity"` Delegator string `bun:"delegator,type:text" comment:"Delegator address" json:"-"` Address string `bun:"address,unique:address_validator,type:text" comment:"Validator address" json:"-"` ConsAddress string `bun:"cons_address" comment:"Consensus address" json:"-"` Moniker string `bun:"moniker,type:text" comment:"Human-readable name for the validator" json:"-"` Website string `bun:"website,type:text" comment:"Website link" json:"-"` Identity string `bun:"identity,type:text" comment:"Optional identity signature" json:"-"` Contacts string `bun:"contacts,type:text" comment:"Contacts" json:"-"` Details string `bun:"details,type:text" comment:"Detailed information about validator" json:"-"` Rate decimal.Decimal `` /* 128-byte string literal not displayed */ MaxRate decimal.Decimal `` /* 128-byte string literal not displayed */ MaxChangeRate decimal.Decimal `` /* 128-byte string literal not displayed */ MinSelfDelegation decimal.Decimal `` /* 128-byte string literal not displayed */ Stake decimal.Decimal `bun:"stake,type:numeric" comment:"Validator's stake" json:"-"` Rewards decimal.Decimal `bun:"rewards,type:numeric" comment:"Validator's rewards" json:"-"` Commissions decimal.Decimal `bun:"commissions,type:numeric" comment:"Commissions" json:"-"` Height pkgTypes.Level `bun:"height" comment:"Height when validator was created" json:"-"` Jailed *bool `bun:"jailed" comment:"True if validator was punished" json:"-"` }
func EmptyValidator ¶ added in v1.6.0
func EmptyValidator() Validator
type ValidatorFilters ¶ added in v1.6.0
type VestingAccount ¶ added in v1.7.0
type VestingAccount struct { bun.BaseModel `bun:"vesting_account" comment:"Table with vesting accounts"` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal identity"` Height pkgTypes.Level `bun:"height,notnull" comment:"The number (height) of this block"` Time time.Time `bun:"time,notnull" comment:"The time of block"` TxId *uint64 `bun:"tx_id" comment:"Transaction internal identity"` AddressId uint64 `bun:"address_id,notnull" comment:"Address internal id"` Type types.VestingType `bun:"type,type:vesting_type" comment:"Type vesting account"` Amount decimal.Decimal `bun:"amount,type:numeric" comment:"Vested amount"` StartTime *time.Time `bun:"start_time" comment:"Start time of unlock value"` EndTime *time.Time `bun:"end_time" comment:"End time of unlock value"` Address *Address `bun:"rel:has-one"` Tx *Tx `bun:"rel:has-one"` VestingPeriods []VestingPeriod `bun:"rel:has-many"` }
func (VestingAccount) TableName ¶ added in v1.7.0
func (VestingAccount) TableName() string
type VestingPeriod ¶ added in v1.7.0
type VestingPeriod struct { bun.BaseModel `bun:"vesting_period" comment:"Table with vesting periods"` Id uint64 `bun:"id,pk,notnull,autoincrement" comment:"Unique internal identity"` Height pkgTypes.Level `bun:"height,notnull" comment:"The number (height) of this block"` VestingAccountId uint64 `bun:"vesting_account_id" comment:"Vesting account internal identity"` Time time.Time `bun:"time,notnull" comment:"The time of periodic vesting"` Amount decimal.Decimal `bun:"amount,type:numeric" comment:"Vested amount"` }
func (VestingPeriod) TableName ¶ added in v1.7.0
func (VestingPeriod) TableName() string
type Vote ¶ added in v1.12.0
type Vote struct { bun.BaseModel `bun:"vote" comment:"Table with proposal's votes"` Id uint64 `bun:"id,pk,autoincrement" comment:"Unique internal identity"` Height pkgTypes.Level `bun:"height,notnull" comment:"The number (height) of this block"` Time time.Time `bun:"time,pk,notnull" comment:"The time of block"` Option types.VoteOption `bun:"option,type:vote_option" comment:"Selected vote option"` Weight decimal.Decimal `bun:"weight,type:numeric" comment:"Vote's weight"` VoterId uint64 `bun:"voter_id" comment:"Voter internal identity"` ProposalId uint64 `bun:"proposal_id" comment:"Proposal id"` ValidatorId uint64 `bun:"validator_id" comment:"Validator id"` Voter *Address `bun:"rel:belongs-to,join:voter_id=id"` Proposal *Proposal `bun:"rel:belongs-to,join:proposal_id=id"` Validator *Validator `bun:"rel:belongs-to,join:validator_id=id"` }
type VoteFilters ¶ added in v1.12.0
Source Files
¶
- address.go
- api_key.go
- balance.go
- blob_log.go
- block.go
- block_signature.go
- block_stats.go
- constant.go
- delegation.go
- denom_metadata.go
- errors.go
- event.go
- generic.go
- grant.go
- hl_mailbox.go
- hl_token.go
- hl_transfer.go
- ibc_channel.go
- ibc_client.go
- ibc_connection.go
- ibc_transfer.go
- jail.go
- message.go
- message_address.go
- namespace.go
- namespace_message.go
- proposal.go
- redelegation.go
- rollup.go
- rollup_provider.go
- signers.go
- staking_log.go
- state.go
- stats.go
- tx.go
- undelegation.go
- validator.go
- vesting_account.go
- vesting_period.go
- views.go
- vote.go
Directories
¶
Path | Synopsis |
---|---|
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.