Index

_

__init__() (DashboardServerHandle method) (ExecutionSupervisor method) (GraphContextLifecycleService method) (GraphServiceProtocol method) (RingCursor method) (SampleRing method) (StreamTap method) (StreamTapClient method) (StreamTapManager method)

A

acquire() (StreamTap method) active_topics (StreamTapManager property) adapt_graph_snapshot() (in module ezmsg.dashboard.backend.services.adapters) adapt_profiling_snapshot() (in module ezmsg.dashboard.backend.services.adapters) adapt_profiling_trace_batch() (in module ezmsg.dashboard.backend.services.adapters) adapt_settings_event() (in module ezmsg.dashboard.backend.services.adapters)

adapt_settings_snapshot() (in module ezmsg.dashboard.backend.services.adapters) adapt_settings_value() (in module ezmsg.dashboard.backend.services.adapters) adapt_topology_event() (in module ezmsg.dashboard.backend.services.adapters) as_numpy() (in module ezmsg.dashboard.backend.services.stream_tap) AUTO (in module ezmsg.dashboard.backend.services.stream_tap) availability_payload() (in module ezmsg.dashboard.backend.services.stream_tap)

B

batches (ProfilingTracePayload attribute)

build_parser() (in module ezmsg.dashboard.server)

C

cache_headers_for() (DashboardStaticFiles static method) capacity (SampleRing property) catalog_payload() (in module ezmsg.dashboard.backend.catalog) changed_topics (TopologyChangedPayload attribute) check_graph() (GraphDocument method) check_main_threads() (in module ezmsg.dashboard.backend.execution_worker) client() (StreamTapManager method) close() (ExecutionSupervisor method) cmdline() (in module ezmsg.dashboard.server)

column_remainder (StreamTapClient attribute) compatible() (in module ezmsg.dashboard.backend.execution_document) component (NodeDefinition attribute) component_address (SettingsChangedPayload attribute) component_details() (in module ezmsg.dashboard.backend.catalog) construct_graph() (in module ezmsg.dashboard.backend.execution_document) create_app() (in module ezmsg.dashboard.backend.app) create_dashboard_app() (in module ezmsg.dashboard.server) cursor (StreamTapClient attribute)

D

dashboard_url() (in module ezmsg.dashboard.server) DashboardGraphServerUnavailableError DashboardJSONResponse (class in ezmsg.dashboard.backend.app) DashboardServerHandle (class in ezmsg.dashboard.server) DashboardStaticFiles (class in ezmsg.dashboard.backend.app) data (ProfilingTraceEnvelope attribute) (SettingsChangedEnvelope attribute) (SystemErrorEnvelope attribute) (SystemHeartbeatEnvelope attribute) (SystemReadyEnvelope attribute) (TopologyChangedEnvelope attribute)

decode_binary_frame() (in module ezmsg.dashboard.backend.stream_frames) decode_float_token() (in module ezmsg.dashboard.backend.json_encoding) DEFAULT_WINDOW_SECONDS (in module ezmsg.dashboard.backend.services.stream_tap) deploy() (ExecutionSupervisor method) describe() (in module ezmsg.dashboard.backend.catalog_worker) description (StreamTap property) description_generation (StreamTap property) distribution (Registration attribute) document (ExecutionRequest attribute)

E

EdgeDefinition (class in ezmsg.dashboard.backend.execution_document) edges (GraphDocument attribute) effective_columns() (StreamTapClient method) enabled (ProfilingTraceControlRequest attribute) encode_binary_frame() (in module ezmsg.dashboard.backend.stream_frames) encode_float() (in module ezmsg.dashboard.backend.json_encoding) envelope_pairs() (in module ezmsg.dashboard.backend.stream_frames) event_envelopes() (GraphContextLifecycleService method) (GraphServiceProtocol method) event_type (SettingsChangedPayload attribute) (TopologyChangedPayload attribute) ExecutionConflict ExecutionRequest (class in ezmsg.dashboard.backend.app) ExecutionSupervisor (class in ezmsg.dashboard.backend.execution) expected_revision (ExecutionRequest attribute) (StopExecutionRequest attribute) external_inputs (GraphDocument attribute) external_sources() (in module ezmsg.dashboard.backend.external_sources) ExternalInput (class in ezmsg.dashboard.backend.execution_document) ezmsg.dashboard module ezmsg.dashboard.backend module ezmsg.dashboard.backend.app module ezmsg.dashboard.backend.catalog module

