Index

A

add_listener() (purgatory.service._async.circuitbreaker.AsyncCircuitBreakerFactory method) (purgatory.service._async.messagebus.AsyncMessageRegistry method) (purgatory.service._sync.circuitbreaker.SyncCircuitBreakerFactory method) (purgatory.service._sync.messagebus.SyncMessageRegistry method) AsyncAbstractRepository (class in purgatory.service._async.repository) AsyncAbstractUnitOfWork (class in purgatory.service._async.unit_of_work)

AsyncCircuitBreaker (class in purgatory.service._async.circuitbreaker) AsyncCircuitBreakerFactory (class in purgatory.service._async.circuitbreaker) AsyncInMemoryRepository (class in purgatory.service._async.repository) AsyncInMemoryUnitOfWork (class in purgatory.service._async.unit_of_work) AsyncMessageRegistry (class in purgatory.service._async.messagebus) AsyncRedisRepository (class in purgatory.service._async.repository) AsyncRedisUnitOfWork (class in purgatory.service._async.unit_of_work)

C

cb_created() (purgatory.service._async.circuitbreaker.PublicEvent method) (purgatory.service._sync.circuitbreaker.PublicEvent method) cb_failed() (purgatory.service._async.circuitbreaker.PublicEvent method) (purgatory.service._sync.circuitbreaker.PublicEvent method) cb_recovered() (purgatory.service._async.circuitbreaker.PublicEvent method) (purgatory.service._sync.circuitbreaker.PublicEvent method) cb_state_changed() (purgatory.service._async.circuitbreaker.PublicEvent method) (purgatory.service._sync.circuitbreaker.PublicEvent method) CircuitBreakerCreated (class in purgatory.domain.messages.events) CircuitBreakerFailed (class in purgatory.domain.messages.events) CircuitBreakerRecovered (class in purgatory.domain.messages.events) ClosedState (class in purgatory.domain.model) collect_new_events() (purgatory.service._async.unit_of_work.AsyncAbstractUnitOfWork method) (purgatory.service._sync.unit_of_work.SyncAbstractUnitOfWork method)

Command (class in purgatory.domain.messages.base) commit() (purgatory.service._async.unit_of_work.AsyncAbstractUnitOfWork method) (purgatory.service._async.unit_of_work.AsyncInMemoryUnitOfWork method) (purgatory.service._async.unit_of_work.AsyncRedisUnitOfWork method) (purgatory.service._sync.unit_of_work.SyncAbstractUnitOfWork method) (purgatory.service._sync.unit_of_work.SyncInMemoryUnitOfWork method) (purgatory.service._sync.unit_of_work.SyncRedisUnitOfWork method) ConfigurationError, [1], [2], [3] Context (class in purgatory.domain.model) ContextChanged (class in purgatory.domain.messages.events) contexts (purgatory.service._async.unit_of_work.AsyncAbstractUnitOfWork attribute) (purgatory.service._sync.unit_of_work.SyncAbstractUnitOfWork attribute) CreateCircuitBreaker (class in purgatory.domain.messages.commands)

E

Event (class in purgatory.domain.messages.base)

exclude_list (purgatory.domain.model.Context attribute)

F

failure_count (purgatory.domain.messages.events.CircuitBreakerFailed attribute) (purgatory.domain.model.Context property) (purgatory.domain.model.State attribute)

G

get() (purgatory.service._async.repository.AsyncAbstractRepository method) (purgatory.service._async.repository.AsyncInMemoryRepository method) (purgatory.service._async.repository.AsyncRedisRepository method) (purgatory.service._sync.repository.SyncAbstractRepository method) (purgatory.service._sync.repository.SyncInMemoryRepository method) (purgatory.service._sync.repository.SyncRedisRepository method)

get_breaker() (purgatory.service._async.circuitbreaker.AsyncCircuitBreakerFactory method) (purgatory.service._sync.circuitbreaker.SyncCircuitBreakerFactory method)

H

