database

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2023 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Migrations embed.FS

Functions

func Builder 

func Builder(ctx *db.Context) (db.Database, error)

Builder allows to create a new Db instance implementing the db.Builder type

Types

type Db 

type Db struct {
	*postgresql.Database
	Sqlx *sqlx.DB
}

Db represents a PostgreSQL database with expanded features. so that it can properly store custom BigDipper-related data.

func Cast 

func Cast(db db.Database) *Db

Cast allows to cast the given db to a Db instance

func (*Db) DeleteFeeGrantAllowance 

func (db *Db) DeleteFeeGrantAllowance(allowance types.GrantRemoval) error

DeleteFeeGrantAllowance removes the fee grant allowance data from the database

func (*Db) GetAccounts 

func (db *Db) GetAccounts() ([]string, error)

GetAccounts returns all the accounts that are currently stored inside the database.

func (*Db) GetBlockHeightTimeDayAgo 

func (db *Db) GetBlockHeightTimeDayAgo(now time.Time) (dbtypes.BlockRow, error)

GetBlockHeightTimeDayAgo return block height and time that a block proposals about a day (24hour) ago from input date

func (*Db) GetBlockHeightTimeHourAgo 

func (db *Db) GetBlockHeightTimeHourAgo(now time.Time) (dbtypes.BlockRow, error)

GetBlockHeightTimeHourAgo return block height and time that a block proposals about a hour ago from input date

func (*Db) GetBlockHeightTimeMinuteAgo 

func (db *Db) GetBlockHeightTimeMinuteAgo(now time.Time) (dbtypes.BlockRow, error)

GetBlockHeightTimeMinuteAgo return block height and time that a block proposals about a minute ago from input date

func (*Db) GetGenesis 

func (db *Db) GetGenesis() (*types.Genesis, error)

GetGenesis returns the genesis information stored inside the database

func (*Db) GetGovParams 

func (db *Db) GetGovParams() (*types.GovParams, error)

GetGovParams returns the most recent governance parameters

func (*Db) GetItem 

func (db *Db) GetItem(index string) (*types.Item, error)

func (*Db) GetLastBlock 

func (db *Db) GetLastBlock() (*dbtypes.BlockRow, error)

GetLastBlock returns the last block stored inside the database based on the heights

func (*Db) GetLastBlockHeight 

func (db *Db) GetLastBlockHeight() (int64, error)

GetLastBlockHeight returns the last block height stored inside the database

func (*Db) GetOpenProposalsIds 

func (db *Db) GetOpenProposalsIds(blockHeight uint64) ([]uint64, error)

GetOpenProposalsIds returns all the ids of the proposals that are currently in deposit or voting period

func (*Db) GetOperation 

func (db *Db) GetOperation(index string) (*types.Operation, error)

func (*Db) GetProposal 

func (db *Db) GetProposal(id uint64) (*types.Proposal, error)

GetProposal returns the proposal with the given id, or nil if not found

func (*Db) GetStakingParams 

func (db *Db) GetStakingParams() (*types.StakingParams, error)

GetStakingParams returns the types.StakingParams instance containing the current params

func (*Db) GetTokensPriceID 

func (db *Db) GetTokensPriceID() ([]string, error)

GetTokensPriceID returns the slice of price ids for all tokens stored in db

func (*Db) GetValidator 

func (db *Db) GetValidator(valAddress string) (types.Validator, error)

GetValidator returns the validator having the given address. If no validator for such address can be found, an error is returned instead.

func (*Db) GetValidatorBySelfDelegateAddress 

func (db *Db) GetValidatorBySelfDelegateAddress(address string) (types.Validator, error)

GetValidatorBySelfDelegateAddress returns the validator having the given address as the self_delegate_address, or an error if such validator cannot be found.

func (*Db) GetValidatorConsensusAddress 

func (db *Db) GetValidatorConsensusAddress(address string) (sdk.ConsAddress, error)

GetValidatorConsensusAddress returns the consensus address of the validator having the given operator address

func (*Db) GetValidatorOperatorAddress 

func (db *Db) GetValidatorOperatorAddress(consAddr string) (sdk.ValAddress, error)

GetValidatorOperatorAddress returns the operator address of the validator having the given consensus address

func (*Db) GetValidators 

