Documentation
      ¶
    
    
  
    
  
    Index ¶
- func RunMigrations(logger *zap.Logger, pgConnectionString string, downFirst bool) error
 - type AccessKey
 - type AppendValidatorHistoryParams
 - type CommitSlaNodeReportParams
 - type CommitSlaRollupParams
 - type CoreAppState
 - type CoreBlock
 - type CoreDeal
 - type CoreErn
 - type CoreEtlTx
 - type CoreEtlTxDuplicate
 - type CoreEtlTxManageEntity
 - type CoreEtlTxPlay
 - type CoreEtlTxSlaRollup
 - type CoreEtlTxStorageProof
 - type CoreEtlTxStorageProofVerification
 - type CoreEtlTxValidatorDeregistration
 - type CoreEtlTxValidatorRegistration
 - type CoreMead
 - type CoreParty
 - type CorePie
 - type CoreRelease
 - type CoreResource
 - type CoreReward
 - type CoreTransaction
 - type CoreTxStat
 - type CoreUpload
 - type CoreValidator
 - type DBTX
 - type GetAppStateAtHeightRow
 - type GetAvailableCitiesParams
 - type GetAvailableCitiesRow
 - type GetAvailableCountriesRow
 - type GetAvailableRegionsParams
 - type GetAvailableRegionsRow
 - type GetBlocksWithTransactionsRow
 - type GetDecodedPlaysByLocationParams
 - type GetDecodedPlaysByLocationRow
 - type GetDecodedPlaysByTimeRangeParams
 - type GetDecodedPlaysByTimeRangeRow
 - type GetDecodedPlaysByTrackParams
 - type GetDecodedPlaysByTrackRow
 - type GetDecodedPlaysByUserParams
 - type GetDecodedPlaysByUserRow
 - type GetDecodedPlaysRow
 - type GetDecodedTxsByTypeParams
 - type GetERNContainingAddressRow
 - type GetERNReceiptsRow
 - type GetLatestAppStateRow
 - type GetMEADReceiptsRow
 - type GetPIEReceiptsRow
 - type GetRecentRollupsForAllNodesParams
 - type GetRecentRollupsForAllNodesRow
 - type GetRecentRollupsForNodeParams
 - type GetRecentRollupsForNodeRow
 - type GetRollupReportForNodeAndIdParams
 - type GetRollupReportsForNodeInTimeRangeParams
 - type GetRollupReportsForNodeInTimeRangeRow
 - type GetRollupReportsForNodesInTimeRangeParams
 - type GetRollupReportsForNodesInTimeRangeRow
 - type GetStorageProofParams
 - type GetStorageProofRollupForNodeParams
 - type GetStorageProofRollupForNodeRow
 - type GetStorageProofRollupsParams
 - type GetStorageProofRollupsRow
 - type GetStorageProofsForNodeInRangeParams
 - type GetValidatorHistoryForIDParams
 - type HasAccessToTrackReleaseParams
 - type InsertAccessKeyParams
 - type InsertCoreDealParams
 - type InsertCoreERNParams
 - type InsertCoreMEADParams
 - type InsertCorePIEParams
 - type InsertCorePartyParams
 - type InsertCoreReleaseParams
 - type InsertCoreResourceParams
 - type InsertCoreRewardParams
 - type InsertDecodedManageEntityParams
 - type InsertDecodedPlayParams
 - type InsertDecodedSlaRollupParams
 - type InsertDecodedStorageProofParams
 - type InsertDecodedStorageProofVerificationParams
 - type InsertDecodedValidatorDeregistrationParams
 - type InsertDecodedValidatorRegistrationParams
 - type InsertEtlDuplicateParams
 - type InsertEtlTxParams
 - type InsertFailedStorageProofParams
 - type InsertFileUploadParams
 - type InsertManagementKeyParams
 - type InsertRegisteredNodeParams
 - type InsertSoundRecordingParams
 - type InsertStorageProofParams
 - type InsertStorageProofPeersParams
 - type InsertTxStatParams
 - type ManagementKey
 - type NullProofStatus
 - type ProofStatus
 - type Queries
 - func (q *Queries) AppendValidatorHistory(ctx context.Context, arg AppendValidatorHistoryParams) error
 - func (q *Queries) CheckDatabaseExists(ctx context.Context, datname string) (bool, error)
 - func (q *Queries) ClearUncommittedSlaNodeReports(ctx context.Context) error
 - func (q *Queries) CommitSlaNodeReport(ctx context.Context, arg CommitSlaNodeReportParams) error
 - func (q *Queries) CommitSlaRollup(ctx context.Context, arg CommitSlaRollupParams) (int32, error)
 - func (q *Queries) DeleteCoreReward(ctx context.Context, address string) error
 - func (q *Queries) DeleteRegisteredNode(ctx context.Context, cometAddress string) error
 - func (q *Queries) GetActiveRewards(ctx context.Context) ([]CoreReward, error)
 - func (q *Queries) GetAllEthAddressesOfRegisteredNodes(ctx context.Context) ([]string, error)
 - func (q *Queries) GetAllRegisteredNodes(ctx context.Context) ([]CoreValidator, error)
 - func (q *Queries) GetAllRegisteredNodesSorted(ctx context.Context) ([]CoreValidator, error)
 - func (q *Queries) GetAllRewards(ctx context.Context) ([]CoreReward, error)
 - func (q *Queries) GetAppStateAtHeight(ctx context.Context, blockHeight int64) (GetAppStateAtHeightRow, error)
 - func (q *Queries) GetAvailableCities(ctx context.Context, arg GetAvailableCitiesParams) ([]GetAvailableCitiesRow, error)
 - func (q *Queries) GetAvailableCountries(ctx context.Context, limit int32) ([]GetAvailableCountriesRow, error)
 - func (q *Queries) GetAvailableRegions(ctx context.Context, arg GetAvailableRegionsParams) ([]GetAvailableRegionsRow, error)
 - func (q *Queries) GetBlock(ctx context.Context, height int64) (CoreBlock, error)
 - func (q *Queries) GetBlockTransactions(ctx context.Context, blockID int64) ([]CoreTransaction, error)
 - func (q *Queries) GetBlocksWithTransactions(ctx context.Context, dollar_1 []int64) ([]GetBlocksWithTransactionsRow, error)
 - func (q *Queries) GetCoreUpload(ctx context.Context, cid string) (CoreUpload, error)
 - func (q *Queries) GetDBSize(ctx context.Context) (int64, error)
 - func (q *Queries) GetDecodedPlays(ctx context.Context, limit int32) ([]GetDecodedPlaysRow, error)
 - func (q *Queries) GetDecodedPlaysByLocation(ctx context.Context, arg GetDecodedPlaysByLocationParams) ([]GetDecodedPlaysByLocationRow, error)
 - func (q *Queries) GetDecodedPlaysByTimeRange(ctx context.Context, arg GetDecodedPlaysByTimeRangeParams) ([]GetDecodedPlaysByTimeRangeRow, error)
 - func (q *Queries) GetDecodedPlaysByTrack(ctx context.Context, arg GetDecodedPlaysByTrackParams) ([]GetDecodedPlaysByTrackRow, error)
 - func (q *Queries) GetDecodedPlaysByUser(ctx context.Context, arg GetDecodedPlaysByUserParams) ([]GetDecodedPlaysByUserRow, error)
 - func (q *Queries) GetDecodedTx(ctx context.Context, txHash string) (CoreEtlTx, error)
 - func (q *Queries) GetDecodedTxsByBlock(ctx context.Context, blockHeight int64) ([]CoreEtlTx, error)
 - func (q *Queries) GetDecodedTxsByType(ctx context.Context, arg GetDecodedTxsByTypeParams) ([]CoreEtlTx, error)
 - func (q *Queries) GetERN(ctx context.Context, address string) (CoreErn, error)
 - func (q *Queries) GetERNContainingAddress(ctx context.Context, dollar_1 string) (GetERNContainingAddressRow, error)
 - func (q *Queries) GetERNDeals(ctx context.Context, ernAddress string) ([]CoreDeal, error)
 - func (q *Queries) GetERNParties(ctx context.Context, ernAddress string) ([]CoreParty, error)
 - func (q *Queries) GetERNReceipts(ctx context.Context, txHash string) ([]GetERNReceiptsRow, error)
 - func (q *Queries) GetERNReleases(ctx context.Context, ernAddress string) ([]CoreRelease, error)
 - func (q *Queries) GetERNResources(ctx context.Context, ernAddress string) ([]CoreResource, error)
 - func (q *Queries) GetInProgressRollupReports(ctx context.Context) ([]SlaNodeReport, error)
 - func (q *Queries) GetLatestAppState(ctx context.Context) (GetLatestAppStateRow, error)
 - func (q *Queries) GetLatestBlock(ctx context.Context) (CoreBlock, error)
 - func (q *Queries) GetLatestDecodedTxs(ctx context.Context, limit int32) ([]CoreEtlTx, error)
 - func (q *Queries) GetLatestSlaRollup(ctx context.Context) (SlaRollup, error)
 - func (q *Queries) GetMEAD(ctx context.Context, address string) (CoreMead, error)
 - func (q *Queries) GetMEADReceipts(ctx context.Context, txHash string) ([]GetMEADReceiptsRow, error)
 - func (q *Queries) GetNodeByEndpoint(ctx context.Context, endpoint string) (CoreValidator, error)
 - func (q *Queries) GetNodesByEndpoints(ctx context.Context, dollar_1 []string) ([]CoreValidator, error)
 - func (q *Queries) GetPIE(ctx context.Context, address string) (CorePie, error)
 - func (q *Queries) GetPIEReceipts(ctx context.Context, txHash string) ([]GetPIEReceiptsRow, error)
 - func (q *Queries) GetPreviousSlaRollupFromId(ctx context.Context, id int32) (SlaRollup, error)
 - func (q *Queries) GetRecentBlocks(ctx context.Context, limit int32) ([]CoreBlock, error)
 - func (q *Queries) GetRecentRollupsForAllNodes(ctx context.Context, arg GetRecentRollupsForAllNodesParams) ([]GetRecentRollupsForAllNodesRow, error)
 - func (q *Queries) GetRecentRollupsForNode(ctx context.Context, arg GetRecentRollupsForNodeParams) ([]GetRecentRollupsForNodeRow, error)
 - func (q *Queries) GetRecentTxs(ctx context.Context, limit int32) ([]CoreTransaction, error)
 - func (q *Queries) GetRecordingsForTrack(ctx context.Context, trackID string) ([]SoundRecording, error)
 - func (q *Queries) GetRegisteredNodeByCometAddress(ctx context.Context, cometAddress string) (CoreValidator, error)
 - func (q *Queries) GetRegisteredNodeByEthAddress(ctx context.Context, ethAddress string) (CoreValidator, error)
 - func (q *Queries) GetRegisteredNodesByCometAddresses(ctx context.Context, dollar_1 []string) ([]CoreValidator, error)
 - func (q *Queries) GetRegisteredNodesByEthAddresses(ctx context.Context, dollar_1 []string) ([]CoreValidator, error)
 - func (q *Queries) GetRegisteredNodesByType(ctx context.Context, nodeType string) ([]CoreValidator, error)
 - func (q *Queries) GetReward(ctx context.Context, address string) (CoreReward, error)
 - func (q *Queries) GetRewardByID(ctx context.Context, rewardID string) (CoreReward, error)
 - func (q *Queries) GetRewardByTxHash(ctx context.Context, txHash string) (CoreReward, error)
 - func (q *Queries) GetRewardsByClaimAuthority(ctx context.Context, dollar_1 string) ([]CoreReward, error)
 - func (q *Queries) GetRollupReportForNodeAndId(ctx context.Context, arg GetRollupReportForNodeAndIdParams) (SlaNodeReport, error)
 - func (q *Queries) GetRollupReportsForId(ctx context.Context, slaRollupID pgtype.Int4) ([]SlaNodeReport, error)
 - func (q *Queries) GetRollupReportsForNodeInTimeRange(ctx context.Context, arg GetRollupReportsForNodeInTimeRangeParams) ([]GetRollupReportsForNodeInTimeRangeRow, error)
 - func (q *Queries) GetRollupReportsForNodesInTimeRange(ctx context.Context, arg GetRollupReportsForNodesInTimeRangeParams) ([]GetRollupReportsForNodesInTimeRangeRow, error)
 - func (q *Queries) GetSlaRollupWithBlockEnd(ctx context.Context, blockEnd int64) (SlaRollup, error)
 - func (q *Queries) GetSlaRollupWithId(ctx context.Context, id int32) (SlaRollup, error)
 - func (q *Queries) GetSlaRollupWithTimestamp(ctx context.Context, time pgtype.Timestamp) (SlaRollup, error)
 - func (q *Queries) GetStorageProof(ctx context.Context, arg GetStorageProofParams) (StorageProof, error)
 - func (q *Queries) GetStorageProofPeers(ctx context.Context, blockHeight int64) ([]string, error)
 - func (q *Queries) GetStorageProofRollupForNode(ctx context.Context, arg GetStorageProofRollupForNodeParams) (GetStorageProofRollupForNodeRow, error)
 - func (q *Queries) GetStorageProofRollups(ctx context.Context, arg GetStorageProofRollupsParams) ([]GetStorageProofRollupsRow, error)
 - func (q *Queries) GetStorageProofs(ctx context.Context, blockHeight int64) ([]StorageProof, error)
 - func (q *Queries) GetStorageProofsForNodeInRange(ctx context.Context, arg GetStorageProofsForNodeInRangeParams) ([]StorageProof, error)
 - func (q *Queries) GetTx(ctx context.Context, lower string) (CoreTransaction, error)
 - func (q *Queries) GetValidatorHistoryForID(ctx context.Context, arg GetValidatorHistoryForIDParams) (ValidatorHistory, error)
 - func (q *Queries) HasAccessToTrackRelease(ctx context.Context, arg HasAccessToTrackReleaseParams) (bool, error)
 - func (q *Queries) InsertAccessKey(ctx context.Context, arg InsertAccessKeyParams) error
 - func (q *Queries) InsertCoreDeal(ctx context.Context, arg InsertCoreDealParams) error
 - func (q *Queries) InsertCoreERN(ctx context.Context, arg InsertCoreERNParams) error
 - func (q *Queries) InsertCoreMEAD(ctx context.Context, arg InsertCoreMEADParams) error
 - func (q *Queries) InsertCorePIE(ctx context.Context, arg InsertCorePIEParams) error
 - func (q *Queries) InsertCoreParty(ctx context.Context, arg InsertCorePartyParams) error
 - func (q *Queries) InsertCoreRelease(ctx context.Context, arg InsertCoreReleaseParams) error
 - func (q *Queries) InsertCoreResource(ctx context.Context, arg InsertCoreResourceParams) error
 - func (q *Queries) InsertCoreReward(ctx context.Context, arg InsertCoreRewardParams) error
 - func (q *Queries) InsertDecodedManageEntity(ctx context.Context, arg InsertDecodedManageEntityParams) error
 - func (q *Queries) InsertDecodedPlay(ctx context.Context, arg InsertDecodedPlayParams) error
 - func (q *Queries) InsertDecodedSlaRollup(ctx context.Context, arg InsertDecodedSlaRollupParams) error
 - func (q *Queries) InsertDecodedStorageProof(ctx context.Context, arg InsertDecodedStorageProofParams) error
 - func (q *Queries) InsertDecodedStorageProofVerification(ctx context.Context, arg InsertDecodedStorageProofVerificationParams) error
 - func (q *Queries) InsertDecodedValidatorDeregistration(ctx context.Context, arg InsertDecodedValidatorDeregistrationParams) error
 - func (q *Queries) InsertDecodedValidatorRegistration(ctx context.Context, arg InsertDecodedValidatorRegistrationParams) error
 - func (q *Queries) InsertEtlDuplicate(ctx context.Context, arg InsertEtlDuplicateParams) error
 - func (q *Queries) InsertEtlTx(ctx context.Context, arg InsertEtlTxParams) error
 - func (q *Queries) InsertFailedStorageProof(ctx context.Context, arg InsertFailedStorageProofParams) error
 - func (q *Queries) InsertFileUpload(ctx context.Context, arg InsertFileUploadParams) error
 - func (q *Queries) InsertManagementKey(ctx context.Context, arg InsertManagementKeyParams) error
 - func (q *Queries) InsertRegisteredNode(ctx context.Context, arg InsertRegisteredNodeParams) error
 - func (q *Queries) InsertSoundRecording(ctx context.Context, arg InsertSoundRecordingParams) error
 - func (q *Queries) InsertStorageProof(ctx context.Context, arg InsertStorageProofParams) error
 - func (q *Queries) InsertStorageProofPeers(ctx context.Context, arg InsertStorageProofPeersParams) error
 - func (q *Queries) InsertTrackId(ctx context.Context, trackID string) error
 - func (q *Queries) InsertTxStat(ctx context.Context, arg InsertTxStatParams) error
 - func (q *Queries) StoreBlock(ctx context.Context, arg StoreBlockParams) error
 - func (q *Queries) StoreTransaction(ctx context.Context, arg StoreTransactionParams) error
 - func (q *Queries) ToPgxTimestamp(t time.Time) pgtype.Timestamp
 - func (q *Queries) TotalBlocks(ctx context.Context) (int64, error)
 - func (q *Queries) TotalTransactions(ctx context.Context) (int64, error)
 - func (q *Queries) TotalTransactionsByType(ctx context.Context, txType string) (int64, error)
 - func (q *Queries) TotalTxResults(ctx context.Context) (int64, error)
 - func (q *Queries) TotalValidators(ctx context.Context) (int64, error)
 - func (q *Queries) TxsPerHour(ctx context.Context) ([]TxsPerHourRow, error)
 - func (q *Queries) UpdateCoreReward(ctx context.Context, arg UpdateCoreRewardParams) error
 - func (q *Queries) UpdateStorageProof(ctx context.Context, arg UpdateStorageProofParams) error
 - func (q *Queries) UpsertAppState(ctx context.Context, arg UpsertAppStateParams) error
 - func (q *Queries) UpsertSlaRollupReport(ctx context.Context, address string) error
 - func (q *Queries) WithTx(tx pgx.Tx) *Queries
 
