runtimepy package#
Subpackages#
- runtimepy.channel package
- Subpackages
- runtimepy.channel.environment package
- Subpackages
- Submodules
- runtimepy.channel.environment.array module
- runtimepy.channel.environment.base module
- runtimepy.channel.environment.create module
- runtimepy.channel.environment.file module
- runtimepy.channel.environment.sample module
- runtimepy.channel.environment.telemetry module
- Module contents
- runtimepy.channel.event package
- runtimepy.channel.environment package
- Submodules
- runtimepy.channel.registry module
- Module contents
- Subpackages
- runtimepy.codec package
- runtimepy.commands package
- runtimepy.control package
- runtimepy.enum package
- Submodules
- runtimepy.enum.registry module
- runtimepy.enum.types module
- Module contents
RuntimeEnum
RuntimeEnum.as_bool()
RuntimeEnum.as_int()
RuntimeEnum.as_str()
RuntimeEnum.asdict()
RuntimeEnum.bools
RuntimeEnum.data_from_enum()
RuntimeEnum.from_enum()
RuntimeEnum.get_bool()
RuntimeEnum.get_int()
RuntimeEnum.get_str()
RuntimeEnum.init()
RuntimeEnum.ints
RuntimeEnum.is_boolean
RuntimeEnum.is_integer
RuntimeEnum.register_bool()
RuntimeEnum.register_int()
- runtimepy.message package
- Submodules
- runtimepy.message.handlers module
- runtimepy.message.interface module
JsonMessageInterface
JsonMessageInterface.basic_handler()
JsonMessageInterface.channel_command()
JsonMessageInterface.command
JsonMessageInterface.handle_log_message()
JsonMessageInterface.list_handler
JsonMessageInterface.logger
JsonMessageInterface.loopback()
JsonMessageInterface.poll_handler()
JsonMessageInterface.process_json()
JsonMessageInterface.processor
JsonMessageInterface.remote_environments
JsonMessageInterface.send_json()
JsonMessageInterface.send_poll()
JsonMessageInterface.stage_remote_log()
JsonMessageInterface.typed_handler()
JsonMessageInterface.wait_json()
JsonMessageInterface.write()
- runtimepy.message.types module
- Module contents
- runtimepy.metrics package
- runtimepy.mixins package
- Submodules
- runtimepy.mixins.async_command module
- runtimepy.mixins.enum module
- runtimepy.mixins.environment module
- runtimepy.mixins.finalize module
- runtimepy.mixins.logging module
- runtimepy.mixins.psutil module
- runtimepy.mixins.regex module
- runtimepy.mixins.trig module
- Module contents
- runtimepy.net package
- Subpackages
- Submodules
- runtimepy.net.backoff module
- runtimepy.net.connection module
Connection
Connection.async_init()
Connection.auto_restart
Connection.byte_order
Connection.close()
Connection.connected
Connection.default_auto_restart
Connection.disable()
Connection.disable_extra()
Connection.disable_in()
Connection.disabled
Connection.init()
Connection.log_metrics()
Connection.process()
Connection.process_binary()
Connection.process_text()
Connection.process_then_disable()
Connection.restart()
Connection.send_binary()
Connection.send_text()
Connection.tasks
Connection.uses_binary_tx_queue
Connection.uses_text_tx_queue
EchoConnection
NullConnection
- runtimepy.net.manager module
- runtimepy.net.mixin module
- runtimepy.net.mtu module
- runtimepy.net.ssl module
- runtimepy.net.util module
- Module contents
Connection
Connection.async_init()
Connection.auto_restart
Connection.byte_order
Connection.close()
Connection.connected
Connection.default_auto_restart
Connection.disable()
Connection.disable_extra()
Connection.disable_in()
Connection.disabled
Connection.env
Connection.init()
Connection.log_metrics()
Connection.logger
Connection.markdown
Connection.process()
Connection.process_binary()
Connection.process_text()
Connection.process_then_disable()
Connection.restart()
Connection.send_binary()
Connection.send_text()
Connection.tasks
Connection.uses_binary_tx_queue
Connection.uses_text_tx_queue
ConnectionManager
EchoConnection
ExponentialBackoff
IPv4Host
IPv6Host
NullConnection
get_free_socket()
get_free_socket_name()
hostname()
normalize_host()
sockname()
try_log_connection_error()
- runtimepy.noise package
- runtimepy.primitives package
- Subpackages
- Submodules
- runtimepy.primitives.base module
Primitive
Primitive.age_ns()
Primitive.age_str()
Primitive.binary()
Primitive.byte_order
Primitive.callback()
Primitive.copy()
Primitive.decode()
Primitive.encode()
Primitive.from_stream()
Primitive.invert()
Primitive.kind
Primitive.read()
Primitive.register_callback()
Primitive.remove_callback()
Primitive.scale()
Primitive.scaled
Primitive.set_value()
Primitive.size
Primitive.to_stream()
Primitive.update()
Primitive.valid_primitive()
Primitive.value
Primitive.write()
- runtimepy.primitives.bool module
- runtimepy.primitives.byte_order module
- runtimepy.primitives.evaluation module
- runtimepy.primitives.float module
- runtimepy.primitives.int module
- runtimepy.primitives.scaling module
- runtimepy.primitives.string module
- Module contents
BaseFloatPrimitive
BaseIntPrimitive
Bool
Double
Float
Half
Int16
Int32
Int64
Int8
Primitive
Primitive.age_ns()
Primitive.age_str()
Primitive.binary()
Primitive.byte_order
Primitive.callback()
Primitive.callbacks
Primitive.copy()
Primitive.curr_callback
Primitive.decode()
Primitive.encode()
Primitive.from_stream()
Primitive.invert()
Primitive.kind
Primitive.last_updated_ns
Primitive.read()
Primitive.register_callback()
Primitive.remove_callback()
Primitive.scale()
Primitive.scaled
Primitive.set_value()
Primitive.size
Primitive.to_stream()
Primitive.update()
Primitive.valid_primitive()
Primitive.value
Primitive.write()
StrToBool
Uint16
Uint32
Uint64
Uint8
create()
normalize()
- runtimepy.registry package
- runtimepy.sample package
- runtimepy.struct package
- runtimepy.subprocess package
- Submodules
- runtimepy.subprocess.interface module
RuntimepyPeerInterface
RuntimepyPeerInterface.handle_command()
RuntimepyPeerInterface.handle_log_message()
RuntimepyPeerInterface.handle_stderr()
RuntimepyPeerInterface.handle_stdout()
RuntimepyPeerInterface.markdown
RuntimepyPeerInterface.peer_name
RuntimepyPeerInterface.poll_handler()
RuntimepyPeerInterface.poll_metrics()
RuntimepyPeerInterface.poll_period_s
RuntimepyPeerInterface.share_config()
RuntimepyPeerInterface.share_environment()
RuntimepyPeerInterface.struct_pre_finalize()
RuntimepyPeerInterface.struct_type
- runtimepy.subprocess.peer module
- runtimepy.subprocess.program module
PeerProgram
PeerProgram.cleanup()
PeerProgram.got_eof
PeerProgram.heartbeat_task()
PeerProgram.io_task()
PeerProgram.json_output
PeerProgram.main()
PeerProgram.poll_handler()
PeerProgram.pre_environment_exchange()
PeerProgram.run()
PeerProgram.run_standard()
PeerProgram.running()
PeerProgram.singleton()
PeerProgram.stream_metrics
PeerProgram.stream_output
PeerProgram.streaming_events()
PeerProgram.struct_pre_finalize()
PeerProgram.struct_type
PeerProgram.write()
- runtimepy.subprocess.protocol module
RuntimepySubprocessProtocol
RuntimepySubprocessProtocol.connection_made()
RuntimepySubprocessProtocol.elapsed_time
RuntimepySubprocessProtocol.exited
RuntimepySubprocessProtocol.pid
RuntimepySubprocessProtocol.pipe_connection_lost()
RuntimepySubprocessProtocol.pipe_data_received()
RuntimepySubprocessProtocol.process_exited()
RuntimepySubprocessProtocol.start_time
RuntimepySubprocessProtocol.stderr
RuntimepySubprocessProtocol.stderr_queue
RuntimepySubprocessProtocol.stderr_transport
RuntimepySubprocessProtocol.stdin
RuntimepySubprocessProtocol.stdout
RuntimepySubprocessProtocol.stdout_queue
RuntimepySubprocessProtocol.stdout_transport
RuntimepySubprocessProtocol.subproc
RuntimepySubprocessProtocol.transport
- Module contents
- runtimepy.task package
- runtimepy.telemetry package
- runtimepy.tui package
- runtimepy.ui package
Submodules#
runtimepy.app module#
This package’s command-line entry-point application.
runtimepy.entry module#
This package’s command-line entry-point (boilerplate).
runtimepy.mapping module#
A module implementing a generic, two-way mapping interface.
- class runtimepy.mapping.TwoWayNameMapping(mapping: MutableMapping[T, str] = None, reverse: MutableMapping[str, T] = None)[source]#
Bases:
RegexMixin
,LoggerMixin
,Generic
[T
]A class interface for managing two-way mappings.
- classmethod bool_from_dict(data: MutableMapping[str | bool, str | bool]) BoolMapping [source]#
Create a boolean-to-name mapping from a dictionary with arbitrary data.
- identifier(key: str | T) T | None [source]#
Get the integer identifier associated with a registry key.
- classmethod int_from_dict(data: MutableMapping[str | int, str | int]) IntMapping [source]#
Create an integer-to-name mapping from a dictionary with arbitrary data.
- property names: Iterator[str]#
Iterate over names.
runtimepy.schemas module#
A module for working with schemas belonging to this package.
- class runtimepy.schemas.RuntimepyDictCodec(data: dict[str, str | int | float | bool | None | dict[str, str | int | float | bool | None] | list[str | int | float | bool | None]] = None, schemas: SchemaMap = None, dest_attr: str = 'data', verify: bool = True)[source]#
Bases:
DictCodec
A simple wrapper for package classes that want to implement DictCodec.
- default_schemas: SchemaMap | None = {'TaskConfig': <vcorelib.schemas.json.JsonSchema object>, 'RuntimeEnum': <vcorelib.schemas.json.JsonSchema object>, 'EnumRegistry': <vcorelib.schemas.json.JsonSchema object>, 'BitFields': <vcorelib.schemas.json.JsonSchema object>, 'StructConfig': <vcorelib.schemas.json.JsonSchema object>, 'ChannelCommand': <vcorelib.schemas.json.JsonSchema object>, 'PeerProcessConfig': <vcorelib.schemas.json.JsonSchema object>, 'FindFile': <vcorelib.schemas.json.JsonSchema object>, 'ChannelRegistry': <vcorelib.schemas.json.JsonSchema object>, 'has_request_flag': <vcorelib.schemas.json.JsonSchema object>, 'ConnectionArbiterConfig': <vcorelib.schemas.json.JsonSchema object>, 'ServerConnectionConfig': <vcorelib.schemas.json.JsonSchema object>, 'ClientConnectionConfig': <vcorelib.schemas.json.JsonSchema object>, 'has_config': <vcorelib.schemas.json.JsonSchema object>, 'has_factory': <vcorelib.schemas.json.JsonSchema object>, 'channel_controls': <vcorelib.schemas.json.JsonSchema object>, 'has_name': <vcorelib.schemas.json.JsonSchema object>, 'Channel': <vcorelib.schemas.json.JsonSchema object>, 'has_markdown': <vcorelib.schemas.json.JsonSchema object>}#
runtimepy.util module#
A module implementing package utilities.
- class runtimepy.util.Identifier(start: int = 1, scale: int = 2)[source]#
Bases:
object
A simple message indentifier interface.
- runtimepy.util.normalize_root(*src_parts: str | Path) Path [source]#
Make paths absolute that aren’t. Useful for HTTP-request pathing.
- runtimepy.util.parse_path_parts(path: str, key: str = 'json') Iterator[str] [source]#
Parse a path such that all parts appearing after a possible ‘key’ appears are yielded.
Module contents#
Useful defaults and other package metadata.