Documentation
¶
Index ¶
- func ApplyParameters(query string, params ...interface{}) string
- func IndexGenesis(cfg *config.Config, db *sql.DB, indexers []Indexer, mut *sync.RWMutex) error
- func ProcessDataFeed(csConsumer transports.Consumer, txFeed *txfeed.TxFeed, db *sql.DB, ...)
- type BlockIndexer
- type HealthCheck
- type Indexer
- type LogIndexer
- type TxIndexer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ApplyParameters ¶
applyParameters applies a set of parameters into a SQL statement in a manner that will be safe for execution. Note that this should only be used in the context of blocks, transactions, and logs - beyond the datatypes used in those datatypes, safety is not guaranteed.
func IndexGenesis ¶
func ProcessDataFeed ¶
Types ¶
type BlockIndexer ¶
type BlockIndexer struct {
// contains filtered or unexported fields
}
func (*BlockIndexer) Index ¶
func (indexer *BlockIndexer) Index(pb *delivery.PendingBatch) ([]string, error)
type HealthCheck ¶ added in v1.0.6
type HealthCheck struct {
// contains filtered or unexported fields
}
func (*HealthCheck) Healthy ¶ added in v1.0.6
func (hc *HealthCheck) Healthy() rpc.HealthStatus
type Indexer ¶
type Indexer interface {
Index(*delivery.PendingBatch) ([]string, error)
}
func NewBlockIndexer ¶
func NewLogIndexer ¶
func NewTxIndexer ¶
type LogIndexer ¶
type LogIndexer struct {
// contains filtered or unexported fields
}
func (*LogIndexer) Index ¶
func (indexer *LogIndexer) Index(pb *delivery.PendingBatch) ([]string, error)
Source Files
Click to show internal directories.
Click to hide internal directories.