Index

Symbols

-c vis-receiver command line option -h vis-receiver command line option

-o vis-receiver command line option

A

AccumulatingConsumer (class in realtime.receive.modules.consumers.accumulating_consumer) aclose() (realtime.receive.modules.scan_provider.ScanProvider method) (realtime.receive.modules.scan_provider.SdpConfigScanProvider method) add() (realtime.receive.modules.consumers.plasma_writer.InvocationResults method) add_payload() (realtime.receive.modules.aggregators.MultiBeamPipeline method) (realtime.receive.modules.aggregators.PayloadAggregator method) added_payloads (realtime.receive.modules.aggregators.MultiBeamPipeline property) (realtime.receive.modules.aggregators.PayloadAggregator property) aggregated_payloads (realtime.receive.modules.aggregators.MultiBeamPipeline property) (realtime.receive.modules.receivers.spead2_receivers.receiver property)

aggregation (realtime.receive.modules.receiver.ReceiverConfig attribute) AggregationConfig (class in realtime.receive.modules.aggregators) antenna_layout (realtime.receive.modules.receiver.TelescopeManagerConfig attribute) as_configuration (realtime.receive.modules.tm.base_tm.TelescopeManager property) assign_resources_command (realtime.receive.modules.receiver.ScanProviderConfig attribute) AssignResourcesScanProvider (class in realtime.receive.modules.scan_provider) astart() (realtime.receive.modules.aggregators.MultiBeamPipeline method) astop() (realtime.receive.modules.aggregators.MultiBeamPipeline method) (realtime.receive.modules.consumers.mswriter.MSWriterConsumer method) (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method)

B

backend (realtime.receive.modules.receiver.SdpConfigDbConfig attribute) backoff_time (realtime.receive.modules.aggregators.AggregationConfig attribute)

baselines_as_visibility_indices (realtime.receive.modules.tm.base_tm.TelescopeManager property) bind_hostname (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) buffer_size (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)

C

channels_per_stream (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) command_template (realtime.receive.modules.consumers.mswriter.MSWriterConsumerConfig attribute) Config (class in realtime.receive.modules.consumers) (class in realtime.receive.modules.receivers) config_class (realtime.receive.modules.consumers.mswriter.MSWriterConsumer attribute) (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer attribute) (realtime.receive.modules.receivers.spead2_receivers.receiver attribute) connect() (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method)

consume() (realtime.receive.modules.consumers.accumulating_consumer.AccumulatingConsumer method) (realtime.receive.modules.consumers.mswriter.MSWriterConsumer method) (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method) consumer (realtime.receive.modules.aggregators.MultiBeamPipeline property) (realtime.receive.modules.receiver.ReceiverConfig attribute) (realtime.receive.modules.receivers.spead2_receivers.receiver property) continuous_mode (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) create_stream() (in module realtime.receive.modules.receivers.spead2_receivers)

D

data_loss_report_rate (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) data_source (realtime.receive.modules.receiver.ScanProviderConfig property) (realtime.receive.modules.receiver.TelescopeManagerConfig property)

disable_astropy_iers_autodownload (realtime.receive.modules.receiver.UVWEngineConfig attribute) disconnect() (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method)

E

end_scan() (realtime.receive.modules.consumers.accumulating_consumer.AccumulatingConsumer method) (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method) end_scan_max_delay (realtime.receive.modules.receiver.ScanProviderConfig attribute) end_scan_pending (realtime.receive.modules.scan_provider.SdpConfigScanProvider property)

engine (realtime.receive.modules.receiver.UVWEngineConfig attribute) execution_block_id (realtime.receive.modules.receiver.ScanProviderConfig attribute) (realtime.receive.modules.receiver.TelescopeManagerConfig attribute) exit_timeout (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)

F

FakeScanProvider (class in realtime.receive.modules.scan_provider) find_processors() (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method) flush() (realtime.receive.modules.aggregators.MultiBeamPipeline method) (realtime.receive.modules.aggregators.PayloadAggregator method)

from_sdp_config() (realtime.receive.modules.tm.sched_tm.SKATelescopeManager static method) from_spectral_window() (realtime.receive.modules.scan_provider.FakeScanProvider static method)

G

get() (realtime.receive.modules.scan_provider.AssignResourcesScanProvider method) (realtime.receive.modules.scan_provider.FakeScanProvider method) (realtime.receive.modules.scan_provider.ScanProvider method) (realtime.receive.modules.scan_provider.SdpConfigScanProvider method)

