storage

package
v0.0.0-...-95106c8 Latest Latest
Warning

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

Go to latest
Published: May 23, 2019 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var EOD = time.Date(time.Now().Year(), time.Now().Month(), time.Now().Day(), 23, 59, 59, 0, time.UTC)

Functions

This section is empty.

Types

type Config

type Config struct {
	User     string `json:"user"`
	Password string `json:"password"`
	Database string `json:"database"`
	Address  string `json:"address"`
}

type MongoDB

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

func NewConnection

func NewConnection(cfg *Config) (*MongoDB, error)

func (*MongoDB) AddBlock

func (m *MongoDB) AddBlock(b *models.Block) error

func (*MongoDB) AddForkedBlock

func (m *MongoDB) AddForkedBlock(b *models.Block) error

func (*MongoDB) AddLineChart

func (m *MongoDB) AddLineChart(t *models.LineChart) error

func (*MongoDB) AddMLChart

func (m *MongoDB) AddMLChart(t *models.MLineChart) error

func (*MongoDB) AddTokenTransfer

func (m *MongoDB) AddTokenTransfer(tt *models.TokenTransfer) error

func (*MongoDB) AddTransaction

func (m *MongoDB) AddTransaction(tx *models.Transaction) error

func (*MongoDB) AddUncle

func (m *MongoDB) AddUncle(u *models.Uncle) error

func (*MongoDB) BlockByHash

func (m *MongoDB) BlockByHash(hash string) (models.Block, error)

func (*MongoDB) BlockByNumber

func (m *MongoDB) BlockByNumber(number uint64) (models.Block, error)

func (*MongoDB) BlockTransactions

func (m *MongoDB) BlockTransactions(number uint64) ([]models.Transaction, error)

func (*MongoDB) BlocksIter

func (m *MongoDB) BlocksIter(blockno uint64) *mgo.Iter

func (*MongoDB) ChartData

func (m *MongoDB) ChartData(chart string, limit int64) (models.LineChart, error)

func (*MongoDB) ChartDataML

func (m *MongoDB) ChartDataML(chart string, limit int64, miner string) (models.LineChart, error)

func (*MongoDB) ForkedBlockByNumber

func (m *MongoDB) ForkedBlockByNumber(number uint64) (models.Block, error)

func (*MongoDB) GetBlock

func (m *MongoDB) GetBlock(height uint64) (*models.Block, error)

func (*MongoDB) GetBlocks

func (m *MongoDB) GetBlocks(days int) *mgo.Iter

func (*MongoDB) GetTokenTransfers

func (m *MongoDB) GetTokenTransfers(contractAddress, address string, after int64) *mgo.Iter

func (*MongoDB) GetTxnCounts

func (m *MongoDB) GetTxnCounts(days int) *mgo.Iter

func (*MongoDB) IndexHead

func (m *MongoDB) IndexHead() [1]uint64

func (*MongoDB) Init

func (m *MongoDB) Init()

func (*MongoDB) InitIndex

func (m *MongoDB) InitIndex()

func (*MongoDB) IsFirstRun

func (m *MongoDB) IsFirstRun() bool

func (*MongoDB) IsInDB

func (m *MongoDB) IsInDB(height uint64, hash string) (bool, bool)

func (*MongoDB) IsPresent

func (m *MongoDB) IsPresent(height uint64) bool

func (*MongoDB) LatestBlock

func (m *MongoDB) LatestBlock() (models.Block, error)

func (*MongoDB) LatestBlocks

func (m *MongoDB) LatestBlocks(limit int) ([]models.Block, error)

func (*MongoDB) LatestForkedBlocks

func (m *MongoDB) LatestForkedBlocks(limit int) ([]models.Block, error)

func (*MongoDB) LatestTokenTransfers

func (m *MongoDB) LatestTokenTransfers(limit int) ([]models.TokenTransfer, error)

func (*MongoDB) LatestTokenTransfersByAccount

func (m *MongoDB) LatestTokenTransfersByAccount(hash string) ([]models.TokenTransfer, error)

func (*MongoDB) LatestTransactions

func (m *MongoDB) LatestTransactions(limit int) ([]models.Transaction, error)

func (*MongoDB) LatestTransactionsByAccount

func (m *MongoDB) LatestTransactionsByAccount(hash string) ([]models.Transaction, error)

func (*MongoDB) LatestTransfersByToken

func (m *MongoDB) LatestTransfersByToken(hash string) ([]models.TokenTransfer, error)

func (*MongoDB) LatestUncles

func (m *MongoDB) LatestUncles(limit int) ([]models.Uncle, error)

func (*MongoDB) Ping

func (m *MongoDB) Ping() error

func (*MongoDB) Purge

func (m *MongoDB) Purge(height uint64)

func (*MongoDB) Store

func (m *MongoDB) Store() (models.Store, error)

func (*MongoDB) SupplyObject

func (m *MongoDB) SupplyObject(symbol string) (models.Store, error)

func (*MongoDB) TokenTransferByAccountCount

func (m *MongoDB) TokenTransferByAccountCount(token string, account string) (int, error)

func (*MongoDB) TokenTransferCount

func (m *MongoDB) TokenTransferCount(hash string) (int, error)

func (*MongoDB) TokenTransferCountByContract

func (m *MongoDB) TokenTransferCountByContract(hash string) (int, error)

func (*MongoDB) TokenTransfersByAccount

func (m *MongoDB) TokenTransfersByAccount(token string, account string) ([]models.TokenTransfer, error)

func (*MongoDB) TotalBlockCount

func (m *MongoDB) TotalBlockCount() (int, error)

func (*MongoDB) TotalTxnCount

func (m *MongoDB) TotalTxnCount() (int, error)

func (*MongoDB) TotalUncleCount

func (m *MongoDB) TotalUncleCount() (int, error)

func (*MongoDB) TransactionByContractAddress

func (m *MongoDB) TransactionByContractAddress(hash string) (models.Transaction, error)

func (*MongoDB) TransactionByHash

func (m *MongoDB) TransactionByHash(hash string) (models.Transaction, error)

func (*MongoDB) TxnCount

func (m *MongoDB) TxnCount(hash string) (int, error)

func (*MongoDB) UncleByHash

func (m *MongoDB) UncleByHash(hash string) (models.Uncle, error)

func (*MongoDB) UpdateStore

func (m *MongoDB) UpdateStore(latestBlock *models.Block, synctype string) error

func (*MongoDB) UpdateSupply

func (m *MongoDB) UpdateSupply(ticker string, new *models.Store) error

Jump to

Keyboard shortcuts

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