Versions in this module Expand all Collapse all v1 v1.2.4 Mar 13, 2026 Changes in this version + type ETLService struct + func NewETLService(indexer *etl.Indexer, locationDB *location.LocationService, logger *zap.Logger) *ETLService + func (s *ETLService) ChainID() string + func (s *ETLService) GetBlockPubsub() *etl.BlockPubsub + func (s *ETLService) GetBlocks(context.Context, *connect.Request[v1.GetBlocksRequest]) (*connect.Response[v1.GetBlocksResponse], error) + func (s *ETLService) GetDB() *db.Queries + func (s *ETLService) GetHealth(context.Context, *connect.Request[v1.GetHealthRequest]) (*connect.Response[v1.GetHealthResponse], error) + func (s *ETLService) GetLocation(context.Context, *connect.Request[v1.GetLocationRequest]) (*connect.Response[v1.GetLocationResponse], error) + func (s *ETLService) GetLocationDB() *location.LocationService + func (s *ETLService) GetManageEntities(context.Context, *connect.Request[v1.GetManageEntitiesRequest]) (*connect.Response[v1.GetManageEntitiesResponse], error) + func (s *ETLService) GetPlayPubsub() *etl.PlayPubsub + func (s *ETLService) GetPlays(context.Context, *connect.Request[v1.GetPlaysRequest]) (*connect.Response[v1.GetPlaysResponse], error) + func (s *ETLService) GetTransactions(context.Context, *connect.Request[v1.GetTransactionsRequest]) (*connect.Response[v1.GetTransactionsResponse], error) + func (s *ETLService) GetValidators(context.Context, *connect.Request[v1.GetValidatorsRequest]) (*connect.Response[v1.GetValidatorsResponse], error) + func (s *ETLService) Indexer() *etl.Indexer + func (s *ETLService) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) + func (s *ETLService) Run() error + func (s *ETLService) SetRunDownMigrations(v bool)
Go to main page