rdbviewrepo

package
v0.0.0-...-5038352 Latest Latest
Warning

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

 Go to latest Published: Jul 25, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RDB_SQL_TRANSACTION_TYPES      = "('transfer','deposit','unbond','withdraw','nodejoin','unjail')"
	RDB_SQL_EVENT_TYPES            = "('reward','jail','slash')"
	RDB_SQL_NON_REWARD_EVENT_TYPES = "('jail','slash')"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type RDbActivityViewRepo 

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

func NewRDbActivityViewRepo 

func NewRDbActivityViewRepo(
	conn adapter.RDbConn,
	stmtBuilder sq.StatementBuilderType,
	typeConv adapter.RDbTypeConv,
) *RDbActivityViewRepo

func (*RDbActivityViewRepo) FindEventByBlockHeightEventPosition 

func (repo *RDbActivityViewRepo) FindEventByBlockHeightEventPosition(blockHeight uint64, eventPosition uint64) (*viewrepo.Event, error)

func (*RDbActivityViewRepo) FindTransactionByTxId 

func (repo *RDbActivityViewRepo) FindTransactionByTxId(txid string) (*viewrepo.Transaction, error)

func (*RDbActivityViewRepo) ListEvents 

func (repo *RDbActivityViewRepo) ListEvents(filter viewrepo.EventFilter, pagination *viewrepo.Pagination) ([]viewrepo.Event, *viewrepo.PaginationResult, error)

func (*RDbActivityViewRepo) ListTransactions 

func (repo *RDbActivityViewRepo) ListTransactions(filter viewrepo.TransactionFilter, pagination *viewrepo.Pagination) ([]viewrepo.Transaction, *viewrepo.PaginationResult, error)

func (*RDbActivityViewRepo) SearchEvents 

func (repo *RDbActivityViewRepo) SearchEvents(keyword string, pagination *viewrepo.Pagination) ([]viewrepo.Event, *viewrepo.PaginationResult, error)

func (*RDbActivityViewRepo) SearchTransactions 

func (repo *RDbActivityViewRepo) SearchTransactions(keyword string, pagination *viewrepo.Pagination) ([]viewrepo.Transaction, *viewrepo.PaginationResult, error)

func (*RDbActivityViewRepo) TransactionsCount 

func (repo *RDbActivityViewRepo) TransactionsCount() (uint64, error)

type RDbBlockViewRepo 

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

func NewRDbBlockViewRepo 

func NewRDbBlockViewRepo(
	conn adapter.RDbConn,
	stmtBuilder sq.StatementBuilderType,
	typeConv adapter.RDbTypeConv,
) *RDbBlockViewRepo

func (*RDbBlockViewRepo) FindBlock 

func (repo *RDbBlockViewRepo) FindBlock(blockIdentity viewrepo.BlockIdentity) (*viewrepo.Block, error)

func (*RDbBlockViewRepo) LatestBlockHeight 

func (repo *RDbBlockViewRepo) LatestBlockHeight() (uint64, error)

func (*RDbBlockViewRepo) ListBlockEvents 

func (repo *RDbBlockViewRepo) ListBlockEvents(
	blockIdentity viewrepo.BlockIdentity,
	pagination *viewrepo.Pagination,
) ([]viewrepo.BlockEvent, *viewrepo.PaginationResult, error)

func (*RDbBlockViewRepo) ListBlockTransactions 

func (repo *RDbBlockViewRepo) ListBlockTransactions(
	blockIdentity viewrepo.BlockIdentity,
	pagination *viewrepo.Pagination,
) ([]viewrepo.Transaction, *viewrepo.PaginationResult, error)

func (*RDbBlockViewRepo) ListBlocks 

func (repo *RDbBlockViewRepo) ListBlocks(filter viewrepo.BlockFilter, pagination *viewrepo.Pagination) ([]viewrepo.Block, *viewrepo.PaginationResult, error)

func (*RDbBlockViewRepo) Search 

func (repo *RDbBlockViewRepo) Search(keyword string, pagination *viewrepo.Pagination) ([]viewrepo.Block, *viewrepo.PaginationResult, error)

type RDbCouncilNodeViewRepo 

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

func NewRDbCouncilNodeViewRepo 

func NewRDbCouncilNodeViewRepo(
	conn adapter.RDbConn,
	stmtBuilder sq.StatementBuilderType,
	typeConv adapter.RDbTypeConv,
) *RDbCouncilNodeViewRepo

func (*RDbCouncilNodeViewRepo) FindById 

func (repo *RDbCouncilNodeViewRepo) FindById(id uint64) (*viewrepo.CouncilNode, error)

func (*RDbCouncilNodeViewRepo) ListActive 

func (repo *RDbCouncilNodeViewRepo) ListActive(pagination *viewrepo.Pagination) ([]viewrepo.CouncilNodeListItem, *viewrepo.PaginationResult, error)

func (*RDbCouncilNodeViewRepo) ListActivitiesById 

func (repo *RDbCouncilNodeViewRepo) ListActivitiesById(councilNodeId uint64, filter viewrepo.ActivityFilter, pagination *viewrepo.Pagination) ([]viewrepo.StakingAccountActivity, *viewrepo.PaginationResult, error)

func (*RDbCouncilNodeViewRepo) Search 

func (repo *RDbCouncilNodeViewRepo) Search(keyword string, pagination *viewrepo.Pagination) ([]viewrepo.CouncilNode, *viewrepo.PaginationResult, error)

func (*RDbCouncilNodeViewRepo) Stats 

func (repo *RDbCouncilNodeViewRepo) Stats() (*viewrepo.CouncilNodeStats, error)

type RDbRewardViewRepo 

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

func NewRDbRewardViewRepo 

func NewRDbRewardViewRepo(
	conn adapter.RDbConn,
	stmtBuilder sq.StatementBuilderType,
	typeConv adapter.RDbTypeConv,
) *RDbRewardViewRepo

func (*RDbRewardViewRepo) Total 

func (repo *RDbRewardViewRepo) Total() (*bignum.WBigInt, error)

func (*RDbRewardViewRepo) TotalMinted 

func (repo *RDbRewardViewRepo) TotalMinted() (*bignum.WBigInt, error)

type RDbStkaingAccountViewRepo 

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

func NewRDbStkaingAccountViewRepo 

func NewRDbStkaingAccountViewRepo(
	conn adapter.RDbConn,
	stmtBuilder sq.StatementBuilderType,
	typeConv adapter.RDbTypeConv,
) *RDbStkaingAccountViewRepo

func (*RDbStkaingAccountViewRepo) Search 

func (repo *RDbStkaingAccountViewRepo) Search(keyword string, pagination *viewrepo.Pagination) ([]viewrepo.StakingAccount, *viewrepo.PaginationResult, 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.