API documentation

Plasma Processor Interface

class realtime.calibration.processors.rcal_processor.RCalProcessor(calibrator_to_use: ~realtime.calibration.calibrators.base_calibrator.BaseCalibrator = <realtime.calibration.calibrators.rcal_calibrator.RCalCalibrator object>, kafka_server: str | None = None, kafka_topic: str | None = None, output_hdf5: str | None = None, array: str | None = None)

A processor that can present Visibility data to the RCal library. Child of BaseProcessor.

Attributes

calibrator_to_use: BaseCalibrator

Calibration support class to use. Default = RCalCalibrator()

kafka_server: Optional[str]

Bootstrap server for RCal Kafka producer. Default = None (i.e. no Kafka output)

kafka_topic: Optional[str]

Kafka topic for RCal Kafka producer. Default = None (i.e. no Kafka output)

output_hdf5: Optional[str]

Output HDF5 gain file, mostly used for debugging. Default = None

array: Optional[str]

Explicitly set the array type for re-channelisation (“MID” or “LOW”). Default = None

Methods

create(argv: Iterable[str]) -> “RCalProcessor”:

process(_dataset: Visibility) -> bool:

timeout() -> bool:

close()

param BaseProcessor:

processor base class

async close()

Stop any pending actions in this processor.

static create(argv: Iterable[str]) → RCalProcessor

Creates an instance of this class from the given command line parameters. This allows user-provided classes to have their own command line parsing logic, and receive arbitrary user-provided parameters.

Parameters:

argv – A list of command line parameters.

Returns:

A new instance of this class.

async process(_dataset: Visibility) → bool

Processes the given visibilities dataset.

Parameters:

dataset – A dataset read from Plasma.