- type SlaNodeReport
 - type SlaRollup
 - type SoundRecording
 - type StorageProof
 - type StorageProofPeer
 - type StoreBlockParams
 - type StoreTransactionParams
 - type TrackRelease
 - type TxsPerHourRow
 - type UpdateCoreRewardParams
 - type UpdateStorageProofParams
 - type UpsertAppStateParams
 - type ValidatorEventType
 - type ValidatorHistory
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CommitSlaRollupParams ¶
type CoreAppState ¶
type CoreEtlTxDuplicate ¶
type CoreEtlTxManageEntity ¶
type CoreEtlTxPlay ¶
type CoreEtlTxSlaRollup ¶
type CoreEtlTxSlaRollup struct {
	ID         int64
	TxHash     string
	BlockStart int64
	BlockEnd   int64
	Timestamp  pgtype.Timestamptz
	CreatedAt  pgtype.Timestamptz
}
    type CoreEtlTxStorageProof ¶
type CoreRelease ¶
type CoreResource ¶
type CoreReward ¶
type CoreTransaction ¶
type CoreTxStat ¶
type CoreUpload ¶
type CoreValidator ¶
type GetAppStateAtHeightRow ¶
type GetAvailableCitiesParams ¶
type GetAvailableCitiesParams struct {
	Column1 interface{}
	Column2 interface{}
	Limit   int32
}
    type GetAvailableCitiesRow ¶
