Index

A

add_instance() (pymoa_remote.client.LocalRegistry method) add_item() (pymoa_remote.utils.MaxSizeErrorDeque method) (pymoa_remote.utils.MaxSizeSkipDeque method) allow_import_from_main (pymoa_remote.server.ExecutorServerBase attribute) (pymoa_remote.socket.multiprocessing_client.MultiprocessSocketExecutor attribute) allow_remote_class_registration (pymoa_remote.server.ExecutorServerBase attribute) (pymoa_remote.socket.multiprocessing_client.MultiprocessSocketExecutor attribute) apply_config_from_remote() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) apply_data_from_remote() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method)

apply_execute_from_remote() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) apply_executor() (in module pymoa_remote.client) apply_generator_executor() (in module pymoa_remote.client) apply_property_data_from_remote() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) asynccontextmanager() (in module pymoa_remote.utils) AsyncThreadExecutor (class in pymoa_remote.threading)

C

call_execute_callback() (pymoa_remote.executor.ExecutorBase class method) call_execute_callback_func() (pymoa_remote.executor.ExecutorBase class method) call_instance_method() (pymoa_remote.server.ExecutorServer method) call_instance_method_gen() (pymoa_remote.server.ExecutorServer method) cancel_nursery (pymoa_remote.threading.AsyncThreadExecutor attribute)

convert_base64_to_hash() (pymoa_remote.executor.InstanceRegistry method) convert_hash_to_base64() (pymoa_remote.executor.InstanceRegistry method) create_app() (in module pymoa_remote.app.quart) create_instance() (pymoa_remote.server.RemoteRegistry method) create_socket_context() (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.socket.websocket_client.WebSocketExecutor method)

D

DataLogger (class in pymoa_remote.server) decode() (pymoa_remote.app.multiprocessing.ProcessSocketServer method) (pymoa_remote.app.quart.QuartSocketServer method) (pymoa_remote.client.Executor method) (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.server.ExecutorServer method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.socket.multiprocessing_client.MultiprocessSocketExecutor method) (pymoa_remote.socket.websocket_client.WebSocketExecutor method) decode_json() (pymoa_remote.executor.InstanceRegistry method) decode_json_buffers() (pymoa_remote.app.quart.QuartSocketServer method) (pymoa_remote.executor.InstanceRegistry method)

decode_json_buffers_header() (pymoa_remote.executor.InstanceRegistry method) decode_json_buffers_raw() (pymoa_remote.executor.InstanceRegistry method) delete_instance() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.client.LocalRegistry method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.RemoteRegistry method) (pymoa_remote.server.SimpleExecutorServer method) delete_remote_instance() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) dispatch_stream_channel_to_queues() (in module pymoa_remote.server)

E

encode() (pymoa_remote.app.multiprocessing.ProcessSocketServer method) (pymoa_remote.app.quart.QuartSocketServer method) (pymoa_remote.client.Executor method) (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.server.ExecutorServer method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.socket.client.SocketExecutor method) encode_json() (pymoa_remote.executor.InstanceRegistry method) encode_json_buffers() (pymoa_remote.executor.InstanceRegistry method) encode_json_func() (pymoa_remote.executor.InstanceRegistry method) ensure_instance() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) ensure_remote_instance() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) eof (pymoa_remote.threading.SyncThreadExecutor attribute) execute() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.AsyncThreadExecutor method) (pymoa_remote.threading.SyncThreadExecutor method) (pymoa_remote.threading.ThreadExecutor method)

execute_generator() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.AsyncThreadExecutor method) (pymoa_remote.threading.SyncThreadExecutor method) (pymoa_remote.threading.ThreadExecutor method) Executor (class in pymoa_remote.client) executor (pymoa_remote.client.ExecutorContext attribute) (pymoa_remote.server.ExecutorServer attribute) ExecutorBase (class in pymoa_remote.executor) ExecutorContext (class in pymoa_remote.client) ExecutorServer (class in pymoa_remote.server) ExecutorServerBase (class in pymoa_remote.server) extract_frames() (in module pymoa_remote.exception)

F

finish_sse_event() (pymoa_remote.rest.sse.SSEStream class method)

G

get_channel_from_remote() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) get_class_bases() (in module pymoa_remote.utils) get_data_from_remote() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) get_echo_clock() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.AsyncThreadExecutor method) (pymoa_remote.threading.SyncThreadExecutor method) (pymoa_remote.threading.ThreadExecutor method) get_execute_callback_func() (pymoa_remote.executor.ExecutorBase class method) get_fake_traceback_obj() (in module pymoa_remote.exception) get_instance() (pymoa_remote.server.RemoteRegistry method)

