postgres

package
v0.0.0-...-cddd04e Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2020 License: ISC Imports: 27 Imported by: 0

README

postgres

  • TODO => Add docs

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrNonConsecutiveTicks = errors.New("postgres/exchanges: Non consecutive exchange ticks")
)

Functions

func Connect 

func Connect(host, port, user, pass, dbname string) (*sql.DB, error)

Connect opens a connection to a PostgreSQL database. The caller is responsible for calling Close() on the returned db when finished using it. The input host may be an IP address for TCP connection, or an absolute path to a UNIX domain socket. An empty string should be provided for UNIX sockets.

func DisableLog 

func DisableLog()

DisableLog disables all library log output. Logging output is disabled by default until UseLogger is called.

func RoundValue 

func RoundValue(input float64) string

func UnixTimeToString 

func UnixTimeToString(t int64) string

func UseLogger 

func UseLogger(logger slog.Logger)

UseLogger uses a specified Logger to output package logging info.

Types

type PgDb 

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

func NewPgDb 

func NewPgDb(host, port, user, pass, dbname string, debug bool) (*PgDb, error)

func (*PgDb) AddPowData 

func (pg *PgDb) AddPowData(ctx context.Context, data []pow.PowData) error

func (*PgDb) AddPowDataFromSync 

func (pg *PgDb) AddPowDataFromSync(ctx context.Context, data interface{}) error

func (*PgDb) AddVspSourceFromSync 

func (pg *PgDb) AddVspSourceFromSync(ctx context.Context, vspData interface{}) error

func (*PgDb) AddVspTicksFromSync 

func (pg *PgDb) AddVspTicksFromSync(ctx context.Context, tick datasync.VSPTickSyncDto) error

func (*PgDb) AllExchange 

func (pg *PgDb) AllExchange(ctx context.Context) (models.ExchangeSlice, error)

AllExchange fetches a slice of all exchange from the db

func (*PgDb) AllExchangeTicks 

func (pg *PgDb) AllExchangeTicks(ctx context.Context, currencyPair string, interval, offset, limit int) ([]ticks.TickDto, int64, error)

FetchExchangeTicks fetches a slice exchange ticks of the supplied exchange name

func (*PgDb) AllExchangeTicksCurrencyPair 

func (pg *PgDb) AllExchangeTicksCurrencyPair(ctx context.Context) ([]ticks.TickDtoCP, error)

func (*PgDb) AllExchangeTicksInterval 

func (pg *PgDb) AllExchangeTicksInterval(ctx context.Context) ([]ticks.TickDtoInterval, error)

func (PgDb) AllNodeContries 

func (pg PgDb) AllNodeContries(ctx context.Context) (countries []string, err error)

func (PgDb) AllNodeVersions 

func (pg PgDb) AllNodeVersions(ctx context.Context) (versions []string, err error)

func (*PgDb) AllVSPTicks 

func (pg *PgDb) AllVSPTicks(ctx context.Context, offset, limit int) ([]vsp.VSPTickDto, int64, error)

VSPTicks

func (PgDb) AttemptPeer 

func (pg PgDb) AttemptPeer(ctx context.Context, address string, now int64) error

func (PgDb) AverageLatency 

func (pg PgDb) AverageLatency(ctx context.Context, address string) (int, error)

func (*PgDb) BlockBinTableExits 

func (pg *PgDb) BlockBinTableExits() bool

func (*PgDb) BlockCount 

func (pg *PgDb) BlockCount(ctx context.Context) (int64, error)

func (*PgDb) BlockTableExits 

func (pg *PgDb) BlockTableExits() bool

func (PgDb) BlockTableName 

func (pg PgDb) BlockTableName() string

func (*PgDb) Blocks 

func (pg *PgDb) Blocks(ctx context.Context, offset int, limit int) ([]mempool.BlockDto, error)

func (*PgDb) BlocksWithoutVotes 

func (pg *PgDb) BlocksWithoutVotes(ctx context.Context, offset int, limit int) ([]mempool.BlockDto, error)

func (*PgDb) Close 

func (pg *PgDb) Close() error

func (*PgDb) CommunityChart 

func (pg *PgDb) CommunityChart(ctx context.Context, platform string, dataType string, filters map[string]string) (stats []commstats.ChartData, err error)

func (*PgDb) CountGithubStat 

func (pg *PgDb) CountGithubStat(ctx context.Context, repository string) (int64, error)

func (*PgDb) CountRedditStat 