type GetAvailableRegionsParams ¶
type GetAvailableRegionsParams struct {
	Column1 interface{}
	Limit   int32
}
    type GetAvailableRegionsRow ¶
type GetDecodedPlaysByLocationParams ¶
type GetDecodedPlaysByLocationParams struct {
	Column1 interface{}
	Column2 interface{}
	Column3 interface{}
	Limit   int32
}
    type GetDecodedPlaysByTimeRangeParams ¶
type GetDecodedPlaysByTimeRangeParams struct {
	PlayedAt   pgtype.Timestamptz
	PlayedAt_2 pgtype.Timestamptz
	Limit      int32
}
    type GetDecodedPlaysRow ¶
type GetERNReceiptsRow ¶
type GetLatestAppStateRow ¶
type GetMEADReceiptsRow ¶
type GetPIEReceiptsRow ¶
type GetStorageProofParams ¶
type InsertAccessKeyParams ¶
type InsertCoreDealParams ¶
type InsertCoreERNParams ¶
type InsertCoreMEADParams ¶
type InsertCorePIEParams ¶
type InsertCorePartyParams ¶
type InsertCoreReleaseParams ¶
type InsertCoreRewardParams ¶
type InsertDecodedPlayParams ¶
type InsertDecodedSlaRollupParams ¶
type InsertDecodedSlaRollupParams struct {
	TxHash     string
	BlockStart int64
	BlockEnd   int64
	Timestamp  pgtype.Timestamptz
	CreatedAt  pgtype.Timestamptz
}
    type InsertDecodedStorageProofVerificationParams ¶