HalfOpenedState (class in purgatory.domain.model) handle() (purgatory.service._async.messagebus.AsyncMessageRegistry method) (purgatory.service._sync.messagebus.SyncMessageRegistry method) handle_end_request() (purgatory.domain.model.ClosedState method) (purgatory.domain.model.Context method) (purgatory.domain.model.HalfOpenedState method) (purgatory.domain.model.OpenedState method) (purgatory.domain.model.State method) handle_exception() (purgatory.domain.model.ClosedState method) (purgatory.domain.model.Context method) (purgatory.domain.model.HalfOpenedState method) (purgatory.domain.model.OpenedState method) (purgatory.domain.model.State method)

handle_new_request() (purgatory.domain.model.ClosedState method) (purgatory.domain.model.Context method) (purgatory.domain.model.HalfOpenedState method) (purgatory.domain.model.OpenedState method) (purgatory.domain.model.State method)

I

inc_circuit_breaker_failure() (in module purgatory.service._async.message_handlers) (in module purgatory.service._sync.message_handlers) inc_failures() (purgatory.service._async.repository.AsyncAbstractRepository method) (purgatory.service._async.repository.AsyncInMemoryRepository method) (purgatory.service._async.repository.AsyncRedisRepository method) (purgatory.service._sync.repository.SyncAbstractRepository method) (purgatory.service._sync.repository.SyncInMemoryRepository method) (purgatory.service._sync.repository.SyncRedisRepository method) initialize() (purgatory.service._async.circuitbreaker.AsyncCircuitBreakerFactory method) (purgatory.service._async.repository.AsyncAbstractRepository method) (purgatory.service._async.repository.AsyncRedisRepository method) (purgatory.service._async.unit_of_work.AsyncAbstractUnitOfWork method) (purgatory.service._async.unit_of_work.AsyncRedisUnitOfWork method) (purgatory.service._sync.circuitbreaker.SyncCircuitBreakerFactory method) (purgatory.service._sync.repository.SyncAbstractRepository method) (purgatory.service._sync.repository.SyncRedisRepository method) (purgatory.service._sync.unit_of_work.SyncAbstractUnitOfWork method) (purgatory.service._sync.unit_of_work.SyncRedisUnitOfWork method)

M

mark_failure() (purgatory.domain.model.Context method) Message (class in purgatory.domain.messages.base) messages (purgatory.domain.model.Context attribute) (purgatory.service._async.repository.AsyncAbstractRepository attribute) (purgatory.service._sync.repository.SyncAbstractRepository attribute) module purgatory.domain.messages.base purgatory.domain.messages.commands purgatory.domain.messages.events purgatory.domain.model purgatory.service._async.circuitbreaker purgatory.service._async.message_handlers purgatory.service._async.messagebus purgatory.service._async.repository purgatory.service._async.unit_of_work purgatory.service._sync.circuitbreaker purgatory.service._sync.message_handlers purgatory.service._sync.messagebus purgatory.service._sync.repository purgatory.service._sync.unit_of_work

N

name (purgatory.domain.messages.commands.CreateCircuitBreaker attribute) (purgatory.domain.messages.events.CircuitBreakerCreated attribute) (purgatory.domain.messages.events.CircuitBreakerFailed attribute) (purgatory.domain.messages.events.CircuitBreakerRecovered attribute) (purgatory.domain.messages.events.ContextChanged attribute) (purgatory.domain.model.ClosedState attribute) (purgatory.domain.model.Context attribute) (purgatory.domain.model.HalfOpenedState attribute) (purgatory.domain.model.OpenedState attribute) (purgatory.domain.model.State attribute)

O

opened_at (purgatory.domain.messages.events.ContextChanged attribute) (purgatory.domain.model.Context property) (purgatory.domain.model.State attribute)

OpenedState

P

PublicEvent (class in purgatory.service._async.circuitbreaker) (class in purgatory.service._sync.circuitbreaker) purgatory.domain.messages.base module purgatory.domain.messages.commands module purgatory.domain.messages.events module purgatory.domain.model module purgatory.service._async.circuitbreaker module purgatory.service._async.message_handlers module purgatory.service._async.messagebus module

