Index

_

__init__() (BaseProcessor method) (BaseProducer method) (BaseStatefulProcessor method) (BaseStatefulProducer method) (ClockDrivenSettings method) (ClockSettings method) (CompositeProcessor method) (CompositeProducer method) (CounterSettings method) (PipelineSettingsEvent method) (PipelineSettingsProducerSettings method) (Processor method) (Producer method) (SampleMessage method) (SampleTriggerMessage method) (StatefulProcessor method) (StatefulProducer method) (SyncToAsyncGeneratorWrapper method)

A

aclose() (SyncToAsyncGeneratorWrapper method) AdaptiveTransformer (class in ezmsg.baseproc.protocols) apartial_fit() (AdaptiveTransformer method) (BaseAdaptiveTransformer method)

apartial_fit_transform() (AdaptiveTransformer method) (BaseAdaptiveTransformer method) asend() (BaseProcessor method) (SyncToAsyncGeneratorWrapper method)

B

BaseAdaptiveTransformer (class in ezmsg.baseproc.stateful) BaseAdaptiveTransformerUnit (class in ezmsg.baseproc.units) BaseAsyncTransformer (class in ezmsg.baseproc.stateful) BaseClockDrivenProducer (class in ezmsg.baseproc.clockdriven) BaseClockDrivenUnit (class in ezmsg.baseproc.units) BaseConsumer (class in ezmsg.baseproc.processor) BaseConsumerUnit (class in ezmsg.baseproc.units) BaseProcessor (class in ezmsg.baseproc.processor)

BaseProcessorUnit (class in ezmsg.baseproc.units) BaseProducer (class in ezmsg.baseproc.processor) BaseProducerUnit (class in ezmsg.baseproc.units) BaseStatefulConsumer (class in ezmsg.baseproc.stateful) BaseStatefulProcessor (class in ezmsg.baseproc.stateful) BaseStatefulProducer (class in ezmsg.baseproc.stateful) BaseStatefulTransformer (class in ezmsg.baseproc.stateful) BaseTransformer (class in ezmsg.baseproc.processor) BaseTransformerUnit (class in ezmsg.baseproc.units)

C

check_message_type_compatibility() (in module ezmsg.baseproc.util.typeresolution) Clock (class in ezmsg.baseproc.clock) ClockDrivenSettings (class in ezmsg.baseproc.clockdriven) ClockDrivenState (class in ezmsg.baseproc.clockdriven) ClockProducer (class in ezmsg.baseproc.clock) ClockSettings (class in ezmsg.baseproc.clock) ClockState (class in ezmsg.baseproc.clock) close() (BaseProcessor method) (BaseProducer method) component_address (PipelineSettingsEvent attribute) CompositeProcessor (class in ezmsg.baseproc.composite) CompositeProducer (class in ezmsg.baseproc.composite) CompositeStateful (class in ezmsg.baseproc.composite) construct_generator() (GenAxisArray method)

Consumer (class in ezmsg.baseproc.protocols) CoroutineExecutionError Counter (class in ezmsg.baseproc.counter) counter (ClockDrivenState attribute) CounterSettings (class in ezmsg.baseproc.counter) CounterTransformer (class in ezmsg.baseproc.counter) CounterTransformerState (class in ezmsg.baseproc.counter) create_processor() (BaseAdaptiveTransformerUnit method) (BaseClockDrivenUnit method) (BaseConsumerUnit method) (BaseProcessorUnit method) (BaseTransformerUnit method) create_producer() (BaseProducerUnit method) ctx (PipelineSettingsProducerState attribute)

D

DEFAULT_REMOVAL (in module ezmsg.baseproc.util.deprecation)

dispatch_rate (ClockSettings attribute)

E

event_type (PipelineSettingsEvent attribute) ezmsg.baseproc module ezmsg.baseproc.clock module ezmsg.baseproc.clockdriven module ezmsg.baseproc.composite module ezmsg.baseproc.counter module ezmsg.baseproc.processor module ezmsg.baseproc.protocols module ezmsg.baseproc.stateful module

