latest
Installation
Running
Configuration options
Aggregation
Consumers
Plasma Processors
API documentation
Appendix
ska-sdp-realtime-receive-modules
Index
Edit on GitLab
Index
Symbols
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
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)
add() (realtime.receive.modules.consumers.plasma_writer.InvocationResults method)
add_payload() (realtime.receive.modules.aggregation.PayloadAggregator method)
add_payloads_and_flush() (realtime.receive.modules.aggregation.PayloadAggregator method)
added_payloads (realtime.receive.modules.aggregation.PayloadAggregator property)
aggregated_payloads (realtime.receive.modules.aggregation.PayloadAggregator property)
(realtime.receive.modules.receivers.spead2_receivers.receiver property)
aggregation (realtime.receive.modules.receiver.ReceiverConfig attribute)
AggregationConfig (class in realtime.receive.modules.aggregation)
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)
astart() (realtime.receive.modules.aggregation.PayloadAggregator method)
astop() (realtime.receive.modules.aggregation.PayloadAggregator 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.aggregation.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)
collect() (realtime.receive.modules.receivers.spead2_receivers.StatsTracker method)
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)
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.aggregation.PayloadAggregator 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)
duration (realtime.receive.modules.receivers.spead2_receivers.StatsTracker property)
E
end_scan() (realtime.receive.modules.consumers.accumulating_consumer.AccumulatingConsumer method)
(realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method)
(realtime.receive.modules.receivers.spead2_receivers.receiver method)
end_scan_max_delay (realtime.receive.modules.receiver.ScanProviderConfig attribute)
engine (realtime.receive.modules.receiver.UVWEngineConfig attribute)
execution_block_id (realtime.receive.modules.receiver.ScanProviderConfig attribute)
(realtime.receive.modules.receiver.TelescopeManagerConfig attribute)
F
find_processors() (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConsumer method)
FixedLowSOSItemValues (class in realtime.receive.modules.receivers.spead2_receivers)
flush() (realtime.receive.modules.aggregation.PayloadAggregator method)
from_sdp_config() (realtime.receive.modules.tm.sched_tm.SKATelescopeManager static method)
G
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)
host (realtime.receive.modules.receiver.SdpConfigDbConfig attribute)
I
incomplete_heaps() (in module realtime.receive.modules.receivers.spead2_receivers)
inform_item_group_size() (realtime.receive.modules.receivers.spead2_receivers.StatsTracker method)
inform_num_streams() (realtime.receive.modules.aggregation.PayloadAggregator method)
integration_interval_tolerance (realtime.receive.modules.aggregation.AggregationConfig 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)
L
log_stats() (in module realtime.receive.modules.receivers.spead2_receivers)
LostDataTracker (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.aggregation
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
MSWriterConsumer (class in realtime.receive.modules.consumers.mswriter)
MSWriterConsumerConfig (class in realtime.receive.modules.consumers.mswriter)
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)
O
output_filename (realtime.receive.modules.consumers.mswriter.MSWriterConsumerConfig attribute)
P
PayloadAggregator (class in realtime.receive.modules.aggregation)
payloads_in_flight (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConfig attribute)
payloads_per_backoff (realtime.receive.modules.aggregation.AggregationConfig attribute)
pcap_file (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)
plasma_path (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConfig attribute)
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_start (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)
R
readiness_filename (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)
realtime.receive.modules.aggregation
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)
reception_started() (realtime.receive.modules.receivers.spead2_receivers.StatsTracker method)
reception_stopped() (realtime.receive.modules.receivers.spead2_receivers.StatsTracker method)
ReceptionStats (class in realtime.receive.modules.receivers.spead2_receivers)
record_data_heap_lost() (realtime.receive.modules.receivers.spead2_receivers.LostDataTracker method)
record_low_start_of_stream() (realtime.receive.modules.receivers.spead2_receivers.StartOfStreamLogger method)
record_mid_start_of_stream() (realtime.receive.modules.receivers.spead2_receivers.StartOfStreamLogger method)
remove_old_references_timeout (realtime.receive.modules.consumers.plasma_writer.PlasmaWriterConfig attribute)
reset() (realtime.receive.modules.receivers.spead2_receivers.LostDataTracker method)
(realtime.receive.modules.receivers.spead2_receivers.StartOfStreamLogger method)
reset_time_indexing() (realtime.receive.modules.aggregation.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)
ScanProviderConfig (class in realtime.receive.modules.receiver)
ScanProviderConfig.DataSource (class in realtime.receive.modules.receiver)
schedblock (realtime.receive.modules.receiver.TelescopeManagerConfig attribute)
sdp_config_db (realtime.receive.modules.receiver.ReceiverConfig attribute)
SdpConfigDbConfig (class in realtime.receive.modules.receiver)
set_item_descriptors() (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceiverPayload method)
SKATelescopeManager (class in 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)
(realtime.receive.modules.receivers.spead2_receivers.receiver method)
StartOfStreamLogger (class in realtime.receive.modules.receivers.spead2_receivers)
stats (realtime.receive.modules.receivers.spead2_receivers.receiver property)
stats_receiver_interval (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)
stats_receiver_kafka_config (realtime.receive.modules.receivers.spead2_receivers.Spead2ReceptionConfig attribute)
StatsTracker (class in realtime.receive.modules.receivers.spead2_receivers)
summary() (realtime.receive.modules.receivers.spead2_receivers.LostDataTracker method)
(realtime.receive.modules.receivers.spead2_receivers.StartOfStreamLogger method)
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.aggregation.AggregationConfig attribute)
timestamp_output (realtime.receive.modules.consumers.mswriter.MSWriterConsumerConfig attribute)
tm (realtime.receive.modules.receiver.ReceiverConfig attribute)
tolerance (realtime.receive.modules.aggregation.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.aggregation.PayloadAggregator property)
(realtime.receive.modules.receivers.spead2_receivers.receiver property)
visibilities_flagged_fraction (realtime.receive.modules.aggregation.PayloadAggregator property)
visibilities_generated (realtime.receive.modules.aggregation.PayloadAggregator 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)
Read the Docs
v: latest
Versions
latest
stable
5.0.0
4.3.0-alpha.1
4.2.1
4.2.0
4.1.0
4.0.0
3.10.2
3.9.2
Downloads
On Read the Docs
Project Home
Builds