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

Source Files

View all Source files

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.