clickhouse

package
v0.0.0-...-e01acf0 Latest Latest
Warning

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

Go to latest
Published: Apr 14, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DB

type DB struct {
	// contains filtered or unexported fields
}

func NewDB

func NewDB(cfg config.Clickhouse) (*DB, error)

func (DB) CreateBalanceUpdates

func (db DB) CreateBalanceUpdates(updates []dmodels.BalanceUpdate) error

func (DB) CreateBlocks

func (db DB) CreateBlocks(blocks []dmodels.Block) error

func (DB) CreateDelegations

func (db DB) CreateDelegations(delegations []dmodels.Delegation) error

func (DB) CreateDelegatorRewards

func (db DB) CreateDelegatorRewards(rewards []dmodels.DelegatorReward) error

func (DB) CreateHistoricalStates

func (db DB) CreateHistoricalStates(states []dmodels.HistoricalState) error

func (DB) CreateHistoryProposals

func (db DB) CreateHistoryProposals(proposals []dmodels.HistoryProposal) error

func (DB) CreateJailers

func (db DB) CreateJailers(jailers []dmodels.Jailer) error

func (DB) CreateMissedBlocks

func (db DB) CreateMissedBlocks(blocks []dmodels.MissedBlock) error

func (DB) CreateProposalDeposits

func (db DB) CreateProposalDeposits(deposits []dmodels.ProposalDeposit) error

func (DB) CreateProposalVotes

func (db DB) CreateProposalVotes(votes []dmodels.ProposalVote) error

func (DB) CreateStats

func (db DB) CreateStats(stats []dmodels.Stat) (err error)

func (DB) CreateTransactions

func (db DB) CreateTransactions(transactions []dmodels.Transaction) error

func (DB) CreateTransfers

func (db DB) CreateTransfers(transfers []dmodels.Transfer) error

func (DB) CreateValidatorRewards

func (db DB) CreateValidatorRewards(rewards []dmodels.ValidatorReward) error

func (*DB) Find

func (db *DB) Find(dest interface{}, b squirrel.SelectBuilder) error

func (*DB) FindFirst

func (db *DB) FindFirst(dest interface{}, b squirrel.SelectBuilder) error

func (DB) GetActiveAccounts

func (db DB) GetActiveAccounts(filter filters.ActiveAccounts) (addresses []string, err error)

func (DB) GetAggBlocksCount

func (db DB) GetAggBlocksCount(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetAggBlocksDelay

func (db DB) GetAggBlocksDelay(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetAggDelegationsVolume

func (db DB) GetAggDelegationsVolume(filter filters.DelegationsAgg) (items []smodels.AggItem, err error)

func (DB) GetAggHistoricalStatesByField

func (db DB) GetAggHistoricalStatesByField(filter filters.Agg, field string) (items []smodels.AggItem, err error)

func (DB) GetAggOperationsCount

func (db DB) GetAggOperationsCount(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetAggProposalVotes

func (db DB) GetAggProposalVotes(filter filters.Agg, id []uint64) (items []smodels.AggItem, err error)

func (DB) GetAggTransactionsFee

func (db DB) GetAggTransactionsFee(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetAggTransfersVolume

func (db DB) GetAggTransfersVolume(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetAggUndelegationsVolume

func (db DB) GetAggUndelegationsVolume(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetAggUniqBlockValidators

func (db DB) GetAggUniqBlockValidators(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetAggValidators33Power

func (db DB) GetAggValidators33Power(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetAggWhaleAccounts

func (db DB) GetAggWhaleAccounts(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetAvgBlocksDelay

func (db DB) GetAvgBlocksDelay(filter filters.TimeRange) (delay float64, err error)

func (DB) GetAvgOperationsPerBlock

func (db DB) GetAvgOperationsPerBlock(filter filters.Agg) (items []smodels.AggItem, err error)

func (DB) GetBalanceUpdate

func (db DB) GetBalanceUpdate(filter filters.BalanceUpdates) (updates []dmodels.BalanceUpdate, err error)

func (DB) GetBlocks

func (db DB) GetBlocks(filter filters.Blocks) (blocks []dmodels.Block, err error)

func (DB) GetDelegatorsTotal

func (db DB) GetDelegatorsTotal(filter filters.Delegators) (total uint64, err error)

func (DB) GetHistoricalStates

func (db DB) GetHistoricalStates(filter filters.HistoricalState) (states []dmodels.HistoricalState, err error)

func (DB) GetHistoryProposals

func (db DB) GetHistoryProposals(filter filters.HistoryProposals) (proposals []dmodels.HistoryProposal, err error)

func (DB) GetJailersTotal

func (db DB) GetJailersTotal() (total uint64, err error)

func (DB) GetMissedBlocksCount

func (db DB) GetMissedBlocksCount(filter filters.MissedBlocks) (total uint64, err error)

func (DB) GetMostJailedValidators

func (db DB) GetMostJailedValidators() (items []dmodels.ValidatorValue, err error)

func (DB) GetMultiDelegatorsTotal

func (db DB) GetMultiDelegatorsTotal(filter filters.TimeRange) (total uint64, err error)

func (DB) GetProposalDeposits

func (db DB) GetProposalDeposits(filter filters.ProposalDeposits) (deposits []dmodels.ProposalDeposit, err error)

func (DB) GetProposalVotes

func (db DB) GetProposalVotes(filter filters.ProposalVotes) (votes []dmodels.ProposalVote, err error)

func (DB) GetProposedBlocksTotal

func (db DB) GetProposedBlocksTotal(filter filters.BlocksProposed) (total uint64, err error)

func (DB) GetStats

func (db DB) GetStats(filter filters.Stats) (stats []dmodels.Stat, err error)

func (DB) GetTopProposedBlocksValidators

func (db DB) GetTopProposedBlocksValidators() (items []dmodels.ValidatorValue, err error)

func (DB) GetTotalVotesByAddress

func (db DB) GetTotalVotesByAddress(address string) (total uint64, err error)

func (DB) GetTransactionsFeeVolume

func (db DB) GetTransactionsFeeVolume(filter filters.TimeRange) (total decimal.Decimal, err error)

func (DB) GetTransactionsHighestFee

func (db DB) GetTransactionsHighestFee(filter filters.TimeRange) (total decimal.Decimal, err error)

func (DB) GetTransferVolume

func (db DB) GetTransferVolume(filter filters.TimeRange) (total decimal.Decimal, err error)

func (DB) GetUndelegationsVolume

func (db DB) GetUndelegationsVolume(filter filters.TimeRange) (total decimal.Decimal, err error)

func (DB) GetValidatorDelegators

func (db DB) GetValidatorDelegators(filter filters.ValidatorDelegators) (items []dmodels.ValidatorDelegator, err error)

func (DB) GetValidatorDelegatorsTotal

func (db DB) GetValidatorDelegatorsTotal(filter filters.ValidatorDelegators) (total uint64, err error)

func (DB) GetValidatorsDelegatorsTotal

func (db DB) GetValidatorsDelegatorsTotal() (values []dmodels.ValidatorValue, err error)

func (DB) GetVotingPower

func (db DB) GetVotingPower(filter filters.VotingPower) (volume decimal.Decimal, err error)

func (*DB) Insert

func (db *DB) Insert(b squirrel.InsertBuilder) error

Jump to

Keyboard shortcuts

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