Updated
On this page
Package entry point re-exporting the dispatch public API: execute_action, TransientEventDelivery, DispatchWorker, InMemoryDispatchBackend/PgDispatchBackend, and the Subscription/Source types.
#dispatch.src.orxtra.dispatch
#dispatch.src.orxtra.dispatch
#__version__
python
__version__ = version('orxtra-dispatch')#execute_action
python
from orxtra.dispatch._action_executor import execute_action#execute_actions_bounded
python
from orxtra.dispatch._action_executor import execute_actions_bounded#SourcePrincipalResolver
python
from orxtra.dispatch._delivery import SourcePrincipalResolver#TransientEventDelivery
python
from orxtra.dispatch._delivery import TransientEventDelivery#match_subscription
python
from orxtra.dispatch._delivery import match_subscription#DispatchWorker
python
from orxtra.dispatch._dispatch_worker import DispatchWorker#InMemoryDispatchBackend
python
from orxtra.dispatch._memory_backend import InMemoryDispatchBackend#PgDispatchBackend
python
from orxtra.dispatch._pg_backend import PgDispatchBackend#AccumulatorStorage
python
from orxtra.dispatch._protocols import AccumulatorStorage#ActionStorage
python
from orxtra.dispatch._protocols import ActionStorage#DispatchBackend
python
from orxtra.dispatch._protocols import DispatchBackend#SourceStorage
python
from orxtra.dispatch._protocols import SourceStorage#SubscriptionStorage
python
from orxtra.dispatch._protocols import SubscriptionStorage#AccumulatorEntry
python
from orxtra.dispatch._types import AccumulatorEntry#FilterPredicate
python
from orxtra.dispatch._types import FilterPredicate#Source
python
from orxtra.dispatch._types import Source#Subscription
python
from orxtra.dispatch._types import Subscription#SubscriptionAction
python
from orxtra.dispatch._types import SubscriptionAction#ActionExecutor
python
from orxtra.protocols import ActionExecutor#EventFireCallback
python
from orxtra.protocols import EventFireCallback