Class GlobalProcessor

constructor

• new GlobalProcessor(config: Omit<BindOptions, "address">): GlobalProcessor

  Parameters

  • config: Omit<BindOptions, "address">

  Returns GlobalProcessor

blockHandlers

config

eventHandlers

traceHandlers

transactionHandler

getChainId

• getChainId(): EthChainId

  Returns EthChainId

onBlockInterval

• onBlockInterval(
      handler: (block: RichBlock, ctx: GlobalContext) => PromiseOrVoid,
      blockInterval?: number,
      backfillBlockInterval?: number,
      handlerOptions?: HandlerOptions<EthFetchConfig, RichBlock>,
      preprocessHandler?: (
          block: RichBlock,
          ctx: GlobalContext,
          preprocessStore: { [k: string]: any },
      ) => Promise<PreprocessResult>,
  ): this

  Parameters

  • handler: (block: RichBlock, ctx: GlobalContext) => PromiseOrVoid
  • blockInterval: number = 250
  • backfillBlockInterval: number = 1000
  • OptionalhandlerOptions: HandlerOptions<EthFetchConfig, RichBlock>
  • preprocessHandler: (
        block: RichBlock,
        ctx: GlobalContext,
        preprocessStore: { [k: string]: any },
    ) => Promise<PreprocessResult> = defaultPreprocessHandler

  Returns this

onEvent

• onEvent(
      handler: (rawLog: LogParams, ctx: GlobalContext) => PromiseOrVoid,
      filter?: AddressOrTypeEventFilter | AddressOrTypeEventFilter[],
      handlerOptions?: HandlerOptions<EthFetchConfig, TypedEvent<any, any>>,
  ): this

  Parameters

  • handler: (rawLog: LogParams, ctx: GlobalContext) => PromiseOrVoid
  • Optionalfilter: AddressOrTypeEventFilter | AddressOrTypeEventFilter[]
  • OptionalhandlerOptions: HandlerOptions<EthFetchConfig, TypedEvent<any, any>>

  Returns this

onInterval

• onInterval(
      handler: (block: RichBlock, ctx: GlobalContext) => PromiseOrVoid,
      timeInterval: undefined | HandleInterval,
      blockInterval: undefined | HandleInterval,
      handlerOptions?: HandlerOptions<EthFetchConfig, RichBlock>,
      preprocessHandler?: (
          block: RichBlock,
          ctx: GlobalContext,
          preprocessStore: { [k: string]: any },
      ) => Promise<PreprocessResult>,
  ): this

  Parameters

  • handler: (block: RichBlock, ctx: GlobalContext) => PromiseOrVoid
  • timeInterval: undefined | HandleInterval
  • blockInterval: undefined | HandleInterval
  • OptionalhandlerOptions: HandlerOptions<EthFetchConfig, RichBlock>
  • preprocessHandler: (
        block: RichBlock,
        ctx: GlobalContext,
        preprocessStore: { [k: string]: any },
    ) => Promise<PreprocessResult> = defaultPreprocessHandler

  Returns this

onTimeInterval

• onTimeInterval(
      handler: (block: RichBlock, ctx: GlobalContext) => PromiseOrVoid,
      timeIntervalInMinutes?: number,
      backfillTimeIntervalInMinutes?: number,
      handlerOptions?: HandlerOptions<EthFetchConfig, RichBlock>,
      preprocessHandler?: (
          block: RichBlock,
          ctx: GlobalContext,
          preprocessStore: { [k: string]: any },
      ) => Promise<PreprocessResult>,
  ): this

  Parameters

  • handler: (block: RichBlock, ctx: GlobalContext) => PromiseOrVoid
  • timeIntervalInMinutes: number = 60
  • backfillTimeIntervalInMinutes: number = 240
  • OptionalhandlerOptions: HandlerOptions<EthFetchConfig, RichBlock>
  • preprocessHandler: (
        block: RichBlock,
        ctx: GlobalContext,
        preprocessStore: { [k: string]: any },
    ) => Promise<PreprocessResult> = defaultPreprocessHandler

  Returns this

onTrace

• onTrace(
      signatures: string | string[],
      handler: (trace: Trace, ctx: GlobalContext) => PromiseOrVoid,
      handlerOptions?: HandlerOptions<EthFetchConfig, Trace>,
      preprocessHandler?: (
          trace: Trace,
          ctx: GlobalContext,
          preprocessStore: { [k: string]: any },
      ) => Promise<PreprocessResult>,
  ): this

  Parameters

  • signatures: string | string[]
  • handler: (trace: Trace, ctx: GlobalContext) => PromiseOrVoid
  • OptionalhandlerOptions: HandlerOptions<EthFetchConfig, Trace>
  • preprocessHandler: (
        trace: Trace,
        ctx: GlobalContext,
        preprocessStore: { [k: string]: any },
    ) => Promise<PreprocessResult> = defaultPreprocessHandler

  Returns this

onTransaction

• onTransaction(
      handler: (
          transaction: TransactionResponseParams,
          ctx: GlobalContext,
      ) => PromiseOrVoid,
      handlerOptions?: HandlerOptions<EthFetchConfig, TransactionResponseParams>,
      preprocessHandler?: (
          transaction: TransactionResponseParams,
          ctx: GlobalContext,
          preprocessStore: { [k: string]: any },
      ) => Promise<PreprocessResult>,
  ): this

  Parameters

  • handler: (transaction: TransactionResponseParams, ctx: GlobalContext) => PromiseOrVoid
  • OptionalhandlerOptions: HandlerOptions<EthFetchConfig, TransactionResponseParams>
  • preprocessHandler: (
        transaction: TransactionResponseParams,
        ctx: GlobalContext,
        preprocessStore: { [k: string]: any },
    ) => Promise<PreprocessResult> = defaultPreprocessHandler

  Returns this

Staticbind

• bind(config: Omit<BindOptions, "address">): GlobalProcessor

  Parameters

  • config: Omit<BindOptions, "address">

  Returns GlobalProcessor