get_antennas() (realtime.receive.modules.tm.base_tm.TelescopeManager method) get_baselines() (realtime.receive.modules.tm.base_tm.TelescopeManager method)

H

hardcoded_auto_corr (realtime.receive.modules.receiver.TelescopeManagerConfig attribute) hardcoded_lower_triangular (realtime.receive.modules.receiver.TelescopeManagerConfig attribute) hardcoded_num_receptors (realtime.receive.modules.receiver.TelescopeManagerConfig attribute)

hardcoded_spectral_window_channels (realtime.receive.modules.receiver.ScanProviderConfig attribute) has_all_required_item_descriptors (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceiverPayload property) host (realtime.receive.modules.receiver.SdpConfigDbConfig attribute)

I

IGNORE (realtime.receive.modules.consumers.plasma_writer.PlasmaExitedAction attribute) invocation_results (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer property)

InvocationResults (class in realtime.receive.modules.consumers.plasma_writer) invocations_in_flight (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer property) ItemDescStatus (class in realtime.receive.modules.receivers.spead2_receivers)

M

max_packet_size (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) max_payloads_per_ms (realtime.receive.modules.consumers.mswriter.MSWriterConsumerConfig attribute) max_pending_data_heaps (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) measurement_set (realtime.receive.modules.receiver.ScanProviderConfig attribute) (realtime.receive.modules.receiver.TelescopeManagerConfig attribute) MeasurementSetTM (class in realtime.receive.modules.tm.ms_tm) method (realtime.receive.modules.receivers.Config attribute) (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) module realtime.receive.modules.aggregators realtime.receive.modules.consumers.accumulating_consumer realtime.receive.modules.consumers.mswriter realtime.receive.modules.consumers.plasma_writer realtime.receive.modules.receivers.spead2_receivers realtime.receive.modules.scan_provider realtime.receive.modules.tm.base_tm realtime.receive.modules.tm.ms_tm realtime.receive.modules.tm.sched_tm

MSScanProvider (class in realtime.receive.modules.scan_provider) MSWriterConsumer (class in realtime.receive.modules.consumers.mswriter) MSWriterConsumerConfig (class in realtime.receive.modules.consumers.mswriter) MultiBeamPipeline (class in realtime.receive.modules.aggregators)

N

name (realtime.receive.modules.consumers.Config attribute) (realtime.receive.modules.consumers.mswriter.MSWriterConsumerConfig attribute) (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConfig attribute) needs_sdp_config_db (realtime.receive.modules.receiver.ReceiverConfig property) (realtime.receive.modules.receiver.ScanProviderConfig property) (realtime.receive.modules.receiver.TelescopeManagerConfig property)

num_baselines (realtime.receive.modules.tm.base_tm.TelescopeManager property) num_channels (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) num_processors (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer property) num_stations (realtime.receive.modules.tm.base_tm.TelescopeManager property) num_streams (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) num_timestamps_per_aggregation (realtime.receive.modules.aggregators.AggregationConfig attribute)

O

output_filename (realtime.receive.modules.consumers.mswriter.MSWriterConsumerConfig attribute)

P

parse_ap_ids() (in module realtime.receive.modules.tm.sched_tm) PayloadAggregator (class in realtime.receive.modules.aggregators) payloads_in_flight (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConfig attribute) payloads_per_backoff (realtime.receive.modules.aggregators.AggregationConfig attribute) pcap_file (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) plasma_path (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConfig attribute)

PlasmaExitedAction (class in realtime.receive.modules.consumers.plasma_writer) PlasmaWriterConfig (class in realtime.receive.modules.consumers.plasma_writer) PlasmaWriterConsumer (class in realtime.receive.modules.consumers.plasma_writer) port (realtime.receive.modules.receiver.SdpConfigDbConfig attribute) port_range (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig property) port_start (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)

Q

query_scan() (realtime.receive.modules.scan_provider.AssignResourcesScanProvider method) (realtime.receive.modules.scan_provider.FakeScanProvider method) (realtime.receive.modules.scan_provider.ScanProvider method) (realtime.receive.modules.scan_provider.SdpConfigScanProvider method)

query_scans() (realtime.receive.modules.scan_provider.AssignResourcesScanProvider method) (realtime.receive.modules.scan_provider.FakeScanProvider method) (realtime.receive.modules.scan_provider.ScanProvider method) (realtime.receive.modules.scan_provider.SdpConfigScanProvider method)

R

