Framework Package

Contains all high-level abstractions for building multithreaded indexers on Aleph.

TODO

  • Improve stats calculation performance caching already processed events for larger time frames. For example if we only configure just one big time frame like "Year" without configuring others smaller than it, we will reprocess all the events in the last year for each new incoming event
  • Change all time ranges bounds calculations to [inclusive left bound, exclusive right bound), except for databases in which both bound should be inclusive.
  • Allow to pass a custom stats schema to the graphQL base class
  • Implement a new option in the stats class for calculating accumulated values in time series
  • Implement a broadcasting algorithm for sharing history backups between fetcher instances
  • Allow to include custom schemas on the parser, from the development side

References

Enumerations

Classes

Interfaces

Type Aliases

APISchemaConfig AccountAggregatorFnArgs AccountDateRange AccountEntityFetcherMainState AccountEntityHistoryFetcherState AccountEntityHistoryState AccountEntityHistoryStorage AccountEntityHistoryStorageEntity AccountEntityIndexerState AccountEventsFilters AccountIndexerConfigWithMeta AccountIndexerEntityRequestArgs AccountIndexerLogRequestArgs AccountIndexerRequestArgs AccountIndexerState AccountIndexerStateRequestArgs AccountIndexerTransactionRequestArgs AccountSlotRange AccountState AccountStateState AccountStateStorage AccountStats AccountStatsFilters AccountTimeSeriesStats AccountTimeSeriesStatsConfig AddAccountEntityRequestArgs BaseFetcherJobRunnerOptions BaseFetcherJobState BaseFetcherJobStates BaseFetcherPaginationResponse BaseFetcherState BlockchainFetcherClientFactory BlockchainFetcherFactory BlockchainIndexerClientFactory BlockchainIndexerFactory BlockchainMainDomainFactory BlockchainParserClientFactory BlockchainParserFactory BlockchainRequestArgs BlockchainWorkerDomainFactory CheckEntityRequestArgs DelAccountEntityRequestArgs DelAccountIndexerRequestArgs DelEntityRequestArgs EntityDateRangeResponse EntityFetcherState EntityIndexerHandler EntityIndexerState EntityIndexerStateStorage EntityParsedResponse EntityRequest EntityRequestDateRange EntityRequestId EntityRequestIncomingEntityStorage EntityRequestParams EntityRequestPendingEntity EntityRequestPendingEntityStorage EntityRequestResponse EntityRequestResponseStorage EntityRequestStorage EntitySignatureResponse EntityState EventBase FetchAccountEntitiesByDateRequestArgs FetchEntitiesByIdRequestArgs FetcherAccountEntityTypeRequestArgs FetcherAccountPartitionRequestArgs FetcherCommonDomainContext FetcherInstanceDomainContext FetcherJobRunnerHandleFetchResult FetcherJobRunnerUpdateCursorResult FetcherMainDomainContext FetcherPartitionRequestArgs FetcherState FetcherStateLevelStorageOptions FetcherStateRequestArgs GetAccountEntityStateRequestArgs GetAccountIndexingEntityStateRequestArgs GetEntityPendingRequestsRequestArgs IdRange IndexerAccountPartitionRequestArgs IndexerCommonDomainContext IndexerConfig IndexerDomainContext IndexerIdRequestArgs IndexerIndexerPartitionRequestArgs IndexerMainDomainConfig IndexerMainDomainContext IndexerMainDomainI IndexerMainDomainWithDiscovery IndexerMainDomainWithStats IndexerWorkerDomainI IndexerWorkerDomainWithStats InputStreamFactoryFnArgs InvokeBlockchainMethodRequestArgs InvokeMethodRequestArgs ParseEntityRequestArgs ParsedEntity ParsedEntityMsg ParserContext PendingAccountStorage PendingEntityStorage PrevValueFactoryFnArgs RawEntity RawEntityMsg RawEntityStorage StatsState StatsStateStorage StatsTimeSeries StatsTimeSeriesStorage TimeSeries TimeSeriesAggregatorFnArgs TimeSeriesItem TimeSeriesStatsConfig TypedValue

Variables

Functions

References

Renames and re-exports TimeInfo

Generated using TypeDoc