Documentation / @etherfold/browser / createIndexerState
Function: createIndexerState()
createIndexerState<
ABI,ProcessResultType,ProcessorConfig>(processor,options?):object
Defined in: browser/src/IndexerState.ts:59
Type Parameters
ABI
ABI extends Abi
ProcessResultType
ProcessResultType
ProcessorConfig
ProcessorConfig = undefined
Parameters
processor
EventProcessorWithInitialState<ABI, ProcessResultType, ProcessorConfig>
options?
catchupThreshold?
number
createIndexer?
(provider, processor, source, config) => EthereumIndexer<ABI, ProcessResultType>
keepState?
KeepState<ABI, ProcessResultType, unknown, ProcessorConfig>
keepStream?
ExistingStream<ABI>
logRequests?
boolean
trackNumRequests?
boolean
Returns
object
dispose
dispose: () =>
void
Returns
void
indexMore
indexMore: () =>
Promise<LastSync<ABI>>
Returns
Promise<LastSync<ABI>>
indexMoreAndCatchupIfNeeded
indexMoreAndCatchupIfNeeded: () =>
Promise<LastSync<ABI>>
Returns
Promise<LastSync<ABI>>
indexToLatest
indexToLatest: () =>
Promise<LastSync<ABI>>
Returns
Promise<LastSync<ABI>>
init
init:
InitFunction<ABI,ProcessorConfig>
reset
reset: () =>
Promise<void>
Returns
Promise<void>
startAutoIndexing
startAutoIndexing: (
intervalInSeconds) =>Promise<boolean>
Parameters
intervalInSeconds?
number = 4
Returns
Promise<boolean>
state
state:
object
state.subscribe
subscribe: (
this,run,invalidate?) =>Unsubscriber=readableState.subscribe
Subscribe on value changes.
Parameters
this
void
run
Subscriber<ProcessResultType>
subscription callback
invalidate?
Invalidator<ProcessResultType>
cleanup callback
Returns
Unsubscriber
state.$state
Get Signature
get $state():
ProcessResultType
Defined in: browser/src/IndexerState.ts:455
Returns
ProcessResultType
status
status:
object
status.subscribe
subscribe: (
this,run,invalidate?) =>Unsubscriber=readableStatus.subscribe
Subscribe on value changes.
Parameters
this
void
run
Subscriber<StatusState>
subscription callback
invalidate?
Invalidator<StatusState>
cleanup callback
Returns
Unsubscriber
status.$state
Get Signature
get $state():
StatusState
Defined in: browser/src/IndexerState.ts:461
Returns
stopAutoIndexing
stopAutoIndexing: () =>
boolean
Returns
boolean
syncing
syncing:
object
syncing.subscribe
subscribe: (
this,run,invalidate?) =>Unsubscriber=readableSyncing.subscribe
Subscribe on value changes.
Parameters
this
void
run
Subscriber<SyncingState<ABI>>
subscription callback
invalidate?
Invalidator<SyncingState<ABI>>
cleanup callback
Returns
Unsubscriber
syncing.$state
Get Signature
get $state():
SyncingState<ABI>
Defined in: browser/src/IndexerState.ts:449
Returns
SyncingState<ABI>
updateIndexer()
updateIndexer(
update):Promise<void>
Parameters
update
provider?
EIP1193ProviderWithoutEvents
source?
IndexingSource<ABI>
streamConfig?
Returns
Promise<void>
updateProcessor()
updateProcessor(
newProcessor,options?):Promise<void>
Parameters
newProcessor
EventProcessorWithInitialState<ABI, ProcessResultType, ProcessorConfig>
options?
force?
boolean
Returns
Promise<void>
withHooks()
withHooks(
react):object
Parameters
react
ReactHooks
Returns
object
dispose
dispose: () =>
void
Returns
void
indexMore
indexMore: () =>
Promise<LastSync<ABI>>
Returns
Promise<LastSync<ABI>>
indexMoreAndCatchupIfNeeded
indexMoreAndCatchupIfNeeded: () =>
Promise<LastSync<ABI>>
Returns
Promise<LastSync<ABI>>
indexToLatest
indexToLatest: () =>
Promise<LastSync<ABI>>
Returns
Promise<LastSync<ABI>>
init
init:
InitFunction<ABI,ProcessorConfig>
reset
reset: () =>
Promise<void>
Returns
Promise<void>
startAutoIndexing
startAutoIndexing: (
intervalInSeconds) =>Promise<boolean>
Parameters
intervalInSeconds?
number = 4
Returns
Promise<boolean>
state
state:
object
state.subscribe
subscribe: (
this,run,invalidate?) =>Unsubscriber=readableState.subscribe
Subscribe on value changes.
Parameters
this
void
run
Subscriber<ProcessResultType>
subscription callback
invalidate?
Invalidator<ProcessResultType>
cleanup callback
Returns
Unsubscriber
state.$state
Get Signature
get $state():
ProcessResultType
Defined in: browser/src/IndexerState.ts:455
Returns
ProcessResultType
status
status:
object
status.subscribe
subscribe: (
this,run,invalidate?) =>Unsubscriber=readableStatus.subscribe
Subscribe on value changes.
Parameters
this
void
run
Subscriber<StatusState>
subscription callback
invalidate?
Invalidator<StatusState>
cleanup callback
Returns
Unsubscriber
status.$state
Get Signature
get $state():
StatusState
Defined in: browser/src/IndexerState.ts:461
Returns
stopAutoIndexing
stopAutoIndexing: () =>
boolean
Returns
boolean
syncing
syncing:
object
syncing.subscribe
subscribe: (
this,run,invalidate?) =>Unsubscriber=readableSyncing.subscribe
Subscribe on value changes.
Parameters
this
void
run
Subscriber<SyncingState<ABI>>
subscription callback
invalidate?
Invalidator<SyncingState<ABI>>
cleanup callback
Returns
Unsubscriber
syncing.$state
Get Signature
get $state():
SyncingState<ABI>
Defined in: browser/src/IndexerState.ts:449
Returns
SyncingState<ABI>
useState
useState: () =>
ProcessResultType
Returns
ProcessResultType
useStatus
useStatus: () =>
StatusState
Returns
useSyncing
useSyncing: () =>
SyncingState<ABI>
Returns
SyncingState<ABI>
updateIndexer()
updateIndexer(
update):Promise<void>
Parameters
update
provider?
EIP1193ProviderWithoutEvents
source?
IndexingSource<ABI>
streamConfig?
Returns
Promise<void>
updateProcessor()
updateProcessor(
newProcessor,options?):Promise<void>
Parameters
newProcessor
EventProcessorWithInitialState<ABI, ProcessResultType, ProcessorConfig>
options?
force?
boolean
Returns
Promise<void>
withHooks()
withHooks(
react): { useState: () => ProcessResultType; useSyncing: () => SyncingState<ABI>; useStatus: () => StatusState; syncing: { subscribe: (this: void, run: Subscriber<SyncingState<ABI>>, invalidate?: Invalidator<...> | undefined) => Unsubscriber; readonly $state: SyncingState<...>; }; ... 12 more ...; withHooks(react: ReactHook...
Parameters
react
ReactHooks
Returns
{ useState: () => ProcessResultType; useSyncing: () => SyncingState<ABI>; useStatus: () => StatusState; syncing: { subscribe: (this: void, run: Subscriber<SyncingState<ABI>>, invalidate?: Invalidator<...> | undefined) => Unsubscriber; readonly $state: SyncingState<...>; }; ... 12 more ...; withHooks(react: ReactHook...