ezmsg.baseproc.units module ezmsg.baseproc.util module ezmsg.baseproc.util.asio module ezmsg.baseproc.util.deprecation module ezmsg.baseproc.util.message module ezmsg.baseproc.util.pipeline_settings module ezmsg.baseproc.util.profile module ezmsg.baseproc.util.streamdim module ezmsg.baseproc.util.typeresolution module

F

flatten_component_settings() (in module ezmsg.baseproc.util.pipeline_settings) flatten_ez_settings() (in module ezmsg.baseproc.util.pipeline_settings)

flatten_for_table() (PipelineSettingsEvent method) fractional_samples (ClockDrivenState attribute) fs (ClockDrivenSettings attribute)

G

gen (GenState attribute) GenAxisArray (class in ezmsg.baseproc.units) GenState (class in ezmsg.baseproc.units) get_base_adaptive_transformer_type() (in module ezmsg.baseproc.units) get_base_clockdriven_producer_type() (in module ezmsg.baseproc.units) get_base_consumer_type() (in module ezmsg.baseproc.units) get_base_producer_type() (in module ezmsg.baseproc.units) get_base_transformer_type() (in module ezmsg.baseproc.units)

get_logger_path() (in module ezmsg.baseproc.util.profile) get_message_type() (BaseConsumer class method) (BaseProcessor class method) (BaseProducer class method) (BaseStatefulConsumer class method) get_settings_type() (BaseProcessor class method) (BaseProducer class method) get_state_type() (Stateful class method) graph_address (PipelineSettingsProducerSettings attribute)

H

has_samples_along() (in module ezmsg.baseproc.util.streamdim)

I

INIT_FINAL_COMPONENT_ADDRESS (in module ezmsg.baseproc.util.pipeline_settings) INITIAL (PipelineSettingsEventType attribute) initialize() (BaseProcessorUnit method) (BaseProducerUnit method) (GenAxisArray method) (PipelineSettingsUnit method) initialized (PipelineSettingsProducerState attribute) INPUT_CLOCK (BaseClockDrivenUnit attribute) INPUT_SAMPLE (BaseAdaptiveTransformerUnit attribute)

INPUT_SETTINGS (BaseProcessorUnit attribute) (BaseProducerUnit attribute) (GenAxisArray attribute) INPUT_SIGNAL (BaseAdaptiveTransformerUnit attribute) (BaseConsumerUnit attribute) (BaseTransformerUnit attribute) (GenAxisArray attribute) is_empty_along() (in module ezmsg.baseproc.util.streamdim) is_sample_message() (in module ezmsg.baseproc.util.message)

L

last_seq (PipelineSettingsProducerState attribute)

M

mod (CounterSettings attribute) module ezmsg.baseproc ezmsg.baseproc.clock ezmsg.baseproc.clockdriven ezmsg.baseproc.composite ezmsg.baseproc.counter ezmsg.baseproc.processor ezmsg.baseproc.protocols ezmsg.baseproc.stateful ezmsg.baseproc.units ezmsg.baseproc.util ezmsg.baseproc.util.asio ezmsg.baseproc.util.deprecation ezmsg.baseproc.util.message ezmsg.baseproc.util.pipeline_settings ezmsg.baseproc.util.profile ezmsg.baseproc.util.streamdim ezmsg.baseproc.util.typeresolution

N

n_dispatch (ClockState attribute) n_time (ClockDrivenSettings attribute)

NONRESET_SETTINGS_FIELDS (BaseProcessor attribute) (BaseProducer attribute)

O

on_clock() (BaseClockDrivenUnit method) on_sample() (BaseAdaptiveTransformerUnit method) on_settings() (BaseProcessorUnit method) (BaseProducerUnit method) (GenAxisArray method) on_signal() (BaseAdaptiveTransformerUnit method) (BaseConsumerUnit method) (BaseTransformerUnit method) (GenAxisArray method)

OUTPUT_SAMPLE (BaseAdaptiveTransformerUnit attribute) OUTPUT_SIGNAL (BaseAdaptiveTransformerUnit attribute) (BaseClockDrivenUnit attribute) (BaseProducerUnit attribute) (BaseTransformerUnit attribute) (GenAxisArray attribute)

P