ezmsg.dashboard.backend.catalog_worker module ezmsg.dashboard.backend.execution module ezmsg.dashboard.backend.execution_document module ezmsg.dashboard.backend.execution_worker module ezmsg.dashboard.backend.external_sources module ezmsg.dashboard.backend.json_encoding module ezmsg.dashboard.backend.models module ezmsg.dashboard.backend.models.events module ezmsg.dashboard.backend.services module ezmsg.dashboard.backend.services.adapters module ezmsg.dashboard.backend.services.graph_context_service module ezmsg.dashboard.backend.services.stream_tap module ezmsg.dashboard.backend.stream_frames module ezmsg.dashboard.server module

F

field_path (SettingsFieldPatchRequest attribute)

G

get_graph_service() (in module ezmsg.dashboard.backend.app) get_packaged_frontend_dir() (in module ezmsg.dashboard.backend.app) get_response() (DashboardStaticFiles method)

GraphContextLifecycleService (class in ezmsg.dashboard.backend.services.graph_context_service) GraphDocument (class in ezmsg.dashboard.backend.execution_document) GraphServiceProtocol (class in ezmsg.dashboard.backend.services.graph_context_service) GraphServiceUnavailableError

H

handle_dashboard() (in module ezmsg.dashboard.server) HEADER_PREFIX (in module ezmsg.dashboard.backend.stream_frames)

health_payload() (GraphContextLifecycleService method) (GraphServiceProtocol method) host (DashboardServerHandle attribute)

I

id (EdgeDefinition attribute) (ExternalInput attribute) (NodeDefinition attribute) (Registration attribute)

inspect_payload() (StreamTap method) is_non_finite_token() (in module ezmsg.dashboard.backend.json_encoding) is_started (GraphContextLifecycleService property)

K

kind (ProfilingTraceEnvelope attribute) (SettingsChangedEnvelope attribute) (SystemErrorEnvelope attribute) (SystemHeartbeatEnvelope attribute) (SystemReadyEnvelope attribute) (TopologyChangedEnvelope attribute)

L

LEAKY_MAX_QUEUE (in module ezmsg.dashboard.backend.services.stream_tap)

M

main() (in module ezmsg.dashboard.backend.catalog_worker) (in module ezmsg.dashboard.backend.execution_worker) MAX_COLUMNS (in module ezmsg.dashboard.backend.services.stream_tap) max_columns (StreamTapClient attribute) MAX_DRAWN_CHANNELS (in module ezmsg.dashboard.backend.services.stream_tap) message (SystemErrorPayload attribute) (SystemReadyPayload attribute) metrics (ProfilingTraceControlRequest attribute) mode (StreamTapClient attribute) model_config (EdgeDefinition attribute) (ExecutionRequest attribute) (ExternalInput attribute) (GraphDocument attribute) (NodeDefinition attribute) (ProfilingTraceControlRequest attribute) (ProfilingTraceEnvelope attribute) (ProfilingTracePayload attribute) (Registration attribute) (SettingsChangedEnvelope attribute) (SettingsChangedPayload attribute) (SettingsFieldPatchRequest attribute) (SettingsValuePayload attribute) (StopExecutionRequest attribute) (SystemErrorEnvelope attribute) (SystemErrorPayload attribute) (SystemHeartbeatEnvelope attribute) (SystemHeartbeatPayload attribute) (SystemReadyEnvelope attribute) (SystemReadyPayload attribute) (TopologyChangedEnvelope attribute) (TopologyChangedPayload attribute)