purgatory.service._async.repository module purgatory.service._async.unit_of_work module purgatory.service._sync.circuitbreaker module purgatory.service._sync.message_handlers module purgatory.service._sync.messagebus module purgatory.service._sync.repository module purgatory.service._sync.unit_of_work module

R

recover_failure() (purgatory.domain.model.Context method) register() (purgatory.service._async.repository.AsyncAbstractRepository method) (purgatory.service._async.repository.AsyncInMemoryRepository method) (purgatory.service._async.repository.AsyncRedisRepository method) (purgatory.service._sync.repository.SyncAbstractRepository method) (purgatory.service._sync.repository.SyncInMemoryRepository method) (purgatory.service._sync.repository.SyncRedisRepository method) register_circuit_breaker() (in module purgatory.service._async.message_handlers) (in module purgatory.service._sync.message_handlers) remove_listener() (purgatory.service._async.circuitbreaker.AsyncCircuitBreakerFactory method) (purgatory.service._async.messagebus.AsyncMessageRegistry method) (purgatory.service._sync.circuitbreaker.SyncCircuitBreakerFactory method) (purgatory.service._sync.messagebus.SyncMessageRegistry method) remove_listeners() (purgatory.service._async.circuitbreaker.PublicEvent method) (purgatory.service._sync.circuitbreaker.PublicEvent method)

reset_failure() (in module purgatory.service._async.message_handlers) (in module purgatory.service._sync.message_handlers) (purgatory.service._async.repository.AsyncAbstractRepository method) (purgatory.service._async.repository.AsyncInMemoryRepository method) (purgatory.service._async.repository.AsyncRedisRepository method) (purgatory.service._sync.repository.SyncAbstractRepository method) (purgatory.service._sync.repository.SyncInMemoryRepository method) (purgatory.service._sync.repository.SyncRedisRepository method) rollback() (purgatory.service._async.unit_of_work.AsyncAbstractUnitOfWork method) (purgatory.service._async.unit_of_work.AsyncInMemoryUnitOfWork method) (purgatory.service._async.unit_of_work.AsyncRedisUnitOfWork method) (purgatory.service._sync.unit_of_work.SyncAbstractUnitOfWork method) (purgatory.service._sync.unit_of_work.SyncInMemoryUnitOfWork method) (purgatory.service._sync.unit_of_work.SyncRedisUnitOfWork method)

S

save_circuit_breaker_state() (in module purgatory.service._async.message_handlers) (in module purgatory.service._sync.message_handlers) set_state() (purgatory.domain.model.Context method) State (class in purgatory.domain.model) state (purgatory.domain.messages.events.ContextChanged attribute) (purgatory.domain.model.Context property) SyncAbstractRepository (class in purgatory.service._sync.repository)

SyncAbstractUnitOfWork (class in purgatory.service._sync.unit_of_work) SyncCircuitBreaker (class in purgatory.service._sync.circuitbreaker) SyncCircuitBreakerFactory (class in purgatory.service._sync.circuitbreaker) SyncInMemoryRepository (class in purgatory.service._sync.repository) SyncInMemoryUnitOfWork (class in purgatory.service._sync.unit_of_work) SyncMessageRegistry (class in purgatory.service._sync.messagebus) SyncRedisRepository (class in purgatory.service._sync.repository) SyncRedisUnitOfWork (class in purgatory.service._sync.unit_of_work)

T

threshold (purgatory.domain.messages.commands.CreateCircuitBreaker attribute) (purgatory.domain.messages.events.CircuitBreakerCreated attribute) (purgatory.domain.model.Context attribute)

ttl (purgatory.domain.messages.commands.CreateCircuitBreaker attribute) (purgatory.domain.messages.events.CircuitBreakerCreated attribute) (purgatory.domain.model.Context attribute)

U

update_state() (purgatory.service._async.repository.AsyncAbstractRepository method) (purgatory.service._async.repository.AsyncInMemoryRepository method) (purgatory.service._async.repository.AsyncRedisRepository method) (purgatory.service._sync.repository.SyncAbstractRepository method) (purgatory.service._sync.repository.SyncInMemoryRepository method) (purgatory.service._sync.repository.SyncRedisRepository method)