func (pg *PgDb) CountRedditStat(ctx context.Context, subreddit string) (int64, error)

func (*PgDb) CountTwitterStat 

func (pg *PgDb) CountTwitterStat(ctx context.Context, handle string) (int64, error)

func (*PgDb) CountYoutubeStat 

func (pg *PgDb) CountYoutubeStat(ctx context.Context, channel string) (int64, error)

func (*PgDb) CreateBlockBinTable 

func (pg *PgDb) CreateBlockBinTable() error

createBlockBinTable

func (*PgDb) CreateBlockTable 

func (pg *PgDb) CreateBlockTable() error

block table

func (*PgDb) CreateExchangeTable 

func (pg *PgDb) CreateExchangeTable() error

func (*PgDb) CreateExchangeTickIndex 

func (pg *PgDb) CreateExchangeTickIndex() error

func (*PgDb) CreateExchangeTickTable 

func (pg *PgDb) CreateExchangeTickTable() error

func (*PgDb) CreateGithubTable 

func (pg *PgDb) CreateGithubTable() error

youtube table

func (*PgDb) CreateHeartbeatTable 

func (pg *PgDb) CreateHeartbeatTable() error

network peer

func (*PgDb) CreateMempoolDataTable 

func (pg *PgDb) CreateMempoolDataTable() error

func (*PgDb) CreateMempoolDayBinTable 

func (pg *PgDb) CreateMempoolDayBinTable() error

func (*PgDb) CreateNetworkNodeTable 

func (pg *PgDb) CreateNetworkNodeTable() error

network node

func (*PgDb) CreateNetworkSnapshotBinTable 

func (pg *PgDb) CreateNetworkSnapshotBinTable() error

network_snapshot_bin

func (*PgDb) CreateNetworkSnapshotTable 

func (pg *PgDb) CreateNetworkSnapshotTable() error

network snapshot

func (*PgDb) CreateNodeLocationTable 

func (pg *PgDb) CreateNodeLocationTable() error

node_location

func (*PgDb) CreateNodeVersoinTable 

func (pg *PgDb) CreateNodeVersoinTable() error

node_version

func (*PgDb) CreatePowBinTable 

func (pg *PgDb) CreatePowBinTable() error

func (*PgDb) CreatePowDataTable 

func (pg *PgDb) CreatePowDataTable() error

func (*PgDb) CreatePropagationTable 

func (pg *PgDb) CreatePropagationTable() error

func (*PgDb) CreateRedditTable 

func (pg *PgDb) CreateRedditTable() error

reddit table

func (*PgDb) CreateTwitterTable 

func (pg *PgDb) CreateTwitterTable() error

twitter table

func (*PgDb) CreateVSPInfoTables 

func (pg *PgDb) CreateVSPInfoTables() error

func (*PgDb) CreateVSPTickBinTable 

func (pg *PgDb) CreateVSPTickBinTable() error

func (*PgDb) CreateVSPTickIndex 

func (pg *PgDb) CreateVSPTickIndex() error

func (*PgDb) CreateVSPTickTables 

func (pg *PgDb) CreateVSPTickTables() error

func (*PgDb) CreateVoteReceiveTimeDeviationTable 

func (pg *PgDb) CreateVoteReceiveTimeDeviationTable() error

vote_receive_time_deviation table

func (*PgDb) CreateVoteTable 

func (pg *PgDb) CreateVoteTable() error

vote table

func (*PgDb) CreateYoutubeTable 

func (pg *PgDb) CreateYoutubeTable() error

youtube table

func (*PgDb) CurrencyPairByExchange 

func (pg *PgDb) CurrencyPairByExchange(ctx context.Context, exchangeName string) ([]ticks.TickDtoCP, error)

func (PgDb) DeleteSnapshot 

func (pg PgDb) DeleteSnapshot(ctx context.Context, timestamp int64)

func (*PgDb) DropAllTables 

func (pg *PgDb) DropAllTables() error

func (*PgDb) DropCacheTables 

func (pg *PgDb) DropCacheTables() error

func (*PgDb) ExchangeTableExits 

func (pg *PgDb) ExchangeTableExits() bool

func (*PgDb) ExchangeTableName 

func (pg *PgDb) ExchangeTableName() string

func (*PgDb) ExchangeTickCount 

func (pg *PgDb) ExchangeTickCount(ctx context.Context) (int64, error)

func (*PgDb) ExchangeTickTableExits 