func (db *Db) GetValidators() ([]types.Validator, error)

GetValidators returns all the validators that are currently stored inside the database.

func (*Db) InsertEnableModules 

func (db *Db) InsertEnableModules(modules []string) error

InsertEnableModules allows to save enabled module into the database

func (*Db) Prune 

func (db *Db) Prune(height int64) error

Prune implements db.PruningDb

func (*Db) RemoveCollection 

func (db *Db) RemoveCollection(indexKey []byte) error

func (*Db) RemoveCollectionData 

func (db *Db) RemoveCollectionData(indexKey []byte) error

func (*Db) RemoveCollectionDataByCollection 

func (db *Db) RemoveCollectionDataByCollection(collection string) error

func (*Db) RemoveItem 

func (db *Db) RemoveItem(index string) error

func (*Db) RemoveOnChainItems 

func (db *Db) RemoveOnChainItems(itemIndex string) error

func (*Db) RemoveRarimoCoreVotes 

func (db *Db) RemoveRarimoCoreVotes(opIndex string) error

func (*Db) RemoveSeed 

func (db *Db) RemoveSeed(seed string) error

func (*Db) SaveAccounts 

func (db *Db) SaveAccounts(accounts []types.Account) error

SaveAccounts saves the given accounts inside the database

func (*Db) SaveAverageBlockTimeGenesis 

func (db *Db) SaveAverageBlockTimeGenesis(averageTime float64, height int64) error

SaveAverageBlockTimeGenesis save the average block time in average_block_time_from_genesis table

func (*Db) SaveAverageBlockTimePerDay 

func (db *Db) SaveAverageBlockTimePerDay(averageTime float64, height int64) error

SaveAverageBlockTimePerDay save the average block time in average_block_time_per_day table

func (*Db) SaveAverageBlockTimePerHour 

func (db *Db) SaveAverageBlockTimePerHour(averageTime float64, height int64) error

SaveAverageBlockTimePerHour save the average block time in average_block_time_per_hour table

func (*Db) SaveAverageBlockTimePerMin 

func (db *Db) SaveAverageBlockTimePerMin(averageTime float64, height int64) error

SaveAverageBlockTimePerMin save the average block time in average_block_time_per_minute table

func (*Db) SaveBridgeParams 

func (db *Db) SaveBridgeParams(params *types.BridgeParams) (err error)

SaveBridgeParams saves the given x/bridge parameters inside the database

func (*Db) SaveChangeParties 

func (db *Db) SaveChangeParties(changeParties []types.ChangeParties) (err error)

func (*Db) SaveCollectionDatas 

func (db *Db) SaveCollectionDatas(collectionDatas []types.CollectionData) error

func (*Db) SaveCollections 

func (db *Db) SaveCollections(collections []types.Collection) error

func (*Db) SaveCommunityPool 

func (db *Db) SaveCommunityPool(coin sdk.DecCoins, height int64) error

SaveCommunityPool allows to save for the given height the given total amount of coins

func (*Db) SaveConfirmations 

func (db *Db) SaveConfirmations(confirmations []types.Confirmation) (err error)

func (*Db) SaveContractUpgrades 

func (db *Db) SaveContractUpgrades(contractUpgrades []types.ContractUpgrade) (err error)

func (*Db) SaveDeposits 

func (db *Db) SaveDeposits(deposits []types.Deposit) error

SaveDeposits allows to save multiple deposits

func (*Db) SaveDistributionParams 

func (db *Db) SaveDistributionParams(params *types.DistributionParams) error

SaveDistributionParams allows to store the given distribution parameters inside the database

func (*Db) SaveDoubleSignEvidence 

func (db *Db) SaveDoubleSignEvidence(evidence types.DoubleSignEvidence) error

SaveDoubleSignEvidence saves the given double sign evidence inside the proper tables

func (*Db) SaveFeeGrantAllowance 

func (db *Db) SaveFeeGrantAllowance(allowance types.FeeGrant) error

SaveFeeGrantAllowance allows to store the fee grant allowances for the given block height

func (*Db) SaveFeeTokenManagements 

func (db *Db) SaveFeeTokenManagements(managements []types.FeeTokenManagement) (err error)

func (*Db) SaveGenesis 

