etlserver

func (*ETLService) ChainID ¶

func (s *ETLService) ChainID() string

ChainID returns the chain ID from the core service.

func (*ETLService) GetBlockPubsub ¶

func (s *ETLService) GetBlockPubsub() *etl.BlockPubsub

GetBlockPubsub returns the block pubsub instance.

func (*ETLService) GetBlocks ¶

func (s *ETLService) GetBlocks(context.Context, *connect.Request[v1.GetBlocksRequest]) (*connect.Response[v1.GetBlocksResponse], error)

func (*ETLService) GetDB ¶

func (s *ETLService) GetDB() *db.Queries

GetDB returns the ETL database queries.

func (*ETLService) GetHealth ¶

func (s *ETLService) GetHealth(context.Context, *connect.Request[v1.GetHealthRequest]) (*connect.Response[v1.GetHealthResponse], error)

func (*ETLService) GetLocation ¶

func (s *ETLService) GetLocation(context.Context, *connect.Request[v1.GetLocationRequest]) (*connect.Response[v1.GetLocationResponse], error)

func (*ETLService) GetLocationDB ¶

func (s *ETLService) GetLocationDB() *location.LocationService

GetLocationDB returns the location service instance.

func (*ETLService) GetManageEntities ¶

func (s *ETLService) GetManageEntities(context.Context, *connect.Request[v1.GetManageEntitiesRequest]) (*connect.Response[v1.GetManageEntitiesResponse], error)

func (*ETLService) GetPlayPubsub ¶

func (s *ETLService) GetPlayPubsub() *etl.PlayPubsub

GetPlayPubsub returns the play pubsub instance.

func (*ETLService) GetPlays ¶

func (s *ETLService) GetPlays(context.Context, *connect.Request[v1.GetPlaysRequest]) (*connect.Response[v1.GetPlaysResponse], error)

func (*ETLService) GetTransactions ¶

func (s *ETLService) GetTransactions(context.Context, *connect.Request[v1.GetTransactionsRequest]) (*connect.Response[v1.GetTransactionsResponse], error)

func (*ETLService) GetValidators ¶

func (s *ETLService) GetValidators(context.Context, *connect.Request[v1.GetValidatorsRequest]) (*connect.Response[v1.GetValidatorsResponse], error)

func (*ETLService) Indexer ¶

func (s *ETLService) Indexer() *etl.Indexer

Indexer returns the underlying indexer for direct access.

func (*ETLService) Ping ¶

func (s *ETLService) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)

func (*ETLService) Run ¶

func (s *ETLService) Run() error

Run runs the indexer. Blocks until done or error.

func (*ETLService) SetRunDownMigrations ¶

func (s *ETLService) SetRunDownMigrations(v bool)

SetRunDownMigrations delegates to the indexer.