corx

• corx package
  • Submodules
  • corx.aggregate module
    • Aggregate
    • HasAggregate
      • HasAggregate.aggregate()
  • corx.base module
    • AsyncLoop
      • AsyncLoop.is_processing()
      • AsyncLoop.process()
      • AsyncLoop.propagate_exceptions()
      • AsyncLoop.push()
    • Executor
      • Executor.activate()
      • Executor.deactivate()
      • Executor.execute()
      • Executor.register()
    • HasUseCase
      • HasUseCase.use_case()
    • Singleton
    • UseCases
      • UseCases.Command
      • UseCases.Event
      • UseCases.Query
  • corx.bootstrap module
    • bootstrap()
  • corx.command module
    • Command
      • Command.created_at
      • Command.use_case()
      • Command.uuid
    • CommandExecutor
      • CommandExecutor.execute()
      • CommandExecutor.register()
      • CommandExecutor.use_case()
    • CommandHandler
      • CommandHandler.handle()
      • CommandHandler.use_case()
  • corx.dispatcher module
    • Dispatchable
      • Dispatchable.dispatch()
    • Dispatcher
      • Dispatcher.activate()
      • Dispatcher.deactivate()
      • Dispatcher.dispatch()
      • Dispatcher.propagate_exceptions()
      • Dispatcher.register()
      • Dispatcher.register_executors()
  • corx.event module
    • AnyEvent
      • AnyEvent.timestamp
      • AnyEvent.uuid
      • AnyEvent.version
    • Event
      • Event.apply()
      • Event.timestamp
      • Event.use_case()
      • Event.uuid
      • Event.version
    • EventExecutor
      • EventExecutor.execute()
      • EventExecutor.register()
      • EventExecutor.use_case()
    • EventListener
      • EventListener.react()
      • EventListener.use_case()
    • ProcessManager
    • RuntimeEventStore
      • RuntimeEventStore.clear()
      • RuntimeEventStore.get()
      • RuntimeEventStore.get_latest_by_type()
      • RuntimeEventStore.react()
      • RuntimeEventStore.seed_events()
  • corx.query module
    • Query
      • Query.created_at
      • Query.use_case()
      • Query.uuid
    • QueryExecutor
      • QueryExecutor.execute()
      • QueryExecutor.register()
      • QueryExecutor.use_case()
    • QueryHandler
      • QueryHandler.handle()
      • QueryHandler.handles()
      • QueryHandler.use_case()
  • corx.test module
    • UnitTestCase
      • UnitTestCase.dispatcher
      • UnitTestCase.given()
      • UnitTestCase.setUpClass()
      • UnitTestCase.tearDown()
      • UnitTestCase.then()
      • UnitTestCase.when()
  • Module contents