harp_apps.storage.worker¶
- class StorageAsyncWorkerQueue[source]¶
Bases:
AsyncWorkerQueue- __init__(engine, storage, blob_storage)[source]¶
- Parameters:
engine (AsyncEngine)
storage (IStorage)
blob_storage (IBlobStorage)
- async on_transaction_ended(event)[source]¶
- Parameters:
event (TransactionEvent)
- async on_transaction_message(event)[source]¶
- Parameters:
event (HttpMessageEvent)
- async on_transaction_started(event)[source]¶
Event handler to store the transaction in the database.
- Parameters:
event (TransactionEvent)
- register_events(dispatcher)[source]¶
- Parameters:
dispatcher (IAsyncEventDispatcher)
- property pressure¶