Message Bus Handlers

Important

The synchronous version is generated from the async version

Async

async purgatory.service._async.message_handlers.register_circuit_breaker(cmd: purgatory.domain.messages.commands.CreateCircuitBreaker, uow: purgatory.service._async.unit_of_work.AsyncAbstractUnitOfWork) → purgatory.domain.model.Context

Register circuit breaker in the repository

when receiving the CreateCircuitBreaker command.

async purgatory.service._async.message_handlers.save_circuit_breaker_state(evt: purgatory.domain.messages.events.ContextChanged, uow: purgatory.service._async.unit_of_work.AsyncAbstractUnitOfWork) → None

Save the circuit breaker state in the repository

when receiving the ContextChanged event.

async purgatory.service._async.message_handlers.inc_circuit_breaker_failure(evt: purgatory.domain.messages.events.CircuitBreakerFailed, uow: purgatory.service._async.unit_of_work.AsyncAbstractUnitOfWork) → None

Increment the number of failure in the repository

when receiving the CircuitBreakerFailed event.

async purgatory.service._async.message_handlers.reset_failure(evt: purgatory.domain.messages.events.CircuitBreakerRecovered, uow: purgatory.service._async.unit_of_work.AsyncAbstractUnitOfWork) → None

Reset the number of failure in the repository

when receiving the CircuitBreakerRecovered event.

Sync

purgatory.service._sync.message_handlers.register_circuit_breaker(cmd: purgatory.domain.messages.commands.CreateCircuitBreaker, uow: purgatory.service._sync.unit_of_work.SyncAbstractUnitOfWork) → purgatory.domain.model.Context

Register circuit breaker in the repository

when receiving the CreateCircuitBreaker command.

purgatory.service._sync.message_handlers.save_circuit_breaker_state(evt: purgatory.domain.messages.events.ContextChanged, uow: purgatory.service._sync.unit_of_work.SyncAbstractUnitOfWork) → None

Save the circuit breaker state in the repository

when receiving the ContextChanged event.

purgatory.service._sync.message_handlers.inc_circuit_breaker_failure(evt: purgatory.domain.messages.events.CircuitBreakerFailed, uow: purgatory.service._sync.unit_of_work.SyncAbstractUnitOfWork) → None

Increment the number of failure in the repository

when receiving the CircuitBreakerFailed event.

purgatory.service._sync.message_handlers.reset_failure(evt: purgatory.domain.messages.events.CircuitBreakerRecovered, uow: purgatory.service._sync.unit_of_work.SyncAbstractUnitOfWork) → None

Reset the number of failure in the repository

when receiving the CircuitBreakerRecovered event.