beamlime.applications.handlers

Module Attributes

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)
random_image_path()	rtype: NewType(ImagePath, Path)

Classes

DataAssembler(*, logger[, merge_every_nth, ...])	Receives data and assembles it into a single data structure.
DataReady(content)
DataReductionHandler(workflow)	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])
WorkflowResultUpdate(content)