indexer

package

v1.9.18 Latest Latest Go to latest Published: Aug 14, 2025 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Taraxa-project/taraxa-indexer

Links

Open Source Insights

Documentation ¶

Index ¶

func MakeAndRun(client common.Client, s storage.Storage, c *common.Config, stats *chain.Stats, ...)
func MakeBlockContext(s storage.Storage, client common.Client, config *common.Config, ...) *blockContext
type Genesis
- func MakeGenesis(s storage.Storage, c common.Client, gen_obj common.GenesisObject, ...) *Genesis
type Indexer
- func NewIndexer(client common.Client, s storage.Storage, c *common.Config, stats *chain.Stats, ...) (i *Indexer)
type SyncQueue
- func MakeSyncQueue(start, end, queueLimit uint64, client common.Client) *SyncQueue

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func MakeAndRun ¶

func MakeAndRun(client common.Client, s storage.Storage, c *common.Config, stats *chain.Stats, retry_time time.Duration)

func MakeBlockContext ¶

func MakeBlockContext(s storage.Storage, client common.Client, config *common.Config, accounts *storage.AccountBalancesMap, dayStats *storage.DayStatsWithTimestamp) *blockContext

Types ¶

type Genesis ¶

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

func MakeGenesis ¶

func MakeGenesis(s storage.Storage, c common.Client, gen_obj common.GenesisObject, genesisHash storage.GenesisHash, accounts *storage.AccountBalancesMap, dayStats *storage.DayStatsWithTimestamp) *Genesis

type Indexer ¶

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

func NewIndexer ¶

func NewIndexer(client common.Client, s storage.Storage, c *common.Config, stats *chain.Stats, retry_time time.Duration) (i *Indexer)

type SyncQueue ¶ added in v1.5.4

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

func MakeSyncQueue ¶ added in v1.5.4

func MakeSyncQueue(start, end, queueLimit uint64, client common.Client) *SyncQueue

func (*SyncQueue) GetCurrent ¶ added in v1.5.4

func (sq *SyncQueue) GetCurrent() uint64

func (*SyncQueue) PopNext ¶ added in v1.5.4

func (sq *SyncQueue) PopNext() *chain.BlockData

func (*SyncQueue) Push ¶ added in v1.5.4

func (sq *SyncQueue) Push(bd *chain.BlockData)

func (*SyncQueue) RequestBlock ¶ added in v1.9.8

func (sq *SyncQueue) RequestBlock(number uint64)

func (*SyncQueue) Start ¶ added in v1.5.4

func (sq *SyncQueue) Start()

Source Files ¶

View all Source files

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