straxen.plugins.raw_records_coin_nv package

Submodules

straxen.plugins.raw_records_coin_nv.nveto_recorder module

straxen.plugins.raw_records_coin_nv.nveto_recorder.find_coincidence(records, nfold=4, resolving_time=300, pre_trigger=0)[source]

Checks if n-neighboring events are less apart from each other then the specified resolving time.

Parameters:

  • records – Can be anything which is of the dtype strax.interval_dtype e.g. records, hits, peaks…

  • nfold – coincidence level.

  • resolving_time – Time window of the coincidence [ns].

  • pre_trigger – Pre trigger window which sould be saved

Returns:

array containing the start times and end times of the corresponding intervals.

Note:

The coincidence window is self-extending. If start times of two intervals are exactly resolving_time apart from each other they will be merged into a single interval.

straxen.plugins.raw_records_coin_nv.nveto_recorder.lone_record_statistics_dtype(n_channels)[source]
straxen.plugins.raw_records_coin_nv.nveto_recorder.merge_intervals(intervals)[source]

Function which merges overlapping intervals into a single one.

Parameters:

intervals – Any numpy array with strax time fields.

Returns:

New intervals with time and endtime according to the overlapping intervals.

class straxen.plugins.raw_records_coin_nv.nveto_recorder.nVETORecorder[source]

Bases: Plugin

Plugin which builds a software trigger based on records.

The trigger is defined by a simple coincidence between pulse fragments within the specified resolving time. All records which do not fall into one of the coincidence windows are labeled as lone records for which we compute some average properties for monitoring purposes. Depending on the setting also a fixed number of the lone_records per channel are stored.

baseline_samples_nv

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

channel_map

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

check_raw_record_overlaps_nv

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

coincidence_level_recorder_nv

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

compressor = 'zstd'
compute(raw_records_nv, start, end)[source]
config: Dict
data_kind: str | immutabledict | dict = {'lone_raw_record_statistics_nv': 'lone_raw_record_statistics_nv', 'lone_raw_records_nv': 'lone_raw_records_nv', 'raw_records_coin_nv': 'raw_records_coin_nv'}
depends_on: tuple = 'raw_records_nv'
deps: Dict
dtype: tuple | dtype | immutabledict | dict
hit_min_amplitude_nv

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

infer_dtype()[source]

Return dtype of computed data; used only if no dtype attribute defined.

input_buffer: Dict[str, Chunk]
n_lone_records_nv

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

parallel: str | bool = 'process'
pre_trigger_time_nv

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

provides: tuple = ('raw_records_coin_nv', 'lone_raw_records_nv', 'lone_raw_record_statistics_nv')
rechunk_on_save = True
resolving_time_recorder_nv

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

run_i: int
run_id: str
save_when = immutabledict({'raw_records_coin_nv': <SaveWhen.TARGET: 2>, 'lone_raw_records_nv': <SaveWhen.TARGET: 2>, 'lone_raw_record_statistics_nv': <SaveWhen.ALWAYS: 3>})
setup()[source]

Hook if plugin wants to do something on initialization.

takes_config = immutabledict({'coincidence_level_recorder_nv': <straxen.url_config.URLConfig object>, 'pre_trigger_time_nv': <straxen.url_config.URLConfig object>, 'resolving_time_recorder_nv': <straxen.url_config.URLConfig object>, 'baseline_samples_nv': <straxen.url_config.URLConfig object>, 'hit_min_amplitude_nv': <straxen.url_config.URLConfig object>, 'n_lone_records_nv': <straxen.url_config.URLConfig object>, 'channel_map': <straxen.url_config.URLConfig object>, 'check_raw_record_overlaps_nv': <straxen.url_config.URLConfig object>})

Module contents