module ezmsg.dashboard ezmsg.dashboard.backend ezmsg.dashboard.backend.app ezmsg.dashboard.backend.catalog ezmsg.dashboard.backend.catalog_worker ezmsg.dashboard.backend.execution ezmsg.dashboard.backend.execution_document ezmsg.dashboard.backend.execution_worker ezmsg.dashboard.backend.external_sources ezmsg.dashboard.backend.json_encoding ezmsg.dashboard.backend.models ezmsg.dashboard.backend.models.events ezmsg.dashboard.backend.services ezmsg.dashboard.backend.services.adapters ezmsg.dashboard.backend.services.graph_context_service ezmsg.dashboard.backend.services.stream_tap ezmsg.dashboard.backend.stream_frames ezmsg.dashboard.server

N

n_channels (SampleRing property) name (NodeDefinition attribute) (Registration attribute)

NodeDefinition (class in ezmsg.dashboard.backend.execution_document) nodes (GraphDocument attribute)

P

pending_samples() (StreamTap method) port (DashboardServerHandle attribute) prepare_document() (in module ezmsg.dashboard.backend.execution_document) process_id (ProfilingTraceControlRequest attribute) ProfilingTraceControlError

ProfilingTraceControlRequest (class in ezmsg.dashboard.backend.app) ProfilingTraceEnvelope (class in ezmsg.dashboard.backend.models.events) ProfilingTracePayload (class in ezmsg.dashboard.backend.models.events) publisher_endpoint_id (ProfilingTraceControlRequest attribute) publisher_topic (ProfilingTraceControlRequest attribute)

R

read() (SampleRing method) read_latest() (StreamTap method) read_sweep() (StreamTap method) ref_count (StreamTap property) Registration (class in ezmsg.dashboard.backend.execution_document) registrations() (in module ezmsg.dashboard.backend.catalog) release() (StreamTap method) render() (DashboardJSONResponse method)

repr_value (SettingsValuePayload attribute) reset_cursor() (StreamTap method) ring_capacity_for() (in module ezmsg.dashboard.backend.stream_frames) RING_MAX_BYTES (in module ezmsg.dashboard.backend.services.stream_tap) RING_SECONDS (in module ezmsg.dashboard.backend.services.stream_tap) RingCursor (class in ezmsg.dashboard.backend.stream_frames) run_until_first_completed() (in module ezmsg.dashboard.backend.app) runtime_name() (in module ezmsg.dashboard.backend.execution_document)

S

sample_mod (ProfilingTraceControlRequest attribute) SampleRing (class in ezmsg.dashboard.backend.stream_frames) samples_per_column() (StreamTapClient method) sanitize_json_value() (in module ezmsg.dashboard.backend.json_encoding) seen_description_generation (StreamTapClient attribute) seen_latest_generation (StreamTapClient attribute) seq (SettingsChangedPayload attribute) (TopologyChangedPayload attribute) serialized_present (SettingsValuePayload attribute) serve_dashboard() (in module ezmsg.dashboard.server) server (DashboardServerHandle attribute) set_max_columns() (StreamTapClient method) set_profiling_trace_control() (GraphContextLifecycleService method) (GraphServiceProtocol method) set_window_seconds() (StreamTapClient method) settings (NodeDefinition attribute) settings_payload() (GraphContextLifecycleService method) (GraphServiceProtocol method) settings_schema (SettingsValuePayload attribute) SettingsChangedEnvelope (class in ezmsg.dashboard.backend.models.events) SettingsChangedPayload (class in ezmsg.dashboard.backend.models.events) SettingsFieldPatchRequest (class in ezmsg.dashboard.backend.app) SettingsPatchError SettingsValuePayload (class in ezmsg.dashboard.backend.models.events) setup_dashboard_cmdline() (in module ezmsg.dashboard.server) shown_seconds() (StreamTapClient method) shutdown() (GraphContextLifecycleService method) (GraphServiceProtocol method) (StreamTapManager method) snapshot_payload() (GraphContextLifecycleService method) (GraphServiceProtocol method) snapshot_rate_hz() (StreamTap method)