partial_fit() (AdaptiveTransformer method) (BaseAdaptiveTransformer method) partial_fit_transform() (AdaptiveTransformer method) (BaseAdaptiveTransformer method) period (SampleTriggerMessage attribute) PipelineSettingsEvent (class in ezmsg.baseproc.util.pipeline_settings) PipelineSettingsEventType (class in ezmsg.baseproc.util.pipeline_settings) PipelineSettingsProducer (class in ezmsg.baseproc.util.pipeline_settings)

PipelineSettingsProducerSettings (class in ezmsg.baseproc.util.pipeline_settings) PipelineSettingsProducerState (class in ezmsg.baseproc.util.pipeline_settings) PipelineSettingsUnit (class in ezmsg.baseproc.util.pipeline_settings) Processor (class in ezmsg.baseproc.protocols) produce() (BaseProducerUnit method) Producer (class in ezmsg.baseproc.protocols) profile_method() (in module ezmsg.baseproc.util.profile) profile_subpub() (in module ezmsg.baseproc.util.profile)

Q

queue (PipelineSettingsProducerState attribute)

R

repr_value (PipelineSettingsEvent attribute) resolve_configured_stream_dim() (in module ezmsg.baseproc.util.streamdim) resolve_feature_dim() (in module ezmsg.baseproc.util.streamdim)

resolve_stream_dim() (in module ezmsg.baseproc.util.streamdim) resolve_transform_dim() (in module ezmsg.baseproc.util.streamdim) resolve_typevar() (in module ezmsg.baseproc.util.typeresolution) run_coroutine_sync() (in module ezmsg.baseproc.util.asio)

S

sample (SampleMessage attribute) SampleMessage (class in ezmsg.baseproc.util.message) SampleTriggerMessage (class in ezmsg.baseproc.util.message) sanitize_settings_column_name() (in module ezmsg.baseproc.util.pipeline_settings) sanitize_settings_value() (in module ezmsg.baseproc.util.pipeline_settings) scope (PipelineSettingsProducerState attribute) scope_components (PipelineSettingsProducerSettings attribute) send() (BaseProcessor method) seq (PipelineSettingsEvent attribute) settings (BaseProcessor attribute) (BaseProducer attribute) SETTINGS (Clock attribute) (Counter attribute) (PipelineSettingsUnit attribute) shutdown() (PipelineSettingsUnit method) source_session_id (PipelineSettingsEvent attribute) state (CompositeStateful property) STATE (GenAxisArray attribute) state (Stateful property) (StatefulProcessor property) (StatefulProducer property)

Stateful (class in ezmsg.baseproc.stateful) stateful_op() (BaseStatefulConsumer method) (BaseStatefulProcessor method) (BaseStatefulProducer method) (BaseStatefulTransformer method) (CompositeProcessor method) (CompositeProducer method) (CompositeStateful method) (Stateful method) (StatefulConsumer method) (StatefulProcessor method) (StatefulProducer method) (StatefulTransformer method) StatefulConsumer (class in ezmsg.baseproc.protocols) StatefulProcessor (class in ezmsg.baseproc.protocols) StatefulProducer (class in ezmsg.baseproc.protocols) StatefulTransformer (class in ezmsg.baseproc.protocols) STREAMING_DIMS (in module ezmsg.baseproc.util.streamdim) (Stateful attribute) structured_value (PipelineSettingsEvent attribute) suppress_axis_deprecation() (in module ezmsg.baseproc.util.deprecation) SyncToAsyncGeneratorWrapper (class in ezmsg.baseproc.util.asio)

T

t_0 (ClockState attribute) table_name (PipelineSettingsEvent attribute) target_table (PipelineSettingsProducerSettings attribute) template (CounterTransformerState attribute)

timestamp (PipelineSettingsEvent attribute) (SampleTriggerMessage attribute) Transformer (class in ezmsg.baseproc.protocols) trigger (SampleMessage attribute)

U

update_settings() (BaseProcessor method) (BaseProducer method) (CompositeProcessor method) (CompositeProducer method)

UPDATED (PipelineSettingsEventType attribute)

V

value (SampleTriggerMessage attribute)

W

warn_axis_deprecated() (in module ezmsg.baseproc.util.deprecation)

watch_task (PipelineSettingsProducerState attribute) with_fingerprint() (in module ezmsg.baseproc.util.streamdim)