readiness_filename (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) realtime.receive.modules.aggregators module realtime.receive.modules.consumers.accumulating_consumer module realtime.receive.modules.consumers.mswriter module realtime.receive.modules.consumers.plasma_writer module realtime.receive.modules.receivers.spead2_receivers module realtime.receive.modules.scan_provider module realtime.receive.modules.tm.base_tm module realtime.receive.modules.tm.ms_tm module

realtime.receive.modules.tm.sched_tm module receive() (in module realtime.receive.modules.receiver) received_payloads (realtime.receive.modules.receivers.spead2_receivers.receiver property) receiver (class in realtime.receive.modules.receivers.spead2_receivers) receiver_threads (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) ReceiverConfig (class in realtime.receive.modules.receiver) reception (realtime.receive.modules.receiver.ReceiverConfig attribute) RECONNECT_AND_RETRY (realtime.receive.modules.consumers.plasma_writer.PlasmaExitedAction attribute) remove_old_references_timeout (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConfig attribute) reset_time_indexing() (realtime.receive.modules.aggregators.MultiBeamPipeline method) (realtime.receive.modules.aggregators.PayloadAggregator method) reset_time_indexing_after_each_scan (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) ring_heaps (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) run() (realtime.receive.modules.receivers.spead2_receivers.receiver method)

S

scan_provider (realtime.receive.modules.receiver.ReceiverConfig attribute) scan_types (realtime.receive.modules.scan_provider.ScanProvider property) ScanProvider (class in realtime.receive.modules.scan_provider) ScanProviderConfig (class in realtime.receive.modules.receiver) ScanProviderConfig.DataSource (class in realtime.receive.modules.receiver) scans_to_receive (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) schedblock (realtime.receive.modules.receiver.TelescopeManagerConfig attribute) sdp_config_db (realtime.receive.modules.receiver.ReceiverConfig attribute) SdpConfigDbConfig (class in realtime.receive.modules.receiver) SdpConfigScanProvider (class in realtime.receive.modules.scan_provider) set_item_descriptors() (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceiverPayload method) SKATelescopeManager (class in realtime.receive.modules.tm.sched_tm)

sort_receptors_by_icd() (in module realtime.receive.modules.tm.sched_tm) Spead2ReceiverPayload (class in realtime.receive.modules.receivers.spead2_receivers) Spead2ReceptionConfig (class in realtime.receive.modules.receivers.spead2_receivers) start_of_stream_report_rate (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) start_scan() (realtime.receive.modules.consumers.accumulating_consumer.AccumulatingConsumer method) (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method) stats (realtime.receive.modules.receivers.spead2_receivers.receiver property) stats_config (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) stats_receiver_interval (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) StatsConfig (class in realtime.receive.modules.receivers.spead2_receivers) stop_streams() (in module realtime.receive.modules.receivers.spead2_receivers) stream_extremes_report_rate (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)

T

TelescopeManager (class in realtime.receive.modules.tm.base_tm) TelescopeManagerConfig (class in realtime.receive.modules.receiver) TelescopeManagerConfig.DataSource (class in realtime.receive.modules.receiver) telmodel_key (realtime.receive.modules.receiver.TelescopeManagerConfig attribute) telmodel_source_uris (realtime.receive.modules.receiver.TelescopeManagerConfig attribute) test_failure (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)

time_period (realtime.receive.modules.aggregators.AggregationConfig attribute) timestamp_output (realtime.receive.modules.consumers.mswriter.MSWriterConsumerConfig attribute) timestamp_tolerance (realtime.receive.modules.aggregators.AggregationConfig attribute) tm (realtime.receive.modules.receiver.ReceiverConfig attribute) tolerance (realtime.receive.modules.aggregators.AggregationConfig property) transport_protocol (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute) TransportProtocols (class in realtime.receive.modules.receivers.spead2_receivers)

U

update() (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceiverPayload method)

uvw_engine (realtime.receive.modules.receiver.ReceiverConfig attribute) UVWEngineConfig (class in realtime.receive.modules.receiver)

V

vis-receiver command line option -c -h -o

visibilities_consumed (realtime.receive.modules.aggregators.MultiBeamPipeline property) (realtime.receive.modules.receivers.spead2_receivers.receiver property) visibilities_generated (realtime.receive.modules.aggregators.MultiBeamPipeline property) (realtime.receive.modules.receivers.spead2_receivers.receiver property)

W

wait_for_all_responses() (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method)

wait_for_all_responses_timeout (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConfig attribute) wait_for_oldest_reponse() (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method)