func (db *Db) SaveGenesis(genesis *types.Genesis) error

SaveGenesis save the given genesis data

func (*Db) SaveGenesisGovParams 

func (db *Db) SaveGenesisGovParams(params *types.GenesisGovParams) error

SaveGenesisGovParams saves the genesis x/gov parameters inside the database

func (*Db) SaveGovParams 

func (db *Db) SaveGovParams(params *types.GovParams) error

SaveGovParams saves the given x/gov parameters inside the database

func (*Db) SaveGroups 

func (db *Db) SaveGroups(groups []*types.Group) (err error)

SaveGroups saves the given x/multisig groups inside the database

func (*Db) SaveHashes 

func (db *Db) SaveHashes(hashes []types.Hash) error

func (*Db) SaveIdentityDefaultTransfers 

func (db *Db) SaveIdentityDefaultTransfers(transfers []types.IdentityDefaultTransfer) (err error)

func (*Db) SaveItems 

func (db *Db) SaveItems(items []types.Item) error

func (*Db) SaveMintParams 

func (db *Db) SaveMintParams(params *types.MintParams) error

SaveMintParams allows to store the given params inside the database

func (*Db) SaveMultisigParams 

func (db *Db) SaveMultisigParams(params *types.MultisigParams) (err error)

SaveMultisigParams saves the given x/multisig parameters inside the database

func (*Db) SaveMultisigProposalVotes 

func (db *Db) SaveMultisigProposalVotes(votes []*types.MultisigProposalVote) (err error)

SaveMultisigProposalVotes saves the given x/multisig proposal votes inside the database

func (*Db) SaveMultisigProposals 

func (db *Db) SaveMultisigProposals(proposals []*types.MultisigProposal) (err error)

SaveMultisigProposals saves the given x/multisig proposals inside the database

func (*Db) SaveOnChainItems 

func (db *Db) SaveOnChainItems(items []types.OnChainItem) error

func (*Db) SaveOperations 

func (db *Db) SaveOperations(operations []types.Operation) error

func (*Db) SaveOracleManagerParams 

func (db *Db) SaveOracleManagerParams(params *types.OracleManagerParams) (err error)

SaveOracleManagerParams saves the given x/oraclemanager parameters inside the database

func (*Db) SaveOracles 

func (db *Db) SaveOracles(oracles []types.Oracle) error

func (*Db) SaveParties 

func (db *Db) SaveParties(parties []types.Party) error

SaveParties saves the given x/gov parameters inside the database

func (*Db) SaveProposalStakingPoolSnapshot 

func (db *Db) SaveProposalStakingPoolSnapshot(snapshot types.ProposalStakingPoolSnapshot) error

SaveProposalStakingPoolSnapshot allows to save the given snapshot of the staking pool

func (*Db) SaveProposalValidatorsStatusesSnapshots 

func (db *Db) SaveProposalValidatorsStatusesSnapshots(snapshots []types.ProposalValidatorStatusSnapshot) error

SaveProposalValidatorsStatusesSnapshots allows to save the given validator statuses snapshots

func (*Db) SaveProposals 

func (db *Db) SaveProposals(proposals []types.Proposal) error

SaveProposals allows to save for the given height the given total amount of coins

func (*Db) SaveRarimoCoreParams 

func (db *Db) SaveRarimoCoreParams(params *types.RarimoCoreParams) (err error)

SaveRarimoCoreParams saves the given x/rarimocore parameters inside the database

func (*Db) SaveRarimoCoreVotes 

func (db *Db) SaveRarimoCoreVotes(votes []types.RarimoCoreVote) (err error)

func (*Db) SaveSeeds 

func (db *Db) SaveSeeds(seeds []types.Seed) error

func (*Db) SaveSlashingParams 

func (db *Db) SaveSlashingParams(params *types.SlashingParams) error

SaveSlashingParams saves the slashing params for the given height

func (*Db) SaveStakingParams 

func (db *Db) SaveStakingParams(params types.StakingParams) error

SaveStakingParams allows to store the given params into the database

func (*Db) SaveStakingPool 

func (db *Db) SaveStakingPool(pool *types.Pool) error

SaveStakingPool allows to save for the given height the given stakingtypes pool

func (*Db) SaveSupply 

