Index

A

abs_path (realtime.receive.processors.storage.DataProductStorage property) (realtime.receive.processors.storage.DataProductStorageStub property) Aggregator (class in realtime.receive.aggregator.metrics_aggregator) AmplitudeAggregator (class in realtime.receive.aggregator.metrics_aggregator)

AmplitudePhaseVarianceAggregator (class in realtime.receive.aggregator.metrics_aggregator) append_payload() (realtime.receive.aggregator.metrics_aggregator.Aggregator method) (realtime.receive.aggregator.metrics_aggregator.StatsAggregator method) AveragedAmplitudeAggregator (class in realtime.receive.aggregator.metrics_aggregator)

B

BandCrossCorrAggregator (class in realtime.receive.aggregator.metrics_aggregator) BaseProcessor (class in realtime.receive.processors.sdp.base_processor)

build() (realtime.receive.aggregator.metrics_aggregator.Aggregator method) (realtime.receive.aggregator.metrics_aggregator.StatsAggregator method)

C

cancel() (realtime.receive.processors.sdp.base_processor.BaseProcessor method) close() (realtime.receive.processors.sdp.base_processor.BaseProcessor method)

CommandFileExecutor (class in realtime.receive.processors.file_executor) create() (realtime.receive.processors.sdp.base_processor.BaseProcessor static method)

D

DataProductStorage (class in realtime.receive.processors.storage) DataProductStorage.File (class in realtime.receive.processors.storage) DataProductStorageStub (class in realtime.receive.processors.storage)

DataProductStorageStub.File (class in realtime.receive.processors.storage) declare_file() (realtime.receive.processors.storage.DataProductStorage method) (realtime.receive.processors.storage.DataProductStorageStub method)

E

end_scan() (realtime.receive.processors.sdp.base_processor.BaseProcessor method)

exists (realtime.receive.processors.storage.DataProductStorage.File property) (realtime.receive.processors.storage.DataProductStorageStub.File property)

F

File (in module realtime.receive.processors.storage) FileExecutor (class in realtime.receive.processors.file_executor)

find_spectral_window_for_frequency_range() (in module realtime.receive.aggregator.metrics_aggregator) FunctionFileExecutor (class in realtime.receive.processors.file_executor)

G

get_storage() (realtime.receive.processors.sdp.base_processor.BaseProcessor method)

I

initialise_storage() (realtime.receive.processors.sdp.base_processor.BaseProcessor method)

L

LagplotAggregator (class in realtime.receive.aggregator.metrics_aggregator)

local_path (realtime.receive.processors.storage.DataProductStorage.File property) (realtime.receive.processors.storage.DataProductStorageStub.File property)

M

metadata (realtime.receive.processors.storage.DataProductStorage property) (realtime.receive.processors.storage.DataProductStorageStub property) metric_data_attrs (realtime.receive.aggregator.metrics_aggregator.Aggregator attribute) (realtime.receive.aggregator.metrics_aggregator.AmplitudeAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.AmplitudePhaseVarianceAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.AveragedAmplitudeAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.BandCrossCorrAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.LagplotAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.PhaseAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.SpectrumAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.UVCoverageAggregator attribute) metric_data_type (realtime.receive.aggregator.metrics_aggregator.Aggregator attribute) (realtime.receive.aggregator.metrics_aggregator.AmplitudeAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.AmplitudePhaseVarianceAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.AveragedAmplitudeAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.BandCrossCorrAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.LagplotAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.PhaseAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.SpectrumAggregator attribute) (realtime.receive.aggregator.metrics_aggregator.UVCoverageAggregator attribute)

module realtime.receive.aggregator.metrics_aggregator realtime.receive.processors.storage MSWriterProcessor (class in realtime.receive.processors.sdp.mswriter_processor)

P

PhaseAggregator (class in realtime.receive.aggregator.metrics_aggregator)

process() (realtime.receive.processors.sdp.base_processor.BaseProcessor method)

R

realtime.receive.aggregator.metrics_aggregator module

realtime.receive.processors.storage module

S

sdp_path (realtime.receive.processors.storage.DataProductStorage.File property) (realtime.receive.processors.storage.DataProductStorageStub.File property) set_plasma_socket() (realtime.receive.processors.sdp.base_processor.BaseProcessor method) set_scan_type() (realtime.receive.aggregator.metrics_aggregator.Aggregator method)

SpectrumAggregator (class in realtime.receive.aggregator.metrics_aggregator) start_scan() (realtime.receive.processors.sdp.base_processor.BaseProcessor method) StatsAggregator (class in realtime.receive.aggregator.metrics_aggregator) Storage (in module realtime.receive.processors.storage) storage (realtime.receive.processors.sdp.base_processor.BaseProcessor property)

U

update_status() (realtime.receive.processors.storage.DataProductStorage.File method) (realtime.receive.processors.storage.DataProductStorageStub.File method)

UVCoverageAggregator (class in realtime.receive.aggregator.metrics_aggregator)

W

write_metadata() (realtime.receive.processors.storage.DataProductStorage method) (realtime.receive.processors.storage.DataProductStorageStub method)