indexer

Documentation

Index

• func Init(environment string)
• func SetupRabbitMQ(cnfg config.Config) (*amqp.Channel, error)
• type Indexer
  • func NewIndexer(str db.Store, cli starknet.Client, rs rest.Client, cnfg config.Config, ...) *Indexer
  • func (ix *Indexer) CheckFees()
  • func (ix *Indexer) GetEvents(from uint64, to rpc.BlockHashAndNumberOutput) error
  • func (ix *Indexer) ListenBlocks()
  • func (ix *Indexer) ProcessEvents()
  • func (ix *Indexer) PublishRmqMsg(msg []byte) error
  • func (ix *Indexer) QueryPrices()
  • func (ix *Indexer) UpdateByFns(block uint64)
  • func (ix *Indexer) UpdateByFnsAll(block uint64)

Functions

func Init

func Init(environment string)

func SetupRabbitMQ

func SetupRabbitMQ(cnfg config.Config) (*amqp.Channel, error)

Types

type Indexer

type Indexer struct {
	Store       db.Store
	Client      starknet.Client
	Rest        rest.Client
	Config      config.Config
	RabbitMQ    *amqp.Channel
	LastQueried *status
	Scheduler   *gocron.Scheduler
}

func NewIndexer

func NewIndexer(str db.Store, cli starknet.Client, rs rest.Client, cnfg config.Config, rmq *amqp.Channel) *Indexer

func (*Indexer) CheckFees

func (ix *Indexer) CheckFees()

func (*Indexer) GetEvents

func (ix *Indexer) GetEvents(from uint64, to rpc.BlockHashAndNumberOutput) error

func (*Indexer) ListenBlocks

func (ix *Indexer) ListenBlocks()

func (*Indexer) ProcessEvents

func (ix *Indexer) ProcessEvents()

func (*Indexer) PublishRmqMsg

func (ix *Indexer) PublishRmqMsg(msg []byte) error

func (*Indexer) QueryPrices

func (ix *Indexer) QueryPrices()

func (*Indexer) UpdateByFns

func (ix *Indexer) UpdateByFns(block uint64)

func (*Indexer) UpdateByFnsAll

func (ix *Indexer) UpdateByFnsAll(block uint64)