@proto-kit/processor • Docs
Documentation / @proto-kit/processor / TimedProcessorTrigger
Class: TimedProcessorTrigger
Used by various module sub-types that may need to be configured
Extends
Constructors
new TimedProcessorTrigger()
new TimedProcessorTrigger(
blockStorage,blockFetching,handlersExecutor):TimedProcessorTrigger
Parameters
• blockStorage: BlockStorage
• blockFetching: BlockFetching
• handlersExecutor: HandlersExecutor<BasePrismaClient, HandlersRecord<BasePrismaClient>>
Returns
Overrides
Defined in
packages/processor/src/triggers/TimedProcessorTrigger.ts:18
Properties
blockFetching
blockFetching:
BlockFetching
Defined in
packages/processor/src/triggers/TimedProcessorTrigger.ts:20
blockStorage
blockStorage:
BlockStorage
Defined in
packages/processor/src/triggers/TimedProcessorTrigger.ts:19
catchingUp
catchingUp:
boolean=false
Defined in
packages/processor/src/triggers/TimedProcessorTrigger.ts:16
currentConfig
protectedcurrentConfig:undefined|TimedProcessorTriggerConfig
Store the config separately, so that we can apply additional checks when retrieving it via the getter
Inherited from
Defined in
packages/common/dist/config/ConfigurableModule.d.ts:17
handlersExecutor
handlersExecutor:
HandlersExecutor<BasePrismaClient,HandlersRecord<BasePrismaClient>>
Defined in
packages/processor/src/triggers/TimedProcessorTrigger.ts:22
Accessors
config
Get Signature
get config():
Config
Returns
Config
Set Signature
set config(
config):void
Parameters
• config: Config
Returns
void
Inherited from
Defined in
packages/common/dist/config/ConfigurableModule.d.ts:18
Methods
catchUp()
catchUp():
Promise<void>
Returns
Promise<void>
Defined in
packages/processor/src/triggers/TimedProcessorTrigger.ts:61
create()
create(
childContainerProvider):void
Parameters
• childContainerProvider: ChildContainerProvider
Returns
void
Inherited from
Defined in
packages/common/dist/config/ConfigurableModule.d.ts:20
processNextBlock()
processNextBlock():
Promise<boolean>
Returns
Promise<boolean>
Defined in
packages/processor/src/triggers/TimedProcessorTrigger.ts:30
start()
start():
Promise<void>
Returns
Promise<void>