func (pg *PgDb) ExchangeTickTableExits() bool

func (*PgDb) ExchangeTickTableName 

func (pg *PgDb) ExchangeTickTableName() string

func (*PgDb) ExchangeTicksChartData 

func (pg *PgDb) ExchangeTicksChartData(ctx context.Context, selectedTick string, currencyPair string, selectedInterval int, source string) ([]ticks.TickChartData, error)

func (*PgDb) FetchBlockForSync 

func (pg *PgDb) FetchBlockForSync(ctx context.Context, blockHeight int64, offtset int, limit int) ([]mempool.Block, int64, error)

func (*PgDb) FetchExchangeForSync 

func (pg *PgDb) FetchExchangeForSync(ctx context.Context, lastID int, skip, take int) ([]ticks.ExchangeData, int64, error)

func (*PgDb) FetchExchangeTicks 

func (pg *PgDb) FetchExchangeTicks(ctx context.Context, currencyPair, name string, interval, offset, limit int) ([]ticks.TickDto, int64, error)

FetchExchangeTicks fetches a slice exchange ticks of the supplied exchange name

func (*PgDb) FetchMempoolForSync 

func (pg *PgDb) FetchMempoolForSync(ctx context.Context, date time.Time, offtset int, limit int) ([]mempool.Mempool, int64, error)

func (*PgDb) FetchNodeLocations 

func (pg *PgDb) FetchNodeLocations(ctx context.Context, offset, limit int) ([]netsnapshot.CountryInfo, int64, error)

func (*PgDb) FetchNodeVersion 

func (pg *PgDb) FetchNodeVersion(ctx context.Context, offset, limit int) ([]netsnapshot.UserAgentInfo, int64, error)

func (*PgDb) FetchPowChartData 

func (pg *PgDb) FetchPowChartData(ctx context.Context, source string, dataType string) (records []pow.PowChartData, err error)

func (*PgDb) FetchPowData 

func (pg *PgDb) FetchPowData(ctx context.Context, offset, limit int) ([]pow.PowDataDto, int64, error)

func (*PgDb) FetchPowDataBySource 

func (pg *PgDb) FetchPowDataBySource(ctx context.Context, source string, offset, limit int) ([]pow.PowDataDto, int64, error)

func (*PgDb) FetchPowDataForSync 

func (pg *PgDb) FetchPowDataForSync(ctx context.Context, date int64, skip, take int) ([]pow.PowData, int64, error)

FetchPowDataForSync returns PoW data for the sync operation

func (*PgDb) FetchPowSourceData 

func (pg *PgDb) FetchPowSourceData(ctx context.Context) ([]pow.PowDataSource, error)

func (*PgDb) FetchVSPs 

func (pg *PgDb) FetchVSPs(ctx context.Context) ([]vsp.VSPDto, error)

func (*PgDb) FetchVoteForSync 

func (pg *PgDb) FetchVoteForSync(ctx context.Context, date time.Time, offtset int, limit int) ([]mempool.Vote, int64, error)

func (*PgDb) FetchVspSourcesForSync 

func (pg *PgDb) FetchVspSourcesForSync(ctx context.Context, lastID int64, skip, take int) ([]vsp.VSPDto, int64, error)

func (*PgDb) FetchVspTicksForSync 

func (pg *PgDb) FetchVspTicksForSync(ctx context.Context, lastID int64, skip, take int) ([]datasync.VSPTickSyncDto, int64, error)

VSPTicks

func (*PgDb) FilteredVSPTicks 

func (pg *PgDb) FilteredVSPTicks(ctx context.Context, vspName string, offset, limit int) ([]vsp.VSPTickDto, int64, error)

func (PgDb) FindNetworkSnapshot 

func (pg PgDb) FindNetworkSnapshot(ctx context.Context, timestamp int64) (*netsnapshot.SnapShot, error)

func (PgDb) GetAvailableNodes 

func (pg PgDb) GetAvailableNodes(ctx context.Context) ([]net.IP, error)

func (PgDb) GetIPLocation 

func (pg PgDb) GetIPLocation(ctx context.Context, ip string) (string, int, error)

func (*PgDb) GetPowDistinctDates 

func (pg *PgDb) GetPowDistinctDates(ctx context.Context, sources []string) ([]time.Time, error)

func (*PgDb) GithubStat 

func (pg *PgDb) GithubStat(ctx context.Context, repository string, offtset int, limit int) ([]commstats.Github, error)