get_object_config() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) get_object_data() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) get_objects() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) get_remote_object_config() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) get_remote_object_property_data() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) get_remote_objects() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) get_traceback_from_frames() (in module pymoa_remote.exception)

H

hashed_instances (pymoa_remote.executor.InstanceRegistry attribute)

hashed_instances_ids (pymoa_remote.executor.InstanceRegistry attribute)

I

InstanceRegistry (class in pymoa_remote.executor) is_class_registered() (pymoa_remote.executor.InstanceRegistry method)

is_remote (pymoa_remote.executor.ExecutorBase attribute) (pymoa_remote.threading.ThreadExecutor attribute)

J

json_coders (pymoa_remote.executor.InstanceRegistry attribute)

L

LocalRegistry (class in pymoa_remote.client) log_event_callback() (pymoa_remote.server.DataLogger method) log_item() (pymoa_remote.server.DataLogger method)

log_property_callback() (pymoa_remote.server.DataLogger method) log_trigger_event_callback() (pymoa_remote.server.DataLogger method) log_trigger_property_callback() (pymoa_remote.server.DataLogger method)

M

max_queue_size (pymoa_remote.threading.SyncThreadExecutor attribute) max_size (pymoa_remote.utils.MaxSizeErrorDeque attribute) (pymoa_remote.utils.MaxSizeSkipDeque attribute) MaxSizeErrorDeque (class in pymoa_remote.utils) MaxSizeSkipDeque (class in pymoa_remote.utils) module pymoa_remote pymoa_remote.app.multiprocessing pymoa_remote.app.quart pymoa_remote.client pymoa_remote.exception pymoa_remote.executor pymoa_remote.rest.client pymoa_remote.rest.sse pymoa_remote.server pymoa_remote.socket.client pymoa_remote.socket.multiprocessing_client pymoa_remote.socket.websocket_client pymoa_remote.threading pymoa_remote.utils

MultiprocessSocketExecutor (class in pymoa_remote.socket.multiprocessing_client)

N

name (pymoa_remote.executor.ExecutorBase attribute)

NO_CALLBACK (in module pymoa_remote.executor) nursery (pymoa_remote.socket.websocket_client.WebSocketExecutor attribute)

O

open_socket() (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.socket.websocket_client.WebSocketExecutor method)

P

packet (pymoa_remote.utils.MaxSizeSkipDeque attribute) port (pymoa_remote.socket.client.SocketExecutor attribute) (pymoa_remote.socket.multiprocessing_client.MultiprocessSocketExecutor attribute) post_stream_channel() (pymoa_remote.app.multiprocessing.ProcessSocketServer method) (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.app.quart.QuartSocketServer method) (pymoa_remote.server.ExecutorServerBase method) prepare_json_buffers() (pymoa_remote.executor.InstanceRegistry method) ProcessSocketServer (class in pymoa_remote.app.multiprocessing) pymoa_remote module pymoa_remote.app.multiprocessing module pymoa_remote.app.quart module pymoa_remote.client module pymoa_remote.exception module

pymoa_remote.executor module pymoa_remote.rest.client module pymoa_remote.rest.sse module pymoa_remote.server module pymoa_remote.socket.client module pymoa_remote.socket.multiprocessing_client module pymoa_remote.socket.websocket_client module pymoa_remote.threading module pymoa_remote.utils module

Q

quart_app (pymoa_remote.app.quart.QuartRestServer attribute) (pymoa_remote.app.quart.QuartSocketServer attribute) QuartRestServer (class in pymoa_remote.app.quart)

QuartSocketServer (class in pymoa_remote.app.quart) queue (pymoa_remote.utils.MaxSizeErrorDeque attribute) QueueFull

R

raise_remote_exception_from_frames() (in module pymoa_remote.exception) raise_return_value() (pymoa_remote.socket.client.SocketExecutor method) read_decode_json_buffers() (pymoa_remote.app.multiprocessing.ProcessSocketServer method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.socket.websocket_client.WebSocketExecutor method) receive_channel (pymoa_remote.utils.MaxSizeErrorDeque attribute) (pymoa_remote.utils.MaxSizeSkipDeque attribute) referenceable_classes (pymoa_remote.executor.InstanceRegistry attribute) referenceable_json_decoder() (pymoa_remote.executor.InstanceRegistry method) register_class() (pymoa_remote.executor.InstanceRegistry method) register_json_coder() (pymoa_remote.executor.InstanceRegistry method) register_remote_class() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method)

registry (pymoa_remote.client.Executor attribute) (pymoa_remote.server.ExecutorServer attribute) remote_import() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) remote_instance() (pymoa_remote.executor.ExecutorBase method) RemoteException RemoteRegistry (class in pymoa_remote.server) rest_execute_generator() (pymoa_remote.app.quart.QuartRestServer method) RestExecutor (class in pymoa_remote.rest.client) run() (pymoa_remote.threading.TrioPortal method) run_app() (in module pymoa_remote.app.multiprocessing) (in module pymoa_remote.app.quart) run_sync() (pymoa_remote.threading.TrioPortal method)

