indexer

Documentation

Index

• func MakeAndRun(url string, s storage.Storage, c *common.Config)
• func MakeBlockContext(s storage.Storage, client chain.Client, config *common.Config) *blockContext
• type Genesis
  • func MakeGenesis(s storage.Storage, c chain.Client, gen_obj chain.GenesisObject, ...) *Genesis
• type Indexer
  • func NewIndexer(url string, s storage.Storage, c *common.Config) (i *Indexer)
• type SyncQueue
  • func MakeSyncQueue(start, queueLimit uint64, client chain.Client) *SyncQueue
  • func (sq *SyncQueue) GetCurrent() uint64
  • func (sq *SyncQueue) PopNext() *chain.BlockData
  • func (sq *SyncQueue) Push(bd *chain.BlockData)
  • func (sq *SyncQueue) Start()

Functions

func MakeAndRun

func MakeAndRun(url string, s storage.Storage, c *common.Config)

func MakeBlockContext

func MakeBlockContext(s storage.Storage, client chain.Client, config *common.Config) *blockContext

Types

type Genesis

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

func MakeGenesis

func MakeGenesis(s storage.Storage, c chain.Client, gen_obj chain.GenesisObject, genesisHash storage.GenesisHash) *Genesis

type Indexer

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

func NewIndexer

func NewIndexer(url string, s storage.Storage, c *common.Config) (i *Indexer)

type SyncQueue

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

func MakeSyncQueue

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

func (*SyncQueue) GetCurrent

func (sq *SyncQueue) GetCurrent() uint64

func (*SyncQueue) PopNext

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

func (*SyncQueue) Push

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

func (*SyncQueue) Start

func (sq *SyncQueue) Start()