beamlime.applications.handlers

Module Attributes

ResultRegistry	Workflow result container.
MergeMessageCountInterval	Every MergeMessageCountInterval-th message the data assembler receives the data reduction is run
MergeMessageTimeInterval	The data reduction is run when the DataAssembler receives a message and the time since the last reduction exceeds the length of the interval (in seconds)

Functions

maxcount_or_maxtime(maxcount, maxtime)
plot_images_with_offsets(*, ax, ...[, cmap, ...])
random_image_path()

Classes

DataAssembler(*, logger[, merge_every_nth, ...])	Receives data and assembles it into a single data structure.
DataReady(content)
DataReductionHandler(workflow[, reuslt_registry])	Data reduction handler to process the raw data.
PlotSaver(*, logger, image_path_prefix[, ...])	Plot handler to save the updated histogram into an image file.
PlotStreamer(*, logger[, max_column])
RawCountHandler(*, logger, nexus_file)	Continuously handle raw counts for every ev44 message.
WorkflowInput(nxevent_data, nxlog)
WorkflowResultUpdate(content)