forked from goodboy/tractor
67 lines
2.0 KiB
Python
67 lines
2.0 KiB
Python
# tractor: structured concurrent "actors".
|
|
# Copyright 2018-eternity Tyler Goodlet.
|
|
|
|
# This program is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU Affero General Public License as published by
|
|
# the Free Software Foundation, either version 3 of the License, or
|
|
# (at your option) any later version.
|
|
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU Affero General Public License for more details.
|
|
|
|
# You should have received a copy of the GNU Affero General Public License
|
|
# along with this program. If not, see <https://www.gnu.org/licenses/>.
|
|
|
|
"""
|
|
tractor: structured concurrent ``trio``-"actors".
|
|
|
|
"""
|
|
from exceptiongroup import BaseExceptionGroup as BaseExceptionGroup
|
|
|
|
from ._clustering import (
|
|
open_actor_cluster as open_actor_cluster,
|
|
)
|
|
from ._context import (
|
|
Context as Context, # the type
|
|
context as context, # a func-decorator
|
|
)
|
|
from ._streaming import (
|
|
MsgStream as MsgStream,
|
|
stream as stream,
|
|
)
|
|
from ._discovery import (
|
|
get_arbiter as get_arbiter,
|
|
find_actor as find_actor,
|
|
wait_for_actor as wait_for_actor,
|
|
query_actor as query_actor,
|
|
)
|
|
from ._supervise import (
|
|
open_nursery as open_nursery,
|
|
ActorNursery as ActorNursery,
|
|
)
|
|
from ._state import (
|
|
current_actor as current_actor,
|
|
is_root_process as is_root_process,
|
|
)
|
|
from ._exceptions import (
|
|
RemoteActorError as RemoteActorError,
|
|
ModuleNotExposed as ModuleNotExposed,
|
|
ContextCancelled as ContextCancelled,
|
|
)
|
|
from .devx import (
|
|
breakpoint as breakpoint,
|
|
pause as pause,
|
|
pause_from_sync as pause_from_sync,
|
|
post_mortem as post_mortem,
|
|
)
|
|
from . import msg as msg
|
|
from ._root import (
|
|
run_daemon as run_daemon,
|
|
open_root_actor as open_root_actor,
|
|
)
|
|
from ._ipc import Channel as Channel
|
|
from ._portal import Portal as Portal
|
|
from ._runtime import Actor as Actor
|