pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 4 Packages Projects Releases Wiki Activity

Drop `__all__` import style from `.services`

distribute_dis
Tyler Goodlet 2024-01-04 10:05:53 -05:00
parent 03e429abf8
commit fc216d37de
1 changed files with 34 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
piker/service/__init__.py
View File

@ -14,49 +14,45 @@
# You should have received a copy of the GNU Affero General Public License # 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/>. # along with this program. If not, see <https://www.gnu.org/licenses/>.
""" '''
Actor-runtime service orchestration machinery. Actor runtime primtives and (distributed) service APIs for,
""" - daemon-service mgmt: `_daemon` (i.e. low-level spawn and supervise machinery
from __future__ import annotations for sub-actors like `brokerd`, `emsd`, datad`, etc.)
from ._mngr import Services - service-actor supervision (via `trio` tasks) API: `._mngr`
from ._registry import ( # noqa
_tractor_kwargs, - discovery interface (via light wrapping around `tractor`'s built-in
_default_reg_addr, prot): `._registry`
_default_registry_host,
_default_registry_port, - `docker` cntr SC supervision for use with `trio`: `_ahab`
open_registry, - wrappers for marketstore and elasticsearch dbs
find_service, => TODO: maybe to (re)move elsewhere?
check_for_service,
'''
from ._mngr import Services as Services
from ._registry import (
_tractor_kwargs as _tractor_kwargs,
_default_reg_addr as _default_reg_addr,
_default_registry_host as _default_registry_host,
_default_registry_port as _default_registry_port,
open_registry as open_registry,
find_service as find_service,
check_for_service as check_for_service,
) )
from ._daemon import ( # noqa from ._daemon import (
maybe_spawn_daemon, maybe_spawn_daemon as maybe_spawn_daemon,
spawn_emsd, spawn_emsd as spawn_emsd,
maybe_open_emsd, maybe_open_emsd as maybe_open_emsd,
) )
from ._actor_runtime import ( from ._actor_runtime import (
open_piker_runtime, open_piker_runtime as open_piker_runtime,
maybe_open_pikerd, maybe_open_pikerd as maybe_open_pikerd,
open_pikerd, open_pikerd as open_pikerd,
get_runtime_vars, get_runtime_vars as get_runtime_vars,
) )
from ..brokers._daemon import ( from ..brokers._daemon import (
spawn_brokerd, spawn_brokerd as spawn_brokerd,
maybe_spawn_brokerd, maybe_spawn_brokerd as maybe_spawn_brokerd,
) )
__all__ = [
'check_for_service',
'Services',
'maybe_spawn_daemon',
'spawn_brokerd',
'maybe_spawn_brokerd',
'spawn_emsd',
'maybe_open_emsd',
'open_piker_runtime',
'maybe_open_pikerd',
'open_pikerd',
'get_runtime_vars',
]