chain_indexer

type ChainIndexerChain interface {
	// GetCurrentHeader retrieves the latest locally known header.
	GetCurrentHeader() *types.BlockHeader

	// NewBlockFeed return feed to subscribe new head header notifications.
	NewBlockFeed() *event.Feed
}

type ChainIndexerConfig struct {
	Enable      bool          `json:"enable"`
	SectionSize uint64        `json:"sectionsize"` // Number of blocks in a single chain segment to process
	ConfirmsReq uint64        `json:"confirmsreq"` // Number of confirmations before processing a completed segment
	Throttling  time.Duration `json:"throttling"`  // Disk throttling to prevent a heavy upgrade from hogging resources
}

type ChainIndexerService struct {
	DatabaseService *database.DatabaseService   `service:"database"`
	ChainService    chain.ChainServiceInterface `service:"chain"`
	Config          *ChainIndexerConfig
	// contains filtered or unexported fields
}

type ChainIndexerServiceInterface interface {
	app.Service
	BloomStatus() (uint64, uint64)
	GetConfig() *ChainIndexerConfig
	GetIndexerStore() *ChainIndexerStore
}

type ChainIndexerStore struct {
	dbinterface.KeyValueStore
	// contains filtered or unexported fields
}