S

send_channel (pymoa_remote.utils.MaxSizeErrorDeque attribute) (pymoa_remote.utils.MaxSizeSkipDeque attribute) serialize_exception() (in module pymoa_remote.exception) server (pymoa_remote.socket.client.SocketExecutor attribute) (pymoa_remote.socket.multiprocessing_client.MultiprocessSocketExecutor attribute) set_sse_field() (pymoa_remote.rest.sse.SSEStream class method) SimpleExecutorServer (class in pymoa_remote.server) size (pymoa_remote.utils.MaxSizeErrorDeque attribute) (pymoa_remote.utils.MaxSizeSkipDeque attribute) size_lock (pymoa_remote.utils.MaxSizeErrorDeque attribute) sleep() (pymoa_remote.app.quart.QuartRestServer method) (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.threading.SyncThreadExecutor method) (pymoa_remote.threading.ThreadExecutor method) socket (pymoa_remote.socket.client.SocketExecutor attribute) (pymoa_remote.socket.websocket_client.WebSocketExecutor attribute) SocketExecutor (class in pymoa_remote.socket.client) sse_channel() (pymoa_remote.app.quart.QuartRestServer method) sse_channel_all() (pymoa_remote.app.quart.QuartRestServer method) sse_channel_create() (pymoa_remote.app.quart.QuartRestServer method) sse_channel_delete() (pymoa_remote.app.quart.QuartRestServer method) sse_channel_execute() (pymoa_remote.app.quart.QuartRestServer method) sse_data() (pymoa_remote.app.quart.QuartRestServer method) SSEStream (class in pymoa_remote.rest.sse) start() (pymoa_remote.threading.AsyncThreadExecutor method) (pymoa_remote.threading.SyncThreadExecutor method)

start_app() (in module pymoa_remote.app.quart) start_executor() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.socket.multiprocessing_client.MultiprocessSocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) start_logging() (pymoa_remote.server.DataLogger method) start_logging_object_data() (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) stop() (pymoa_remote.threading.AsyncThreadExecutor method) (pymoa_remote.threading.SyncThreadExecutor method) stop_executor() (pymoa_remote.executor.ExecutorBase method) (pymoa_remote.rest.client.RestExecutor method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.socket.multiprocessing_client.MultiprocessSocketExecutor method) (pymoa_remote.threading.ThreadExecutor method) stop_logging() (pymoa_remote.server.DataLogger method) stop_logging_object_data() (pymoa_remote.server.ExecutorServerBase method) (pymoa_remote.server.SimpleExecutorServer method) stopped (pymoa_remote.utils.MaxSizeErrorDeque attribute) stream() (pymoa_remote.rest.sse.SSEStream class method) stream_changes (pymoa_remote.server.ExecutorServerBase attribute) (pymoa_remote.socket.multiprocessing_client.MultiprocessSocketExecutor attribute) stream_clients (pymoa_remote.app.multiprocessing.ProcessSocketServer attribute) (pymoa_remote.app.quart.QuartRestServer attribute) (pymoa_remote.app.quart.QuartSocketServer attribute) stream_data_logger (pymoa_remote.server.ExecutorServer attribute) supports_coroutine (pymoa_remote.executor.ExecutorBase attribute) supports_non_coroutine (pymoa_remote.executor.ExecutorBase attribute) SyncThreadExecutor (class in pymoa_remote.threading)

T

thread_id (pymoa_remote.utils.MaxSizeErrorDeque attribute) ThreadExecutor (class in pymoa_remote.threading) to_thread_portal (pymoa_remote.threading.AsyncThreadExecutor attribute)

token (pymoa_remote.client.ExecutorContext attribute) (pymoa_remote.utils.MaxSizeErrorDeque attribute) trio_token (pymoa_remote.threading.TrioPortal attribute) TrioPortal (class in pymoa_remote.threading)

U

uri (pymoa_remote.rest.client.RestExecutor attribute)

W

websocket_data_stream_handler() (pymoa_remote.app.quart.QuartSocketServer method) websocket_handler() (pymoa_remote.app.quart.QuartSocketServer method) websocket_stream_handler() (pymoa_remote.app.quart.QuartSocketServer method) WebSocketExecutor (class in pymoa_remote.socket.websocket_client)

write_socket() (pymoa_remote.app.multiprocessing.ProcessSocketServer method) (pymoa_remote.socket.client.SocketExecutor method) (pymoa_remote.socket.websocket_client.WebSocketExecutor method) ws() (pymoa_remote.app.quart.QuartSocketServer method)