type InsertDecodedStorageProofVerificationParams struct {
	TxHash    string
	Height    int64
	Proof     []byte
	CreatedAt pgtype.Timestamptz
}
    type InsertDecodedValidatorDeregistrationParams ¶
type InsertDecodedValidatorDeregistrationParams struct {
	TxHash       string
	CometAddress string
	PubKey       []byte
	CreatedAt    pgtype.Timestamptz
}
    type InsertEtlTxParams ¶
type InsertFileUploadParams ¶
type InsertTxStatParams ¶
type ManagementKey ¶
type NullProofStatus ¶
type NullProofStatus struct {
	ProofStatus ProofStatus
	Valid       bool // Valid is true if ProofStatus is not NULL
}
    func (*NullProofStatus) Scan ¶
func (ns *NullProofStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type ProofStatus ¶
type ProofStatus string
const ( ProofStatusUnresolved ProofStatus = "unresolved" ProofStatusPass ProofStatus = "pass" ProofStatusFail ProofStatus = "fail" )
func (*ProofStatus) Scan ¶
func (e *ProofStatus) Scan(src interface{}) error
type Queries ¶
type Queries struct {
	// contains filtered or unexported fields
}
    func (*Queries) AppendValidatorHistory ¶
func (q *Queries) AppendValidatorHistory(ctx context.Context, arg AppendValidatorHistoryParams) error
func (*Queries) CheckDatabaseExists ¶
func (*Queries) ClearUncommittedSlaNodeReports ¶
func (*Queries) CommitSlaNodeReport ¶
func (q *Queries) CommitSlaNodeReport(ctx context.Context, arg CommitSlaNodeReportParams) error
func (*Queries) CommitSlaRollup ¶
func (*Queries) DeleteCoreReward ¶
func (*Queries) DeleteRegisteredNode ¶
func (*Queries) GetActiveRewards ¶
func (q *Queries) GetActiveRewards(ctx context.Context) ([]CoreReward, error)
func (*Queries) GetAllEthAddressesOfRegisteredNodes ¶
func (*Queries) GetAllRegisteredNodes ¶
func (q *Queries) GetAllRegisteredNodes(ctx context.Context) ([]CoreValidator, error)
func (*Queries) GetAllRegisteredNodesSorted ¶
func (q *Queries) GetAllRegisteredNodesSorted(ctx context.Context) ([]CoreValidator, error)
func (*Queries) GetAllRewards ¶
func (q *Queries) GetAllRewards(ctx context.Context) ([]CoreReward, error)
func (*Queries) GetAppStateAtHeight ¶
func (*Queries) GetAvailableCities ¶
func (q *Queries) GetAvailableCities(ctx context.Context, arg GetAvailableCitiesParams) ([]GetAvailableCitiesRow, error)
func (*Queries) GetAvailableCountries ¶
func (*Queries) GetAvailableRegions ¶
func (q *Queries) GetAvailableRegions(ctx context.Context, arg GetAvailableRegionsParams) ([]GetAvailableRegionsRow, error)
func (*Queries) GetBlockTransactions ¶
func (*Queries) GetBlocksWithTransactions ¶
func (*Queries) GetCoreUpload ¶
func (*Queries) GetDecodedPlays ¶
func (*Queries) GetDecodedPlaysByLocation ¶
func (q *Queries) GetDecodedPlaysByLocation(ctx context.Context, arg GetDecodedPlaysByLocationParams) ([]GetDecodedPlaysByLocationRow, error)
func (*Queries) GetDecodedPlaysByTimeRange ¶
func (q *Queries) GetDecodedPlaysByTimeRange(ctx context.Context, arg GetDecodedPlaysByTimeRangeParams) ([]GetDecodedPlaysByTimeRangeRow, error)
func (*Queries) GetDecodedPlaysByTrack ¶
func (q *Queries) GetDecodedPlaysByTrack(ctx context.Context, arg GetDecodedPlaysByTrackParams) ([]GetDecodedPlaysByTrackRow, error)
func (*Queries) GetDecodedPlaysByUser ¶
func (q *Queries) GetDecodedPlaysByUser(ctx context.Context, arg GetDecodedPlaysByUserParams) ([]GetDecodedPlaysByUserRow, error)
func (*Queries) GetDecodedTx ¶
func (*Queries) GetDecodedTxsByBlock ¶
func (*Queries) GetDecodedTxsByType ¶
func (*Queries) GetERNContainingAddress ¶
func (*Queries) GetERNDeals ¶
func (*Queries) GetERNParties ¶
func (*Queries) GetERNReceipts ¶
func (*Queries) GetERNReleases ¶
func (*Queries) GetERNResources ¶
func (*Queries) GetInProgressRollupReports ¶
func (q *Queries) GetInProgressRollupReports(ctx context.Context) ([]SlaNodeReport, error)
func (*Queries) GetLatestAppState ¶
func (q *Queries) GetLatestAppState(ctx context.Context) (GetLatestAppStateRow, error)
func (*Queries) GetLatestBlock ¶
func (*Queries) GetLatestDecodedTxs ¶
func (*Queries) GetLatestSlaRollup ¶
func (*Queries) GetMEADReceipts ¶
func (*Queries) GetNodeByEndpoint ¶
func (*Queries) GetNodesByEndpoints ¶
func (*Queries) GetPIEReceipts ¶
func (*Queries) GetPreviousSlaRollupFromId ¶
func (*Queries) GetRecentBlocks ¶
func (*Queries) GetRecentRollupsForAllNodes ¶
func (q *Queries) GetRecentRollupsForAllNodes(ctx context.Context, arg GetRecentRollupsForAllNodesParams) ([]GetRecentRollupsForAllNodesRow, error)
func (*Queries) GetRecentRollupsForNode ¶
func (q *Queries) GetRecentRollupsForNode(ctx context.Context, arg GetRecentRollupsForNodeParams) ([]GetRecentRollupsForNodeRow, error)
func (*Queries) GetRecentTxs ¶
func (*Queries) GetRecordingsForTrack ¶
func (*Queries) GetRegisteredNodeByCometAddress ¶
func (*Queries) GetRegisteredNodeByEthAddress ¶
func (*Queries) GetRegisteredNodesByCometAddresses ¶
func (*Queries) GetRegisteredNodesByEthAddresses ¶
func (*Queries) GetRegisteredNodesByType ¶
func (*Queries) GetRewardByID ¶
func (*Queries) GetRewardByTxHash ¶
func (*Queries) GetRewardsByClaimAuthority ¶
func (*Queries) GetRollupReportForNodeAndId ¶
func (q *Queries) GetRollupReportForNodeAndId(ctx context.Context, arg GetRollupReportForNodeAndIdParams) (SlaNodeReport, error)
func (*Queries) GetRollupReportsForId ¶
func (*Queries) GetRollupReportsForNodeInTimeRange ¶
func (q *Queries) GetRollupReportsForNodeInTimeRange(ctx context.Context, arg GetRollupReportsForNodeInTimeRangeParams) ([]GetRollupReportsForNodeInTimeRangeRow, error)
func (*Queries) GetRollupReportsForNodesInTimeRange ¶
func (q *Queries) GetRollupReportsForNodesInTimeRange(ctx context.Context, arg GetRollupReportsForNodesInTimeRangeParams) ([]GetRollupReportsForNodesInTimeRangeRow, error)
func (*Queries) GetSlaRollupWithBlockEnd ¶
func (*Queries) GetSlaRollupWithId ¶
func (*Queries) GetSlaRollupWithTimestamp ¶
func (*Queries) GetStorageProof ¶
func (q *Queries) GetStorageProof(ctx context.Context, arg GetStorageProofParams) (StorageProof, error)
func (*Queries) GetStorageProofPeers ¶
func (*Queries) GetStorageProofRollupForNode ¶
func (q *Queries) GetStorageProofRollupForNode(ctx context.Context, arg GetStorageProofRollupForNodeParams) (GetStorageProofRollupForNodeRow, error)
func (*Queries) GetStorageProofRollups ¶
func (q *Queries) GetStorageProofRollups(ctx context.Context, arg GetStorageProofRollupsParams) ([]GetStorageProofRollupsRow, error)
func (*Queries) GetStorageProofs ¶
func (*Queries) GetStorageProofsForNodeInRange ¶
func (q *Queries) GetStorageProofsForNodeInRange(ctx context.Context, arg GetStorageProofsForNodeInRangeParams) ([]StorageProof, error)
func (*Queries) GetValidatorHistoryForID ¶
func (q *Queries) GetValidatorHistoryForID(ctx context.Context, arg GetValidatorHistoryForIDParams) (ValidatorHistory, error)
func (*Queries) HasAccessToTrackRelease ¶
func (*Queries) InsertAccessKey ¶
func (q *Queries) InsertAccessKey(ctx context.Context, arg InsertAccessKeyParams) error
func (*Queries) InsertCoreDeal ¶
func (q *Queries) InsertCoreDeal(ctx context.Context, arg InsertCoreDealParams) error
func (*Queries) InsertCoreERN ¶
func (q *Queries) InsertCoreERN(ctx context.Context, arg InsertCoreERNParams) error
ERN, MEAD, PIE insert queries - using protobuf storage with new schema
func (*Queries) InsertCoreMEAD ¶
func (q *Queries) InsertCoreMEAD(ctx context.Context, arg InsertCoreMEADParams) error
func (*Queries) InsertCorePIE ¶
func (q *Queries) InsertCorePIE(ctx context.Context, arg InsertCorePIEParams) error
func (*Queries) InsertCoreParty ¶
func (q *Queries) InsertCoreParty(ctx context.Context, arg InsertCorePartyParams) error
func (*Queries) InsertCoreRelease ¶
func (q *Queries) InsertCoreRelease(ctx context.Context, arg InsertCoreReleaseParams) error
func (*Queries) InsertCoreResource ¶
func (q *Queries) InsertCoreResource(ctx context.Context, arg InsertCoreResourceParams) error
func (*Queries) InsertCoreReward ¶
func (q *Queries) InsertCoreReward(ctx context.Context, arg InsertCoreRewardParams) error
func (*Queries) InsertDecodedManageEntity ¶
func (q *Queries) InsertDecodedManageEntity(ctx context.Context, arg InsertDecodedManageEntityParams) error
func (*Queries) InsertDecodedPlay ¶
func (q *Queries) InsertDecodedPlay(ctx context.Context, arg InsertDecodedPlayParams) error
func (*Queries) InsertDecodedSlaRollup ¶
func (q *Queries) InsertDecodedSlaRollup(ctx context.Context, arg InsertDecodedSlaRollupParams) error
func (*Queries) InsertDecodedStorageProof ¶
func (q *Queries) InsertDecodedStorageProof(ctx context.Context, arg InsertDecodedStorageProofParams) error
func (*Queries) InsertDecodedStorageProofVerification ¶
func (q *Queries) InsertDecodedStorageProofVerification(ctx context.Context, arg InsertDecodedStorageProofVerificationParams) error
func (*Queries) InsertDecodedValidatorDeregistration ¶
func (q *Queries) InsertDecodedValidatorDeregistration(ctx context.Context, arg InsertDecodedValidatorDeregistrationParams) error
func (*Queries) InsertDecodedValidatorRegistration ¶
func (q *Queries) InsertDecodedValidatorRegistration(ctx context.Context, arg InsertDecodedValidatorRegistrationParams) error
func (*Queries) InsertEtlDuplicate ¶
func (q *Queries) InsertEtlDuplicate(ctx context.Context, arg InsertEtlDuplicateParams) error
func (*Queries) InsertEtlTx ¶
func (q *Queries) InsertEtlTx(ctx context.Context, arg InsertEtlTxParams) error
func (*Queries) InsertFailedStorageProof ¶
func (q *Queries) InsertFailedStorageProof(ctx context.Context, arg InsertFailedStorageProofParams) error
func (*Queries) InsertFileUpload ¶
func (q *Queries) InsertFileUpload(ctx context.Context, arg InsertFileUploadParams) error
func (*Queries) InsertManagementKey ¶
func (q *Queries) InsertManagementKey(ctx context.Context, arg InsertManagementKeyParams) error
func (*Queries) InsertRegisteredNode ¶
func (q *Queries) InsertRegisteredNode(ctx context.Context, arg InsertRegisteredNodeParams) error
func (*Queries) InsertSoundRecording ¶
func (q *Queries) InsertSoundRecording(ctx context.Context, arg InsertSoundRecordingParams) error
func (*Queries) InsertStorageProof ¶
func (q *Queries) InsertStorageProof(ctx context.Context, arg InsertStorageProofParams) error
func (*Queries) InsertStorageProofPeers ¶
func (q *Queries) InsertStorageProofPeers(ctx context.Context, arg InsertStorageProofPeersParams) error
func (*Queries) InsertTrackId ¶
func (*Queries) InsertTxStat ¶
func (q *Queries) InsertTxStat(ctx context.Context, arg InsertTxStatParams) error
func (*Queries) StoreBlock ¶
func (q *Queries) StoreBlock(ctx context.Context, arg StoreBlockParams) error
func (*Queries) StoreTransaction ¶
func (q *Queries) StoreTransaction(ctx context.Context, arg StoreTransactionParams) error
func (*Queries) TotalTransactions ¶
func (*Queries) TotalTransactionsByType ¶
func (*Queries) TotalTxResults ¶
func (*Queries) TotalValidators ¶
func (*Queries) TxsPerHour ¶
func (q *Queries) TxsPerHour(ctx context.Context) ([]TxsPerHourRow, error)
func (*Queries) UpdateCoreReward ¶
func (q *Queries) UpdateCoreReward(ctx context.Context, arg UpdateCoreRewardParams) error
func (*Queries) UpdateStorageProof ¶
func (q *Queries) UpdateStorageProof(ctx context.Context, arg UpdateStorageProofParams) error
func (*Queries) UpsertAppState ¶
func (q *Queries) UpsertAppState(ctx context.Context, arg UpsertAppStateParams) error
func (*Queries) UpsertSlaRollupReport ¶
type SlaNodeReport ¶
type SoundRecording ¶
type StorageProof ¶
type StorageProofPeer ¶
type StoreBlockParams ¶
type StoreTransactionParams ¶
type TrackRelease ¶
type TxsPerHourRow ¶
type UpdateCoreRewardParams ¶
type UpdateStorageProofParams ¶
type UpdateStorageProofParams struct {
	Proof       pgtype.Text
	Status      ProofStatus
	BlockHeight int64
	Address     string
}
    type UpsertAppStateParams ¶
type ValidatorEventType ¶
type ValidatorEventType string
const ( ValidatorEventRegistered ValidatorEventType = "registered" ValidatorEventDeregistered ValidatorEventType = "deregistered" )
 Click to show internal directories. 
   Click to hide internal directories.