func (*PgDb) GithubTableExits 

func (pg *PgDb) GithubTableExits() bool

func (*PgDb) HeartbeatTableExists 

func (pg *PgDb) HeartbeatTableExists() bool

func (*PgDb) LastCommStatEntry 

func (pg *PgDb) LastCommStatEntry() (entryTime time.Time)

func (*PgDb) LastEntry 

func (pg *PgDb) LastEntry(ctx context.Context, tableName string, receiver interface{}) error

func (*PgDb) LastExchangeEntryID 

func (pg *PgDb) LastExchangeEntryID() (id int64)

LastExchangeTickEntryTime

func (*PgDb) LastExchangeTickEntryTime 

func (pg *PgDb) LastExchangeTickEntryTime() (time time.Time)

LastExchangeTickEntryTime

func (*PgDb) LastMempoolBlockHeight 

func (pg *PgDb) LastMempoolBlockHeight() (height int64, err error)

func (*PgDb) LastMempoolTime 

func (pg *PgDb) LastMempoolTime() (entryTime time.Time, err error)

func (*PgDb) LastPowEntryTime 

func (pg *PgDb) LastPowEntryTime(source string) (time int64)

func (PgDb) LastSnapshot 

func (pg PgDb) LastSnapshot(ctx context.Context) (*netsnapshot.SnapShot, error)

func (PgDb) LastSnapshotTime 

func (pg PgDb) LastSnapshotTime(ctx context.Context) (timestamp int64)

func (*PgDb) LastVspTickEntryTime 

func (pg *PgDb) LastVspTickEntryTime() (time time.Time)

func (*PgDb) MempoolBinDataTableExits 

func (pg *PgDb) MempoolBinDataTableExits() bool

func (*PgDb) MempoolCount 

func (pg *PgDb) MempoolCount(ctx context.Context) (int64, error)

func (*PgDb) MempoolDataTableExits 

func (pg *PgDb) MempoolDataTableExits() bool

func (PgDb) MempoolTableName 

func (pg PgDb) MempoolTableName() string

func (*PgDb) Mempools 

func (pg *PgDb) Mempools(ctx context.Context, offtset int, limit int) ([]mempool.Dto, error)

func (*PgDb) NetworkNodeTableExists 

func (pg *PgDb) NetworkNodeTableExists() bool

func (PgDb) NetworkPeer 

func (pg PgDb) NetworkPeer(ctx context.Context, address string) (*netsnapshot.NetworkPeer, error)

func (PgDb) NetworkPeers 

func (pg PgDb) NetworkPeers(ctx context.Context, timestamp int64, q string, offset int, limit int) ([]netsnapshot.NetworkPeer, int64, error)

func (*PgDb) NetworkSnapshotBinTableExists 

func (pg *PgDb) NetworkSnapshotBinTableExists() bool

func (*PgDb) NetworkSnapshotTableExists 

func (pg *PgDb) NetworkSnapshotTableExists() bool

func (PgDb) NextSnapshot 

func (pg PgDb) NextSnapshot(ctx context.Context, timestamp int64) (*netsnapshot.SnapShot, error)

func (PgDb) NodeExists 

func (pg PgDb) NodeExists(ctx context.Context, address string) (bool, error)

func (*PgDb) NodeLocationTableExists 

func (pg *PgDb) NodeLocationTableExists() bool

func (*PgDb) NodeVersionTableExists 

func (pg *PgDb) NodeVersionTableExists() bool

func (PgDb) PeerCountByCountries 

func (pg PgDb) PeerCountByCountries(ctx context.Context, sources string, offset, limit int) ([]netsnapshot.CountryInfo, int64, error)

func (PgDb) PeerCountByIPVersion 

func (pg PgDb) PeerCountByIPVersion(ctx context.Context, timestamp int64, iPVersion int) (int64, error)

func (PgDb) PeerCountByUserAgents 

func (pg PgDb) PeerCountByUserAgents(ctx context.Context, sources string, offset, limit int) ([]netsnapshot.UserAgentInfo, int64, error)

func (*PgDb) PowBInTableExits 

func (pg *PgDb) PowBInTableExits() bool

func (*PgDb) PowCount 

func (pg *PgDb) PowCount(ctx context.Context) (int64, error)

func (*PgDb) PowDataTableExits 

func (pg *PgDb) PowDataTableExits() bool

func (*PgDb) PowTableName 

func (pg *PgDb) PowTableName() string