source (EdgeDefinition attribute) source_process_id (SettingsChangedPayload attribute) (TopologyChangedPayload attribute) source_session_id (SettingsChangedPayload attribute) (TopologyChangedPayload attribute) sourceHandle (EdgeDefinition attribute) start() (StreamTap method) start_dashboard_server() (in module ezmsg.dashboard.server) startup() (GraphContextLifecycleService method) (GraphServiceProtocol method) status() (ExecutionSupervisor method) status_payload() (StreamTap method) stop() (DashboardServerHandle method) (ExecutionSupervisor method) (StreamTap method) StopExecutionRequest (class in ezmsg.dashboard.backend.app) STREAM_STATUS_INTERVAL_SECONDS (in module ezmsg.dashboard.backend.app) stream_tap() (GraphContextLifecycleService method) (GraphServiceProtocol method) StreamTap (class in ezmsg.dashboard.backend.services.stream_tap) StreamTapClient (class in ezmsg.dashboard.backend.services.stream_tap) StreamTapError StreamTapManager (class in ezmsg.dashboard.backend.services.stream_tap) StreamTapUnavailableError structured_value (SettingsValuePayload attribute) subscriber_topic (ProfilingTraceControlRequest attribute) SWEEP (in module ezmsg.dashboard.backend.services.stream_tap) SystemErrorEnvelope (class in ezmsg.dashboard.backend.models.events) SystemErrorPayload (class in ezmsg.dashboard.backend.models.events) SystemHeartbeatEnvelope (class in ezmsg.dashboard.backend.models.events) SystemHeartbeatPayload (class in ezmsg.dashboard.backend.models.events) SystemReadyEnvelope (class in ezmsg.dashboard.backend.models.events) SystemReadyPayload (class in ezmsg.dashboard.backend.models.events)

T

take_description() (StreamTapClient method) take_frame() (StreamTapClient method) tap (StreamTapClient attribute) target (EdgeDefinition attribute) (ExternalInput attribute) targetHandle (EdgeDefinition attribute) (ExternalInput attribute) thread (DashboardServerHandle attribute) timeout (ProfilingTraceControlRequest attribute) (SettingsFieldPatchRequest attribute) timestamp (ProfilingTracePayload attribute) (SettingsChangedPayload attribute) (SystemErrorPayload attribute) (SystemHeartbeatPayload attribute) (SystemReadyPayload attribute) (TopologyChangedPayload attribute)

topic (ExternalInput attribute) (StreamTap property) (StreamTapClient property) TopologyChangedEnvelope (class in ezmsg.dashboard.backend.models.events) TopologyChangedPayload (class in ezmsg.dashboard.backend.models.events) total_read (RingCursor attribute) ttl_seconds (ProfilingTraceControlRequest attribute) type_bindings() (in module ezmsg.dashboard.backend.catalog_worker) type_label() (in module ezmsg.dashboard.backend.catalog_worker)

U

update_setting_field() (GraphContextLifecycleService method) (GraphServiceProtocol method)

url (DashboardServerHandle property)

V

value (Registration attribute) (SettingsChangedPayload attribute) (SettingsFieldPatchRequest attribute)

version (GraphDocument attribute) (Registration attribute)

W

wait_for_websocket_disconnect() (in module ezmsg.dashboard.backend.app) width (SampleRing property)

window_seconds (StreamTapClient attribute) write() (SampleRing method) write_status() (in module ezmsg.dashboard.backend.execution_worker)