Documentation
¶
Index ¶
- func RunMigrations(logger *zap.Logger, pgConnectionString string, downFirst bool) error
- type AssociatedWallet
- type Block
- type Comment
- type CommentMention
- type CommentNotificationSetting
- type CommentReaction
- type CommentReport
- type CommentThread
- type CoreIndexedBlock
- type DBTX
- type DashboardWalletUser
- type DeregisterValidatorParams
- type DeveloperApp
- type EmailAccess
- type EncryptedEmail
- type EtlAddress
- type EtlBlock
- type EtlManageEntity
- type EtlPlay
- type EtlSlaNodeReport
- type EtlSlaRollup
- type EtlStorageProof
- type EtlStorageProofVerification
- type EtlTransaction
- type EtlValidator
- type EtlValidatorDeregistration
- type EtlValidatorMisbehaviorDeregistration
- type EtlValidatorRegistration
- type Event
- type Follow
- type GetActiveValidatorsParams
- type GetAllActiveValidatorsWithRecentRollupsRow
- type GetBlockRangeFirstParams
- type GetBlockRangeLastParams
- type GetBlocksByPageParams
- type GetChallengeStatisticsForBlockRangeParams
- type GetChallengeStatisticsForBlockRangeRow
- type GetHealthyValidatorCountsForRollupsRow
- type GetManageEntitiesByBlockHeightCursorParams
- type GetPlaysByBlockHeightCursorParams
- type GetSlaNodeReportsByAddressParams
- type GetSlaNodeReportsByBlockHeightCursorParams
- type GetSlaRollupsByBlockHeightCursorParams
- type GetSlaRollupsWithPaginationParams
- type GetStorageProofVerificationsByBlockHeightCursorParams
- type GetStorageProofsByBlockHeightCursorParams
- type GetTransactionCountByAddressParams
- type GetTransactionsByAddressParams
- type GetTransactionsByAddressRow
- type GetTransactionsByBlockHeightCursorParams
- type GetTransactionsByPageParams
- type GetValidatorDeregistrationsByBlockHeightCursorParams
- type GetValidatorDeregistrationsParams
- type GetValidatorDeregistrationsRow
- type GetValidatorMisbehaviorDeregistrationsByBlockHeightCursorParams
- type GetValidatorRegistrationsByBlockHeightCursorParams
- type GetValidatorRegistrationsParams
- type GetValidatorRegistrationsRow
- type GetValidatorsForSlaRollupRow
- type Grant
- type InsertAddressParams
- type InsertBlockParams
- type InsertFailedStorageProofParams
- type InsertManageEntityParams
- type InsertPlayParams
- type InsertPlaysParams
- type InsertSlaNodeReportParams
- type InsertSlaRollupParams
- type InsertSlaRollupReturningIdParams
- type InsertStorageProofParams
- type InsertStorageProofVerificationParams
- type InsertTransactionParams
- type InsertValidatorDeregistrationParams
- type InsertValidatorMisbehaviorDeregistrationParams
- type InsertValidatorRegistrationParams
- type MaterializedViewManager
- func (m *MaterializedViewManager) ForceRefreshIfStale(ctx context.Context, maxAge time.Duration) error
- func (m *MaterializedViewManager) GetViewRefreshStatus(ctx context.Context) (map[string]time.Time, error)
- func (m *MaterializedViewManager) HealthCheck(ctx context.Context) error
- func (m *MaterializedViewManager) RefreshSlaRollupViews(ctx context.Context) error
- func (m *MaterializedViewManager) StartPeriodicRefresh(ctx context.Context, interval time.Duration)
- type MutedUser
- type MvDashboardTransactionStat
- type MvDashboardTransactionType
- type Notification
- type NotificationSeen
- type Playlist
- type PlaylistRoute
- type PlaylistSeen
- type Queries
- func (q *Queries) DeregisterValidator(ctx context.Context, arg DeregisterValidatorParams) error
- func (q *Queries) GetActiveValidatorCount(ctx context.Context) (int64, error)
- func (q *Queries) GetActiveValidators(ctx context.Context, arg GetActiveValidatorsParams) ([]EtlValidator, error)
- func (q *Queries) GetAllActiveValidatorsWithRecentRollups(ctx context.Context) ([]GetAllActiveValidatorsWithRecentRollupsRow, error)
- func (q *Queries) GetBlockByHeight(ctx context.Context, blockHeight int64) (EtlBlock, error)
- func (q *Queries) GetBlockRangeFirst(ctx context.Context, arg GetBlockRangeFirstParams) (EtlBlock, error)
- func (q *Queries) GetBlockRangeLast(ctx context.Context, arg GetBlockRangeLastParams) (EtlBlock, error)
- func (q *Queries) GetBlockTransactionCount(ctx context.Context, blockHeight int64) (int64, error)
- func (q *Queries) GetBlocksByPage(ctx context.Context, arg GetBlocksByPageParams) ([]EtlBlock, error)
- func (q *Queries) GetChallengeStatisticsForBlockRange(ctx context.Context, arg GetChallengeStatisticsForBlockRangeParams) ([]GetChallengeStatisticsForBlockRangeRow, error)
- func (q *Queries) GetDashboardTransactionStats(ctx context.Context) (MvDashboardTransactionStat, error)
- func (q *Queries) GetDashboardTransactionTypes(ctx context.Context) ([]MvDashboardTransactionType, error)
- func (q *Queries) GetHealthyValidatorCountsForRollups(ctx context.Context, dollar_1 []int32) ([]GetHealthyValidatorCountsForRollupsRow, error)
- func (q *Queries) GetLatestIndexedBlock(ctx context.Context) (int64, error)
- func (q *Queries) GetLatestSlaRollup(ctx context.Context) (EtlSlaRollup, error)
- func (q *Queries) GetManageEntitiesByBlockHeightCursor(ctx context.Context, arg GetManageEntitiesByBlockHeightCursorParams) ([]EtlManageEntity, error)
- func (q *Queries) GetManageEntityByTxHash(ctx context.Context, txHash string) (EtlManageEntity, error)
- func (q *Queries) GetPlaysByBlockHeightCursor(ctx context.Context, arg GetPlaysByBlockHeightCursorParams) ([]EtlPlay, error)
- func (q *Queries) GetPlaysByTxHash(ctx context.Context, txHash string) ([]EtlPlay, error)
- func (q *Queries) GetRelationTypesByAddress(ctx context.Context, lower string) ([]interface{}, error)
- func (q *Queries) GetSlaNodeReportsByAddress(ctx context.Context, arg GetSlaNodeReportsByAddressParams) ([]EtlSlaNodeReport, error)
- func (q *Queries) GetSlaNodeReportsByBlockHeightCursor(ctx context.Context, arg GetSlaNodeReportsByBlockHeightCursorParams) ([]EtlSlaNodeReport, error)
- func (q *Queries) GetSlaRollupById(ctx context.Context, id int32) (EtlSlaRollup, error)
- func (q *Queries) GetSlaRollupByTxHash(ctx context.Context, txHash string) (EtlSlaRollup, error)
- func (q *Queries) GetSlaRollupsByBlockHeightCursor(ctx context.Context, arg GetSlaRollupsByBlockHeightCursorParams) ([]EtlSlaRollup, error)
- func (q *Queries) GetSlaRollupsWithPagination(ctx context.Context, arg GetSlaRollupsWithPaginationParams) ([]EtlSlaRollup, error)
- func (q *Queries) GetStorageProofByTxHash(ctx context.Context, txHash string) (EtlStorageProof, error)
- func (q *Queries) GetStorageProofVerificationByTxHash(ctx context.Context, txHash string) (EtlStorageProofVerification, error)
- func (q *Queries) GetStorageProofVerificationsByBlockHeightCursor(ctx context.Context, arg GetStorageProofVerificationsByBlockHeightCursorParams) ([]EtlStorageProofVerification, error)
- func (q *Queries) GetStorageProofsByBlockHeightCursor(ctx context.Context, arg GetStorageProofsByBlockHeightCursorParams) ([]EtlStorageProof, error)
- func (q *Queries) GetStorageProofsForHeight(ctx context.Context, height int64) ([]EtlStorageProof, error)
- func (q *Queries) GetTotalTransactions(ctx context.Context) (int32, error)
- func (q *Queries) GetTransactionByHash(ctx context.Context, txHash string) (EtlTransaction, error)
- func (q *Queries) GetTransactionCountByAddress(ctx context.Context, arg GetTransactionCountByAddressParams) (int64, error)
- func (q *Queries) GetTransactionsByAddress(ctx context.Context, arg GetTransactionsByAddressParams) ([]GetTransactionsByAddressRow, error)
- func (q *Queries) GetTransactionsByBlockHeightCursor(ctx context.Context, arg GetTransactionsByBlockHeightCursorParams) ([]EtlTransaction, error)
- func (q *Queries) GetTransactionsByPage(ctx context.Context, arg GetTransactionsByPageParams) ([]EtlTransaction, error)
- func (q *Queries) GetValidatorByAddress(ctx context.Context, lower string) (EtlValidator, error)
- func (q *Queries) GetValidatorDeregistrationByTxHash(ctx context.Context, txHash string) (EtlValidatorDeregistration, error)
- func (q *Queries) GetValidatorDeregistrations(ctx context.Context, arg GetValidatorDeregistrationsParams) ([]GetValidatorDeregistrationsRow, error)
- func (q *Queries) GetValidatorDeregistrationsByBlockHeightCursor(ctx context.Context, arg GetValidatorDeregistrationsByBlockHeightCursorParams) ([]EtlValidatorDeregistration, error)
- func (q *Queries) GetValidatorMisbehaviorDeregistrationsByBlockHeightCursor(ctx context.Context, ...) ([]EtlValidatorMisbehaviorDeregistration, error)
- func (q *Queries) GetValidatorRegistrationByTxHash(ctx context.Context, txHash string) (EtlValidatorRegistration, error)
- func (q *Queries) GetValidatorRegistrations(ctx context.Context, arg GetValidatorRegistrationsParams) ([]GetValidatorRegistrationsRow, error)
- func (q *Queries) GetValidatorRegistrationsByBlockHeightCursor(ctx context.Context, arg GetValidatorRegistrationsByBlockHeightCursorParams) ([]EtlValidatorRegistration, error)
- func (q *Queries) GetValidatorsForSlaRollup(ctx context.Context, slaRollupID int32) ([]GetValidatorsForSlaRollupRow, error)
- func (q *Queries) InsertAddress(ctx context.Context, arg InsertAddressParams) error
- func (q *Queries) InsertBlock(ctx context.Context, arg InsertBlockParams) error
- func (q *Queries) InsertFailedStorageProof(ctx context.Context, arg InsertFailedStorageProofParams) error
- func (q *Queries) InsertManageEntity(ctx context.Context, arg InsertManageEntityParams) error
- func (q *Queries) InsertPlay(ctx context.Context, arg InsertPlayParams) error
- func (q *Queries) InsertPlays(ctx context.Context, arg InsertPlaysParams) error
- func (q *Queries) InsertSlaNodeReport(ctx context.Context, arg InsertSlaNodeReportParams) error
- func (q *Queries) InsertSlaRollup(ctx context.Context, arg InsertSlaRollupParams) error
- func (q *Queries) InsertSlaRollupReturningId(ctx context.Context, arg InsertSlaRollupReturningIdParams) (int32, error)
- func (q *Queries) InsertStorageProof(ctx context.Context, arg InsertStorageProofParams) error
- func (q *Queries) InsertStorageProofVerification(ctx context.Context, arg InsertStorageProofVerificationParams) error
- func (q *Queries) InsertTransaction(ctx context.Context, arg InsertTransactionParams) error
- func (q *Queries) InsertValidatorDeregistration(ctx context.Context, arg InsertValidatorDeregistrationParams) error
- func (q *Queries) InsertValidatorMisbehaviorDeregistration(ctx context.Context, arg InsertValidatorMisbehaviorDeregistrationParams) error
- func (q *Queries) InsertValidatorRegistration(ctx context.Context, arg InsertValidatorRegistrationParams) error
- func (q *Queries) RegisterValidator(ctx context.Context, arg RegisterValidatorParams) error
- func (q *Queries) UpdateStorageProofStatus(ctx context.Context, arg UpdateStorageProofStatusParams) error
- func (q *Queries) UpsertValidatorFromPeer(ctx context.Context, arg UpsertValidatorFromPeerParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type Reaction
- type RegisterValidatorParams
- type Repost
- type Safe
- type Share
- type Subscription
- type Track
- type TrackDownload
- type TrackRoute
- type UpdateStorageProofStatusParams
- type UpsertValidatorFromPeerParams
- type User
- type UserTip
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AssociatedWallet ¶
type AssociatedWallet struct {
ID int32 `json:"id"`
UserID int32 `json:"user_id"`
Wallet string `json:"wallet"`
Chain string `json:"chain"`
IsCurrent bool `json:"is_current"`
IsDelete bool `json:"is_delete"`
Blockhash string `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
}
type Comment ¶
type Comment struct {
CommentID int32 `json:"comment_id"`
Text string `json:"text"`
UserID int32 `json:"user_id"`
EntityID int32 `json:"entity_id"`
EntityType string `json:"entity_type"`
TrackTimestampS pgtype.Int4 `json:"track_timestamp_s"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
IsDelete pgtype.Bool `json:"is_delete"`
IsVisible pgtype.Bool `json:"is_visible"`
IsEdited pgtype.Bool `json:"is_edited"`
Txhash string `json:"txhash"`
Blockhash string `json:"blockhash"`
Blocknumber int32 `json:"blocknumber"`
}
type CommentMention ¶
type CommentMention struct {
CommentID int32 `json:"comment_id"`
UserID int32 `json:"user_id"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
IsDelete bool `json:"is_delete"`
Txhash string `json:"txhash"`
Blockhash string `json:"blockhash"`
Blocknumber int32 `json:"blocknumber"`
}
type CommentReaction ¶
type CommentReaction struct {
CommentID int32 `json:"comment_id"`
UserID int32 `json:"user_id"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
IsDelete bool `json:"is_delete"`
Txhash string `json:"txhash"`
Blockhash string `json:"blockhash"`
Blocknumber int32 `json:"blocknumber"`
}
type CommentReport ¶
type CommentReport struct {
CommentID int32 `json:"comment_id"`
UserID int32 `json:"user_id"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
IsDelete bool `json:"is_delete"`
Txhash string `json:"txhash"`
Blockhash string `json:"blockhash"`
Blocknumber int32 `json:"blocknumber"`
}
type CommentThread ¶
type CoreIndexedBlock ¶
type DashboardWalletUser ¶
type DashboardWalletUser struct {
Wallet string `json:"wallet"`
UserID int32 `json:"user_id"`
IsDelete bool `json:"is_delete"`
Txhash string `json:"txhash"`
Blockhash string `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
}
type DeveloperApp ¶
type DeveloperApp struct {
Address string `json:"address"`
Blockhash pgtype.Text `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
UserID pgtype.Int4 `json:"user_id"`
Name string `json:"name"`
IsPersonalAccess bool `json:"is_personal_access"`
IsDelete bool `json:"is_delete"`
CreatedAt pgtype.Timestamp `json:"created_at"`
Txhash string `json:"txhash"`
IsCurrent bool `json:"is_current"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
Description pgtype.Text `json:"description"`
ImageUrl pgtype.Text `json:"image_url"`
}
type EmailAccess ¶
type EmailAccess struct {
EmailOwnerUserID int32 `json:"email_owner_user_id"`
ReceivingUserID int32 `json:"receiving_user_id"`
GrantorUserID int32 `json:"grantor_user_id"`
EncryptedKey string `json:"encrypted_key"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
}
type EncryptedEmail ¶
type EtlAddress ¶
type EtlManageEntity ¶
type EtlManageEntity struct {
ID int32 `json:"id"`
Address string `json:"address"`
EntityType string `json:"entity_type"`
EntityID int64 `json:"entity_id"`
Action string `json:"action"`
Metadata pgtype.Text `json:"metadata"`
Signature string `json:"signature"`
Signer string `json:"signer"`
Nonce string `json:"nonce"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type EtlPlay ¶
type EtlPlay struct {
ID int32 `json:"id"`
UserID string `json:"user_id"`
TrackID string `json:"track_id"`
City string `json:"city"`
Region string `json:"region"`
Country string `json:"country"`
PlayedAt pgtype.Timestamp `json:"played_at"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
ListenedAt pgtype.Timestamp `json:"listened_at"`
RecordedAt pgtype.Timestamp `json:"recorded_at"`
}
type EtlSlaNodeReport ¶
type EtlSlaNodeReport struct {
ID int32 `json:"id"`
SlaRollupID int32 `json:"sla_rollup_id"`
Address string `json:"address"`
NumBlocksProposed int32 `json:"num_blocks_proposed"`
ChallengesReceived int32 `json:"challenges_received"`
ChallengesFailed int32 `json:"challenges_failed"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type EtlSlaRollup ¶
type EtlSlaRollup struct {
ID int32 `json:"id"`
BlockStart int64 `json:"block_start"`
BlockEnd int64 `json:"block_end"`
BlockHeight int64 `json:"block_height"`
ValidatorCount int32 `json:"validator_count"`
BlockQuota int32 `json:"block_quota"`
Bps float64 `json:"bps"`
Tps float64 `json:"tps"`
TxHash string `json:"tx_hash"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type EtlStorageProof ¶
type EtlStorageProof struct {
ID int32 `json:"id"`
Height int64 `json:"height"`
Address string `json:"address"`
ProverAddresses []string `json:"prover_addresses"`
Cid string `json:"cid"`
ProofSignature []byte `json:"proof_signature"`
Proof []byte `json:"proof"`
Status interface{} `json:"status"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type EtlTransaction ¶
type EtlValidator ¶
type EtlValidator struct {
ID int32 `json:"id"`
Address string `json:"address"`
Endpoint string `json:"endpoint"`
CometAddress string `json:"comet_address"`
NodeType string `json:"node_type"`
Spid string `json:"spid"`
VotingPower int64 `json:"voting_power"`
Status string `json:"status"`
RegisteredAt int64 `json:"registered_at"`
DeregisteredAt pgtype.Int8 `json:"deregistered_at"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
}
type EtlValidatorRegistration ¶
type EtlValidatorRegistration struct {
ID int32 `json:"id"`
Address string `json:"address"`
Endpoint string `json:"endpoint"`
CometAddress string `json:"comet_address"`
EthBlock string `json:"eth_block"`
NodeType string `json:"node_type"`
Spid string `json:"spid"`
CometPubkey []byte `json:"comet_pubkey"`
VotingPower int64 `json:"voting_power"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
}
type Event ¶
type Event struct {
EventID int32 `json:"event_id"`
EventType string `json:"event_type"`
UserID int32 `json:"user_id"`
EntityType pgtype.Text `json:"entity_type"`
EntityID pgtype.Int4 `json:"entity_id"`
EndDate pgtype.Timestamp `json:"end_date"`
EventData []byte `json:"event_data"`
IsDeleted bool `json:"is_deleted"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
Txhash string `json:"txhash"`
Blockhash string `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
}
type Follow ¶
type Follow struct {
Blockhash pgtype.Text `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
FollowerUserID int32 `json:"follower_user_id"`
FolloweeUserID int32 `json:"followee_user_id"`
IsCurrent bool `json:"is_current"`
IsDelete bool `json:"is_delete"`
CreatedAt pgtype.Timestamp `json:"created_at"`
Txhash string `json:"txhash"`
Slot pgtype.Int4 `json:"slot"`
}
type GetAllActiveValidatorsWithRecentRollupsRow ¶
type GetAllActiveValidatorsWithRecentRollupsRow struct {
ID int32 `json:"id"`
Address string `json:"address"`
Endpoint string `json:"endpoint"`
CometAddress string `json:"comet_address"`
NodeType string `json:"node_type"`
Spid string `json:"spid"`
VotingPower int64 `json:"voting_power"`
Status string `json:"status"`
RegisteredAt int64 `json:"registered_at"`
DeregisteredAt pgtype.Int8 `json:"deregistered_at"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
SlaRollupID pgtype.Int4 `json:"sla_rollup_id"`
NumBlocksProposed pgtype.Int4 `json:"num_blocks_proposed"`
ChallengesReceived pgtype.Int4 `json:"challenges_received"`
ChallengesFailed pgtype.Int4 `json:"challenges_failed"`
ReportBlockHeight pgtype.Int8 `json:"report_block_height"`
ReportCreatedAt pgtype.Timestamp `json:"report_created_at"`
}
type GetBlockRangeLastParams ¶
type GetBlocksByPageParams ¶
type GetHealthyValidatorCountsForRollupsRow ¶
type GetHealthyValidatorCountsForRollupsRow struct {
RollupID int32 `json:"rollup_id"`
HealthyValidators interface{} `json:"healthy_validators"`
}
type GetTransactionsByAddressRow ¶
type GetTransactionsByAddressRow struct {
ID int32 `json:"id"`
TxHash string `json:"tx_hash"`
BlockHeight int64 `json:"block_height"`
TxIndex int32 `json:"tx_index"`
TxType string `json:"tx_type"`
Address pgtype.Text `json:"address"`
CreatedAt pgtype.Timestamp `json:"created_at"`
Relation interface{} `json:"relation"`
}
type GetValidatorDeregistrationsRow ¶
type GetValidatorDeregistrationsRow struct {
ID int32 `json:"id"`
CometAddress string `json:"comet_address"`
CometPubkey []byte `json:"comet_pubkey"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
Endpoint pgtype.Text `json:"endpoint"`
NodeType pgtype.Text `json:"node_type"`
Spid pgtype.Text `json:"spid"`
VotingPower pgtype.Int8 `json:"voting_power"`
Status pgtype.Text `json:"status"`
}
type GetValidatorRegistrationsRow ¶
type GetValidatorRegistrationsRow struct {
ID int32 `json:"id"`
Address string `json:"address"`
Endpoint string `json:"endpoint"`
CometAddress string `json:"comet_address"`
EthBlock string `json:"eth_block"`
NodeType string `json:"node_type"`
Spid string `json:"spid"`
CometPubkey []byte `json:"comet_pubkey"`
VotingPower int64 `json:"voting_power"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
Endpoint_2 pgtype.Text `json:"endpoint_2"`
NodeType_2 pgtype.Text `json:"node_type_2"`
Spid_2 pgtype.Text `json:"spid_2"`
VotingPower_2 pgtype.Int8 `json:"voting_power_2"`
Status pgtype.Text `json:"status"`
}
type GetValidatorsForSlaRollupRow ¶
type GetValidatorsForSlaRollupRow struct {
ID int32 `json:"id"`
Address string `json:"address"`
Endpoint string `json:"endpoint"`
CometAddress string `json:"comet_address"`
NodeType string `json:"node_type"`
Spid string `json:"spid"`
VotingPower int64 `json:"voting_power"`
Status string `json:"status"`
RegisteredAt int64 `json:"registered_at"`
DeregisteredAt pgtype.Int8 `json:"deregistered_at"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
NumBlocksProposed pgtype.Int4 `json:"num_blocks_proposed"`
ChallengesReceived pgtype.Int4 `json:"challenges_received"`
ChallengesFailed pgtype.Int4 `json:"challenges_failed"`
}
type Grant ¶
type Grant struct {
Blockhash pgtype.Text `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
GranteeAddress string `json:"grantee_address"`
UserID int32 `json:"user_id"`
IsRevoked bool `json:"is_revoked"`
IsCurrent bool `json:"is_current"`
IsApproved pgtype.Bool `json:"is_approved"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
CreatedAt pgtype.Timestamp `json:"created_at"`
Txhash string `json:"txhash"`
}
type InsertAddressParams ¶
type InsertBlockParams ¶
type InsertManageEntityParams ¶
type InsertManageEntityParams struct {
Address string `json:"address"`
EntityType string `json:"entity_type"`
EntityID int64 `json:"entity_id"`
Action string `json:"action"`
Metadata pgtype.Text `json:"metadata"`
Signature string `json:"signature"`
Signer string `json:"signer"`
Nonce string `json:"nonce"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type InsertPlayParams ¶
type InsertPlayParams struct {
UserID string `json:"user_id"`
TrackID string `json:"track_id"`
City string `json:"city"`
Region string `json:"region"`
Country string `json:"country"`
PlayedAt pgtype.Timestamp `json:"played_at"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
ListenedAt pgtype.Timestamp `json:"listened_at"`
RecordedAt pgtype.Timestamp `json:"recorded_at"`
}
type InsertPlaysParams ¶
type InsertPlaysParams struct {
Column1 []string `json:"column_1"`
Column2 []string `json:"column_2"`
Column3 []string `json:"column_3"`
Column4 []string `json:"column_4"`
Column5 []string `json:"column_5"`
Column6 []pgtype.Timestamp `json:"column_6"`
Column7 []int64 `json:"column_7"`
Column8 []string `json:"column_8"`
Column9 []pgtype.Timestamp `json:"column_9"`
Column10 []pgtype.Timestamp `json:"column_10"`
}
type InsertSlaNodeReportParams ¶
type InsertSlaNodeReportParams struct {
SlaRollupID int32 `json:"sla_rollup_id"`
Address string `json:"address"`
NumBlocksProposed int32 `json:"num_blocks_proposed"`
ChallengesReceived int32 `json:"challenges_received"`
ChallengesFailed int32 `json:"challenges_failed"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type InsertSlaRollupParams ¶
type InsertSlaRollupParams struct {
BlockStart int64 `json:"block_start"`
BlockEnd int64 `json:"block_end"`
BlockHeight int64 `json:"block_height"`
ValidatorCount int32 `json:"validator_count"`
BlockQuota int32 `json:"block_quota"`
Bps float64 `json:"bps"`
Tps float64 `json:"tps"`
TxHash string `json:"tx_hash"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type InsertSlaRollupReturningIdParams ¶
type InsertSlaRollupReturningIdParams struct {
BlockStart int64 `json:"block_start"`
BlockEnd int64 `json:"block_end"`
BlockHeight int64 `json:"block_height"`
ValidatorCount int32 `json:"validator_count"`
BlockQuota int32 `json:"block_quota"`
Bps float64 `json:"bps"`
Tps float64 `json:"tps"`
TxHash string `json:"tx_hash"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type InsertStorageProofParams ¶
type InsertStorageProofParams struct {
Height int64 `json:"height"`
Address string `json:"address"`
ProverAddresses []string `json:"prover_addresses"`
Cid string `json:"cid"`
ProofSignature []byte `json:"proof_signature"`
Proof []byte `json:"proof"`
Status interface{} `json:"status"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type InsertTransactionParams ¶
type InsertValidatorRegistrationParams ¶
type InsertValidatorRegistrationParams struct {
Address string `json:"address"`
Endpoint string `json:"endpoint"`
CometAddress string `json:"comet_address"`
EthBlock string `json:"eth_block"`
NodeType string `json:"node_type"`
Spid string `json:"spid"`
CometPubkey []byte `json:"comet_pubkey"`
VotingPower int64 `json:"voting_power"`
BlockHeight int64 `json:"block_height"`
TxHash string `json:"tx_hash"`
}
type MaterializedViewManager ¶
type MaterializedViewManager struct {
// contains filtered or unexported fields
}
MaterializedViewManager handles refreshing materialized views for optimal performance
func NewMaterializedViewManager ¶
func NewMaterializedViewManager(db *pgxpool.Pool, logger *slog.Logger) *MaterializedViewManager
NewMaterializedViewManager creates a new manager for materialized views
func (*MaterializedViewManager) ForceRefreshIfStale ¶
func (m *MaterializedViewManager) ForceRefreshIfStale(ctx context.Context, maxAge time.Duration) error
ForceRefreshIfStale refreshes views if they haven't been refreshed recently
func (*MaterializedViewManager) GetViewRefreshStatus ¶
func (m *MaterializedViewManager) GetViewRefreshStatus(ctx context.Context) (map[string]time.Time, error)
GetViewRefreshStatus returns information about when views were last refreshed
func (*MaterializedViewManager) HealthCheck ¶
func (m *MaterializedViewManager) HealthCheck(ctx context.Context) error
Health check for materialized views - useful for monitoring
func (*MaterializedViewManager) RefreshSlaRollupViews ¶
func (m *MaterializedViewManager) RefreshSlaRollupViews(ctx context.Context) error
RefreshSlaRollupViews refreshes all SLA rollup related materialized views
func (*MaterializedViewManager) StartPeriodicRefresh ¶
func (m *MaterializedViewManager) StartPeriodicRefresh(ctx context.Context, interval time.Duration)
StartPeriodicRefresh starts a background goroutine that refreshes materialized views periodically
type MutedUser ¶
type MutedUser struct {
MutedUserID int32 `json:"muted_user_id"`
UserID int32 `json:"user_id"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
IsDelete pgtype.Bool `json:"is_delete"`
Txhash string `json:"txhash"`
Blockhash string `json:"blockhash"`
Blocknumber int32 `json:"blocknumber"`
}
type MvDashboardTransactionStat ¶
type MvDashboardTransactionStat struct {
Transactions24h int64 `json:"transactions_24h"`
TransactionsPrevious24h int64 `json:"transactions_previous_24h"`
Transactions7d int64 `json:"transactions_7d"`
Transactions30d int64 `json:"transactions_30d"`
TotalTransactions int64 `json:"total_transactions"`
}
type Notification ¶
type Notification struct {
ID int32 `json:"id"`
Specifier string `json:"specifier"`
GroupID string `json:"group_id"`
Type string `json:"type"`
Slot pgtype.Int4 `json:"slot"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
Timestamp pgtype.Timestamp `json:"timestamp"`
Data []byte `json:"data"`
UserIds []int32 `json:"user_ids"`
TypeV2 pgtype.Text `json:"type_v2"`
}
type NotificationSeen ¶
type Playlist ¶
type Playlist struct {
Blockhash pgtype.Text `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
PlaylistID int32 `json:"playlist_id"`
PlaylistOwnerID int32 `json:"playlist_owner_id"`
IsAlbum bool `json:"is_album"`
IsPrivate bool `json:"is_private"`
PlaylistName pgtype.Text `json:"playlist_name"`
PlaylistContents []byte `json:"playlist_contents"`
PlaylistImageMultihash pgtype.Text `json:"playlist_image_multihash"`
IsCurrent bool `json:"is_current"`
IsDelete bool `json:"is_delete"`
Description pgtype.Text `json:"description"`
CreatedAt pgtype.Timestamp `json:"created_at"`
Upc pgtype.Text `json:"upc"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
PlaylistImageSizesMultihash pgtype.Text `json:"playlist_image_sizes_multihash"`
Txhash string `json:"txhash"`
LastAddedTo pgtype.Timestamp `json:"last_added_to"`
Slot pgtype.Int4 `json:"slot"`
MetadataMultihash pgtype.Text `json:"metadata_multihash"`
IsImageAutogenerated bool `json:"is_image_autogenerated"`
IsStreamGated bool `json:"is_stream_gated"`
StreamConditions []byte `json:"stream_conditions"`
DdexApp pgtype.Text `json:"ddex_app"`
DdexReleaseIds []byte `json:"ddex_release_ids"`
Artists []byte `json:"artists"`
CopyrightLine []byte `json:"copyright_line"`
ProducerCopyrightLine []byte `json:"producer_copyright_line"`
ParentalWarningType pgtype.Text `json:"parental_warning_type"`
IsScheduledRelease bool `json:"is_scheduled_release"`
ReleaseDate pgtype.Timestamp `json:"release_date"`
}
type PlaylistRoute ¶
type PlaylistRoute struct {
Slug string `json:"slug"`
TitleSlug string `json:"title_slug"`
CollisionID int32 `json:"collision_id"`
OwnerID int32 `json:"owner_id"`
PlaylistID int32 `json:"playlist_id"`
IsCurrent bool `json:"is_current"`
Blockhash string `json:"blockhash"`
Blocknumber int32 `json:"blocknumber"`
Txhash string `json:"txhash"`
}
type PlaylistSeen ¶
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) DeregisterValidator ¶
func (q *Queries) DeregisterValidator(ctx context.Context, arg DeregisterValidatorParams) error
func (*Queries) GetActiveValidatorCount ¶
func (*Queries) GetActiveValidators ¶
func (q *Queries) GetActiveValidators(ctx context.Context, arg GetActiveValidatorsParams) ([]EtlValidator, error)
func (*Queries) GetAllActiveValidatorsWithRecentRollups ¶
func (q *Queries) GetAllActiveValidatorsWithRecentRollups(ctx context.Context) ([]GetAllActiveValidatorsWithRecentRollupsRow, error)
func (*Queries) GetBlockByHeight ¶
func (*Queries) GetBlockRangeFirst ¶
func (*Queries) GetBlockRangeLast ¶
func (*Queries) GetBlockTransactionCount ¶
func (*Queries) GetBlocksByPage ¶
func (*Queries) GetChallengeStatisticsForBlockRange ¶
func (q *Queries) GetChallengeStatisticsForBlockRange(ctx context.Context, arg GetChallengeStatisticsForBlockRangeParams) ([]GetChallengeStatisticsForBlockRangeRow, error)
func (*Queries) GetDashboardTransactionStats ¶
func (q *Queries) GetDashboardTransactionStats(ctx context.Context) (MvDashboardTransactionStat, error)
Dashboard materialized view queries
func (*Queries) GetDashboardTransactionTypes ¶
func (q *Queries) GetDashboardTransactionTypes(ctx context.Context) ([]MvDashboardTransactionType, error)
func (*Queries) GetHealthyValidatorCountsForRollups ¶
func (*Queries) GetLatestIndexedBlock ¶
get latest indexed block height
func (*Queries) GetLatestSlaRollup ¶
func (q *Queries) GetLatestSlaRollup(ctx context.Context) (EtlSlaRollup, error)
func (*Queries) GetManageEntitiesByBlockHeightCursor ¶
func (q *Queries) GetManageEntitiesByBlockHeightCursor(ctx context.Context, arg GetManageEntitiesByBlockHeightCursorParams) ([]EtlManageEntity, error)
func (*Queries) GetManageEntityByTxHash ¶
func (*Queries) GetPlaysByBlockHeightCursor ¶
func (*Queries) GetPlaysByTxHash ¶
Transaction content queries by hash
func (*Queries) GetRelationTypesByAddress ¶
func (*Queries) GetSlaNodeReportsByAddress ¶
func (q *Queries) GetSlaNodeReportsByAddress(ctx context.Context, arg GetSlaNodeReportsByAddressParams) ([]EtlSlaNodeReport, error)
func (*Queries) GetSlaNodeReportsByBlockHeightCursor ¶
func (q *Queries) GetSlaNodeReportsByBlockHeightCursor(ctx context.Context, arg GetSlaNodeReportsByBlockHeightCursorParams) ([]EtlSlaNodeReport, error)
func (*Queries) GetSlaRollupById ¶
func (*Queries) GetSlaRollupByTxHash ¶
func (*Queries) GetSlaRollupsByBlockHeightCursor ¶
func (q *Queries) GetSlaRollupsByBlockHeightCursor(ctx context.Context, arg GetSlaRollupsByBlockHeightCursorParams) ([]EtlSlaRollup, error)
func (*Queries) GetSlaRollupsWithPagination ¶
func (q *Queries) GetSlaRollupsWithPagination(ctx context.Context, arg GetSlaRollupsWithPaginationParams) ([]EtlSlaRollup, error)
func (*Queries) GetStorageProofByTxHash ¶
func (*Queries) GetStorageProofVerificationByTxHash ¶
func (*Queries) GetStorageProofVerificationsByBlockHeightCursor ¶
func (q *Queries) GetStorageProofVerificationsByBlockHeightCursor(ctx context.Context, arg GetStorageProofVerificationsByBlockHeightCursorParams) ([]EtlStorageProofVerification, error)
func (*Queries) GetStorageProofsByBlockHeightCursor ¶
func (q *Queries) GetStorageProofsByBlockHeightCursor(ctx context.Context, arg GetStorageProofsByBlockHeightCursorParams) ([]EtlStorageProof, error)
func (*Queries) GetStorageProofsForHeight ¶
func (q *Queries) GetStorageProofsForHeight(ctx context.Context, height int64) ([]EtlStorageProof, error)
Storage proof consensus queries
func (*Queries) GetTotalTransactions ¶
func (*Queries) GetTransactionByHash ¶
func (*Queries) GetTransactionCountByAddress ¶
func (*Queries) GetTransactionsByAddress ¶
func (q *Queries) GetTransactionsByAddress(ctx context.Context, arg GetTransactionsByAddressParams) ([]GetTransactionsByAddressRow, error)
Account transaction queries
func (*Queries) GetTransactionsByBlockHeightCursor ¶
func (q *Queries) GetTransactionsByBlockHeightCursor(ctx context.Context, arg GetTransactionsByBlockHeightCursorParams) ([]EtlTransaction, error)
func (*Queries) GetTransactionsByPage ¶
func (q *Queries) GetTransactionsByPage(ctx context.Context, arg GetTransactionsByPageParams) ([]EtlTransaction, error)
func (*Queries) GetValidatorByAddress ¶
func (*Queries) GetValidatorDeregistrationByTxHash ¶
func (*Queries) GetValidatorDeregistrations ¶
func (q *Queries) GetValidatorDeregistrations(ctx context.Context, arg GetValidatorDeregistrationsParams) ([]GetValidatorDeregistrationsRow, error)
func (*Queries) GetValidatorDeregistrationsByBlockHeightCursor ¶
func (q *Queries) GetValidatorDeregistrationsByBlockHeightCursor(ctx context.Context, arg GetValidatorDeregistrationsByBlockHeightCursorParams) ([]EtlValidatorDeregistration, error)
func (*Queries) GetValidatorMisbehaviorDeregistrationsByBlockHeightCursor ¶
func (q *Queries) GetValidatorMisbehaviorDeregistrationsByBlockHeightCursor(ctx context.Context, arg GetValidatorMisbehaviorDeregistrationsByBlockHeightCursorParams) ([]EtlValidatorMisbehaviorDeregistration, error)
func (*Queries) GetValidatorRegistrationByTxHash ¶
func (*Queries) GetValidatorRegistrations ¶
func (q *Queries) GetValidatorRegistrations(ctx context.Context, arg GetValidatorRegistrationsParams) ([]GetValidatorRegistrationsRow, error)
func (*Queries) GetValidatorRegistrationsByBlockHeightCursor ¶
func (q *Queries) GetValidatorRegistrationsByBlockHeightCursor(ctx context.Context, arg GetValidatorRegistrationsByBlockHeightCursorParams) ([]EtlValidatorRegistration, error)
func (*Queries) GetValidatorsForSlaRollup ¶
func (*Queries) InsertAddress ¶
func (q *Queries) InsertAddress(ctx context.Context, arg InsertAddressParams) error
func (*Queries) InsertBlock ¶
func (q *Queries) InsertBlock(ctx context.Context, arg InsertBlockParams) error
func (*Queries) InsertFailedStorageProof ¶
func (q *Queries) InsertFailedStorageProof(ctx context.Context, arg InsertFailedStorageProofParams) error
func (*Queries) InsertManageEntity ¶
func (q *Queries) InsertManageEntity(ctx context.Context, arg InsertManageEntityParams) error
func (*Queries) InsertPlay ¶
func (q *Queries) InsertPlay(ctx context.Context, arg InsertPlayParams) error
func (*Queries) InsertPlays ¶
func (q *Queries) InsertPlays(ctx context.Context, arg InsertPlaysParams) error
func (*Queries) InsertSlaNodeReport ¶
func (q *Queries) InsertSlaNodeReport(ctx context.Context, arg InsertSlaNodeReportParams) error
func (*Queries) InsertSlaRollup ¶
func (q *Queries) InsertSlaRollup(ctx context.Context, arg InsertSlaRollupParams) error
func (*Queries) InsertSlaRollupReturningId ¶
func (*Queries) InsertStorageProof ¶
func (q *Queries) InsertStorageProof(ctx context.Context, arg InsertStorageProofParams) error
func (*Queries) InsertStorageProofVerification ¶
func (q *Queries) InsertStorageProofVerification(ctx context.Context, arg InsertStorageProofVerificationParams) error
func (*Queries) InsertTransaction ¶
func (q *Queries) InsertTransaction(ctx context.Context, arg InsertTransactionParams) error
func (*Queries) InsertValidatorDeregistration ¶
func (q *Queries) InsertValidatorDeregistration(ctx context.Context, arg InsertValidatorDeregistrationParams) error
func (*Queries) InsertValidatorMisbehaviorDeregistration ¶
func (q *Queries) InsertValidatorMisbehaviorDeregistration(ctx context.Context, arg InsertValidatorMisbehaviorDeregistrationParams) error
func (*Queries) InsertValidatorRegistration ¶
func (q *Queries) InsertValidatorRegistration(ctx context.Context, arg InsertValidatorRegistrationParams) error
func (*Queries) RegisterValidator ¶
func (q *Queries) RegisterValidator(ctx context.Context, arg RegisterValidatorParams) error
func (*Queries) UpdateStorageProofStatus ¶
func (q *Queries) UpdateStorageProofStatus(ctx context.Context, arg UpdateStorageProofStatusParams) error
func (*Queries) UpsertValidatorFromPeer ¶
func (q *Queries) UpsertValidatorFromPeer(ctx context.Context, arg UpsertValidatorFromPeerParams) error
type RegisterValidatorParams ¶
type RegisterValidatorParams struct {
Address string `json:"address"`
Endpoint string `json:"endpoint"`
CometAddress string `json:"comet_address"`
NodeType string `json:"node_type"`
Spid string `json:"spid"`
VotingPower int64 `json:"voting_power"`
Status string `json:"status"`
RegisteredAt int64 `json:"registered_at"`
DeregisteredAt pgtype.Int8 `json:"deregistered_at"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
}
type Repost ¶
type Repost struct {
Blockhash pgtype.Text `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
UserID int32 `json:"user_id"`
RepostItemID int32 `json:"repost_item_id"`
RepostType interface{} `json:"repost_type"`
IsCurrent bool `json:"is_current"`
IsDelete bool `json:"is_delete"`
CreatedAt pgtype.Timestamp `json:"created_at"`
Txhash string `json:"txhash"`
Slot pgtype.Int4 `json:"slot"`
IsRepostOfRepost bool `json:"is_repost_of_repost"`
}
type Safe ¶
type Safe struct {
Blockhash pgtype.Text `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
UserID int32 `json:"user_id"`
SaveItemID int32 `json:"save_item_id"`
SaveType interface{} `json:"save_type"`
IsCurrent bool `json:"is_current"`
IsDelete bool `json:"is_delete"`
CreatedAt pgtype.Timestamp `json:"created_at"`
Txhash string `json:"txhash"`
Slot pgtype.Int4 `json:"slot"`
IsSaveOfRepost bool `json:"is_save_of_repost"`
}
type Subscription ¶
type Subscription struct {
Blockhash pgtype.Text `json:"blockhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
SubscriberID int32 `json:"subscriber_id"`
UserID int32 `json:"user_id"`
IsCurrent bool `json:"is_current"`
IsDelete bool `json:"is_delete"`
CreatedAt pgtype.Timestamp `json:"created_at"`
Txhash string `json:"txhash"`
}
type Track ¶
type Track struct {
Blockhash pgtype.Text `json:"blockhash"`
TrackID int32 `json:"track_id"`
IsCurrent bool `json:"is_current"`
IsDelete bool `json:"is_delete"`
OwnerID int32 `json:"owner_id"`
Title pgtype.Text `json:"title"`
CoverArt pgtype.Text `json:"cover_art"`
Tags pgtype.Text `json:"tags"`
Genre pgtype.Text `json:"genre"`
Mood pgtype.Text `json:"mood"`
CreditsSplits pgtype.Text `json:"credits_splits"`
CreateDate pgtype.Text `json:"create_date"`
FileType pgtype.Text `json:"file_type"`
MetadataMultihash pgtype.Text `json:"metadata_multihash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
CreatedAt pgtype.Timestamp `json:"created_at"`
Description pgtype.Text `json:"description"`
Isrc pgtype.Text `json:"isrc"`
Iswc pgtype.Text `json:"iswc"`
License pgtype.Text `json:"license"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
CoverArtSizes pgtype.Text `json:"cover_art_sizes"`
IsUnlisted bool `json:"is_unlisted"`
FieldVisibility []byte `json:"field_visibility"`
RouteID pgtype.Text `json:"route_id"`
StemOf []byte `json:"stem_of"`
RemixOf []byte `json:"remix_of"`
Txhash string `json:"txhash"`
Slot pgtype.Int4 `json:"slot"`
IsAvailable bool `json:"is_available"`
IsStreamGated bool `json:"is_stream_gated"`
StreamConditions []byte `json:"stream_conditions"`
TrackCid pgtype.Text `json:"track_cid"`
IsPlaylistUpload bool `json:"is_playlist_upload"`
Duration pgtype.Int4 `json:"duration"`
AiAttributionUserID pgtype.Int4 `json:"ai_attribution_user_id"`
PreviewCid pgtype.Text `json:"preview_cid"`
AudioUploadID pgtype.Text `json:"audio_upload_id"`
PreviewStartSeconds pgtype.Float8 `json:"preview_start_seconds"`
ReleaseDate pgtype.Timestamp `json:"release_date"`
TrackSegments []byte `json:"track_segments"`
IsScheduledRelease bool `json:"is_scheduled_release"`
IsDownloadable bool `json:"is_downloadable"`
IsDownloadGated bool `json:"is_download_gated"`
DownloadConditions []byte `json:"download_conditions"`
IsOriginalAvailable bool `json:"is_original_available"`
OrigFileCid pgtype.Text `json:"orig_file_cid"`
OrigFilename pgtype.Text `json:"orig_filename"`
PlaylistsContainingTrack []int32 `json:"playlists_containing_track"`
PlacementHosts pgtype.Text `json:"placement_hosts"`
DdexApp pgtype.Text `json:"ddex_app"`
DdexReleaseIds []byte `json:"ddex_release_ids"`
Artists []byte `json:"artists"`
ResourceContributors []byte `json:"resource_contributors"`
IndirectResourceContributors []byte `json:"indirect_resource_contributors"`
RightsController []byte `json:"rights_controller"`
CopyrightLine []byte `json:"copyright_line"`
ProducerCopyrightLine []byte `json:"producer_copyright_line"`
ParentalWarningType pgtype.Text `json:"parental_warning_type"`
PlaylistsPreviouslyContainingTrack []byte `json:"playlists_previously_containing_track"`
AllowedApiKeys []string `json:"allowed_api_keys"`
Bpm pgtype.Float8 `json:"bpm"`
MusicalKey pgtype.Text `json:"musical_key"`
AudioAnalysisErrorCount int32 `json:"audio_analysis_error_count"`
IsCustomBpm pgtype.Bool `json:"is_custom_bpm"`
IsCustomMusicalKey pgtype.Bool `json:"is_custom_musical_key"`
CommentsDisabled pgtype.Bool `json:"comments_disabled"`
PinnedCommentID pgtype.Int4 `json:"pinned_comment_id"`
CoverOriginalSongTitle pgtype.Text `json:"cover_original_song_title"`
CoverOriginalArtist pgtype.Text `json:"cover_original_artist"`
IsOwnedByUser bool `json:"is_owned_by_user"`
NoAiUse pgtype.Bool `json:"no_ai_use"`
}
type TrackDownload ¶
type TrackDownload struct {
Txhash string `json:"txhash"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
ParentTrackID int32 `json:"parent_track_id"`
TrackID int32 `json:"track_id"`
UserID int32 `json:"user_id"`
City pgtype.Text `json:"city"`
Region pgtype.Text `json:"region"`
Country pgtype.Text `json:"country"`
CreatedAt pgtype.Timestamp `json:"created_at"`
}
type TrackRoute ¶
type TrackRoute struct {
Slug string `json:"slug"`
TitleSlug string `json:"title_slug"`
CollisionID int32 `json:"collision_id"`
OwnerID int32 `json:"owner_id"`
TrackID int32 `json:"track_id"`
IsCurrent bool `json:"is_current"`
Blockhash string `json:"blockhash"`
Blocknumber int32 `json:"blocknumber"`
Txhash string `json:"txhash"`
}
type User ¶
type User struct {
Blockhash pgtype.Text `json:"blockhash"`
UserID int32 `json:"user_id"`
IsCurrent bool `json:"is_current"`
Handle pgtype.Text `json:"handle"`
Wallet pgtype.Text `json:"wallet"`
Name pgtype.Text `json:"name"`
ProfilePicture pgtype.Text `json:"profile_picture"`
CoverPhoto pgtype.Text `json:"cover_photo"`
Bio pgtype.Text `json:"bio"`
Location pgtype.Text `json:"location"`
MetadataMultihash pgtype.Text `json:"metadata_multihash"`
CreatorNodeEndpoint pgtype.Text `json:"creator_node_endpoint"`
Blocknumber pgtype.Int4 `json:"blocknumber"`
IsVerified bool `json:"is_verified"`
CreatedAt pgtype.Timestamp `json:"created_at"`
UpdatedAt pgtype.Timestamp `json:"updated_at"`
HandleLc pgtype.Text `json:"handle_lc"`
CoverPhotoSizes pgtype.Text `json:"cover_photo_sizes"`
ProfilePictureSizes pgtype.Text `json:"profile_picture_sizes"`
PrimaryID pgtype.Int4 `json:"primary_id"`
SecondaryIds []int32 `json:"secondary_ids"`
ReplicaSetUpdateSigner pgtype.Text `json:"replica_set_update_signer"`
HasCollectibles bool `json:"has_collectibles"`
Txhash string `json:"txhash"`
PlaylistLibrary []byte `json:"playlist_library"`
IsDeactivated bool `json:"is_deactivated"`
Slot pgtype.Int4 `json:"slot"`
UserStorageAccount pgtype.Text `json:"user_storage_account"`
UserAuthorityAccount pgtype.Text `json:"user_authority_account"`
ArtistPickTrackID pgtype.Int4 `json:"artist_pick_track_id"`
IsAvailable bool `json:"is_available"`
IsStorageV2 bool `json:"is_storage_v2"`
AllowAiAttribution bool `json:"allow_ai_attribution"`
TwitterHandle pgtype.Text `json:"twitter_handle"`
InstagramHandle pgtype.Text `json:"instagram_handle"`
TiktokHandle pgtype.Text `json:"tiktok_handle"`
VerifiedWithTwitter pgtype.Bool `json:"verified_with_twitter"`
VerifiedWithInstagram pgtype.Bool `json:"verified_with_instagram"`
VerifiedWithTiktok pgtype.Bool `json:"verified_with_tiktok"`
}