func (PgDb) PreviousSnapshot 

func (pg PgDb) PreviousSnapshot(ctx context.Context, timestamp int64) (*netsnapshot.SnapShot, error)

func (*PgDb) PropagationTableExists 

func (pg *PgDb) PropagationTableExists() bool

func (PgDb) RecordNodeConnectionFailure 

func (pg PgDb) RecordNodeConnectionFailure(ctx context.Context, address string, maxAllowedFailure int) error

RecordNodeConnectionFailure increase the number of failare for the specified node

The node will be marked as dead if the maxAllowedFailure is reached

func (*PgDb) RedditStats 

func (pg *PgDb) RedditStats(ctx context.Context, subreddit string, offtset int, limit int) ([]commstats.Reddit, error)

func (*PgDb) RedditTableExits 

func (pg *PgDb) RedditTableExits() bool

func (*PgDb) RegisterCharts 

func (pg *PgDb) RegisterCharts(charts *cache.Manager, syncSources []string, syncSourceDbProvider func(source string) (*PgDb, error))

func (*PgDb) RegisterExchange 

func (pg *PgDb) RegisterExchange(ctx context.Context, exchange ticks.ExchangeData) (time.Time, time.Time, time.Time, error)

func (*PgDb) SaveBlock 

func (pg *PgDb) SaveBlock(ctx context.Context, block mempool.Block) error

func (*PgDb) SaveBlockFromSync 

func (pg *PgDb) SaveBlockFromSync(ctx context.Context, block interface{}) error

func (*PgDb) SaveExchangeFromSync 

func (pg *PgDb) SaveExchangeFromSync(ctx context.Context, exchangeData interface{}) error

func (*PgDb) SaveExchangeTickFromSync 

func (pg *PgDb) SaveExchangeTickFromSync(ctx context.Context, tickData interface{}) error

func (PgDb) SaveHeartbeat 

func (pg PgDb) SaveHeartbeat(ctx context.Context, heartbeat netsnapshot.Heartbeat) error

func (PgDb) SaveNode 

func (pg PgDb) SaveNode(ctx context.Context, peer netsnapshot.NetworkPeer) error

SaveNode inserts the new node information. The node is marked as alive by default

func (PgDb) SaveSnapshot 

func (pg PgDb) SaveSnapshot(ctx context.Context, snapshot netsnapshot.SnapShot) error

func (*PgDb) SaveVote 

func (pg *PgDb) SaveVote(ctx context.Context, vote mempool.Vote) error

func (*PgDb) SaveVoteFromSync 

func (pg *PgDb) SaveVoteFromSync(ctx context.Context, voteData interface{}) error

func (PgDb) SeenNodesByTimestamp 

func (pg PgDb) SeenNodesByTimestamp(ctx context.Context) ([]netsnapshot.NodeCount, error)

func (PgDb) SnapshotCount 

func (pg PgDb) SnapshotCount(ctx context.Context) (int64, error)

func (PgDb) Snapshots 

func (pg PgDb) Snapshots(ctx context.Context, offset, limit int, forChart bool) ([]netsnapshot.SnapShot, int64, error)

func (PgDb) SnapshotsByTime 

func (pg PgDb) SnapshotsByTime(ctx context.Context, startDate int64, pageSize int) ([]netsnapshot.SnapShot, error)

func (*PgDb) StoreExchangeTicks 

func (pg *PgDb) StoreExchangeTicks(ctx context.Context, name string, interval int, pair string, ticks []ticks.Tick) (time.Time, error)

StoreExchangeTicks

func (*PgDb) StoreGithubStat 

func (pg *PgDb) StoreGithubStat(ctx context.Context, github commstats.Github) error

github

func (PgDb) StoreMempool 

func (pg PgDb) StoreMempool(ctx context.Context, mempoolDto mempool.Mempool) error

func (PgDb) StoreMempoolFromSync 

func (pg PgDb) StoreMempoolFromSync(ctx context.Context, mempoolDto interface{}) error

func (*PgDb) StoreRedditStat 

func (pg *PgDb) StoreRedditStat(ctx context.Context, stat commstats.Reddit) error

func (*PgDb) StoreTwitterStat 

func (pg *PgDb) StoreTwitterStat(ctx context.Context, twitter commstats.Twitter) error

twitter

func (*PgDb) StoreVSPs 

func (pg *PgDb) StoreVSPs(ctx context.Context, data vsp.Response) (int, []error)

