The main class of the fetcher service.

Hierarchy

Constructors

Properties

blockchainId: Blockchain = Blockchain.Ethereum
broker: ServiceBroker
entityCacheDAL: EntityStorage<EthereumRawLog>
ethereumClient: EthereumClient
pendingEntities: PendingWorkPool<string[]>
pendingEntitiesCache: PendingWorkPool<string[]>
pendingEntitiesFetch: PendingWorkPool<string[]>
pendingEntityCacheDAL: PendingEntityStorage
pendingEntityDAL: PendingEntityStorage
pendingEntityFetchDAL: PendingEntityStorage
pendingLogCacheDAL: PendingEntityStorage
pendingLogDAL: PendingEntityStorage
pendingLogFetchDAL: PendingEntityStorage
throughput: number
throughputInit: number
type: IndexableEntityType

Methods

  • Used to improve performance.

    Parameters

    • count: number

      Entitys counter.

    Returns void

  • Delete the cached entity.

    Parameters

    • args: DelEntityRequestArgs

      The txn ids to delete the cache for.

    Returns Promise<void>

  • Emit entities to the parser.

    Parameters

    Returns Promise<void>

  • Fetch entities from an account by ids.

    Parameters

    • args: FetchEntitiesByIdRequestArgs

      Entity ids.

    Returns Promise<void>

  • Parameters

    • works: PendingWork<string[]>[]
    • Optional isRetry: boolean

    Returns Promise<[RawEntityMsg<EthereumRawLog>[], PendingWork<string[]>[]]>

  • Returns the fetch status of certain txn signatures.

    Parameters

    • args: CheckEntityRequestArgs

    Returns Promise<EntityState[]>

  • Returns Promise<EntityFetcherState>

  • Fetch entities from ids.

    Parameters

    • works: PendingWork<string[]>[]

      Entity ids with extra properties as time and payload.

    Returns Promise<void>

  • Parameters

    • works: PendingWork<string[]>[]

    Returns Promise<void>

  • Parameters

    • works: PendingWork<string[]>[]

    Returns Promise<number | void>

  • Parameters

    • Rest ...msgs: any[]

    Returns void

  • Returns Promise<void>

  • Returns Promise<void>

Generated using TypeDoc