func (db *Db) SaveSupply(coins sdk.Coins, height int64) error

SaveSupply allows to save for the given height the given total amount of coins

func (*Db) SaveTallyResults 

func (db *Db) SaveTallyResults(tallys []types.TallyResult) error

SaveTallyResults allows to save for the given height the given total amount of coins

func (*Db) SaveToken 

func (db *Db) SaveToken(token types.Token) error

SaveToken allows to save the given token details

func (*Db) SaveTokenManagerParams 

func (db *Db) SaveTokenManagerParams(params *types.TokenManagerParams) (err error)

SaveTokenManagerParams saves the given x/tokenmanager parameters inside the database

func (*Db) SaveTokenPricesHistory 

func (db *Db) SaveTokenPricesHistory(prices []types.TokenPrice) error

SaveTokenPricesHistory stores the given prices as historic ones

func (*Db) SaveTokensPrices 

func (db *Db) SaveTokensPrices(prices []types.TokenPrice) error

SaveTokensPrices allows to save the given prices as the most updated ones

func (*Db) SaveTransfers 

func (db *Db) SaveTransfers(transfers []types.Transfer) (err error)

func (*Db) SaveValidatorCommission 

func (db *Db) SaveValidatorCommission(data types.ValidatorCommission) error

SaveValidatorCommission saves a single validator commission. It assumes that the delegator address is already present inside the proper database table. TIP: To store the validator data call SaveValidatorData.

func (*Db) SaveValidatorData 

func (db *Db) SaveValidatorData(validator types.Validator) error

SaveValidatorData saves properly the information about the given validator.

func (*Db) SaveValidatorDescription 

func (db *Db) SaveValidatorDescription(description types.ValidatorDescription) error

SaveValidatorDescription save a single validator description. It assumes that the delegator address is already present inside the proper database table. TIP: To store the validator data call SaveValidatorData.

func (*Db) SaveValidatorsData 

func (db *Db) SaveValidatorsData(validators []types.Validator) error

SaveValidatorsData allows the bulk saving of a list of validators.

func (*Db) SaveValidatorsSigningInfos 

func (db *Db) SaveValidatorsSigningInfos(infos []types.ValidatorSigningInfo) error

SaveValidatorsSigningInfos saves the given infos inside the database

func (*Db) SaveValidatorsStatuses 

func (db *Db) SaveValidatorsStatuses(statuses []types.ValidatorStatus) error

SaveValidatorsStatuses save validator jail and status in the given height and timestamp

func (*Db) SaveValidatorsVotingPowers 

func (db *Db) SaveValidatorsVotingPowers(entries []types.ValidatorVotingPower) error

SaveValidatorsVotingPowers saves the given validator voting powers. It assumes that the delegator address is already present inside the proper database table. TIP: To store the validator data call SaveValidatorData.

func (*Db) SaveVestingAccounts 

func (db *Db) SaveVestingAccounts(vestingAccounts []exported.VestingAccount) error

SaveVestingAccounts saves the given vesting accounts inside the database

func (*Db) SaveViolationReports 

func (db *Db) SaveViolationReports(reports []types.ViolationReport) (err error)

func (*Db) SaveVote 

func (db *Db) SaveVote(vote types.Vote) error

SaveVote allows to save for the given height and the message vote

func (*Db) StoreBaseVestingAccountFromMsg 

func (db *Db) StoreBaseVestingAccountFromMsg(bva *vestingtypes.BaseVestingAccount, txTimestamp time.Time) error

func (*Db) UpdateChangeParties 

func (db *Db) UpdateChangeParties(changeParties types.ChangeParties) (err error)

func (*Db) UpdateCollection 

func (db *Db) UpdateCollection(collection types.Collection) error

func (*Db) UpdateCollectionData 

func (db *Db) UpdateCollectionData(data types.CollectionData) error

func (*Db) UpdateOperation 

func (db *Db) UpdateOperation(operation types.Operation) error

func (*Db) UpdateProposal 

func (db *Db) UpdateProposal(update types.ProposalUpdate) error

UpdateProposal updates a proposal stored inside the database

func (*Db) UpsertItem 

func (db *Db) UpsertItem(item types.Item) error

func (*Db) UpsertSeed 

func (db *Db) UpsertSeed(seed types.Seed) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.