StoreVSPs attempts to store the vsp responses by calling storeVspResponseG and returning a slice of errors

func (*PgDb) StoreYoutubeStat 

func (pg *PgDb) StoreYoutubeStat(ctx context.Context, youtube commstats.Youtube) error

youtube

func (*PgDb) TableNames 

func (pg *PgDb) TableNames() []string

func (*PgDb) TickIntervalsByExchangeAndPair 

func (pg *PgDb) TickIntervalsByExchangeAndPair(ctx context.Context, exchangeName string, currencyPair string) ([]ticks.TickDtoInterval, error)

func (PgDb) TotalPeerCount 

func (pg PgDb) TotalPeerCount(ctx context.Context, timestamp int64) (int64, error)

func (*PgDb) TwitterStats 

func (pg *PgDb) TwitterStats(ctx context.Context, handle string, offtset int, limit int) ([]commstats.Twitter, error)

func (*PgDb) TwitterTableExits 

func (pg *PgDb) TwitterTableExits() bool

func (*PgDb) UpdateBlockBinData 

func (pg *PgDb) UpdateBlockBinData(ctx context.Context) error

UpdateBlockBinData

func (PgDb) UpdateMempoolAggregateData 

func (pg PgDb) UpdateMempoolAggregateData(ctx context.Context) error

func (PgDb) UpdateNode 

func (pg PgDb) UpdateNode(ctx context.Context, peer netsnapshot.NetworkPeer) error

UpdateNode updates the node information in the database

It reset the node's failure count and marks it as alive

func (*PgDb) UpdateNodeLocation 

func (pg *PgDb) UpdateNodeLocation(ctx context.Context) error

func (*PgDb) UpdateNodeVersion 

func (pg *PgDb) UpdateNodeVersion(ctx context.Context) error

func (*PgDb) UpdatePowChart 

func (pg *PgDb) UpdatePowChart(ctx context.Context) error

func (PgDb) UpdatePropagationData 

func (pg PgDb) UpdatePropagationData(ctx context.Context) error

UpdatePropagationData

func (*PgDb) UpdateSnapshotNodesBin 

func (pg *PgDb) UpdateSnapshotNodesBin(ctx context.Context) error

func (*PgDb) UpdateVoteTimeDeviationData 

func (pg *PgDb) UpdateVoteTimeDeviationData(ctx context.Context) error

UpdateVoteTimeDeviationData

func (*PgDb) UpdateVspChart 

func (pg *PgDb) UpdateVspChart(ctx context.Context) error

func (*PgDb) UpdateVspDailyChart 

func (pg *PgDb) UpdateVspDailyChart(ctx context.Context) error

func (*PgDb) UpdateVspHourlyChart 

func (pg *PgDb) UpdateVspHourlyChart(ctx context.Context) error

func (*PgDb) VSPInfoTableExits 

func (pg *PgDb) VSPInfoTableExits() bool

func (*PgDb) VSPTickBinTableExits 

func (pg *PgDb) VSPTickBinTableExits() bool

func (*PgDb) VSPTickTableExits 

func (pg *PgDb) VSPTickTableExits() bool

func (*PgDb) VoteReceiveTimeDeviationTableExits 

func (pg *PgDb) VoteReceiveTimeDeviationTableExits() bool

func (*PgDb) VoteTableExits 

func (pg *PgDb) VoteTableExits() bool

func (PgDb) VoteTableName 

func (pg PgDb) VoteTableName() string

func (*PgDb) Votes 

func (pg *PgDb) Votes(ctx context.Context, offset int, limit int) ([]mempool.VoteDto, error)

func (*PgDb) VotesByBlock 

func (pg *PgDb) VotesByBlock(ctx context.Context, blockHash string) ([]mempool.VoteDto, error)

func (*PgDb) VotesCount 

func (pg *PgDb) VotesCount(ctx context.Context) (int64, error)

func (*PgDb) VspTableName 

func (pg *PgDb) VspTableName() string

func (*PgDb) VspTickCount 

func (pg *PgDb) VspTickCount(ctx context.Context) (int64, error)

func (*PgDb) VspTickTableName 

func (pg *PgDb) VspTickTableName() string

func (*PgDb) YoutubeStat 

func (pg *PgDb) YoutubeStat(ctx context.Context, channel string, offtset int, limit int) ([]commstats.Youtube, error)

func (*PgDb) YoutubeTableExits 

func (pg *PgDb) YoutubeTableExits() bool

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.