rewrite.lib.utils package

Subpackages

• rewrite.lib.utils.db package
  • Submodules
  • rewrite.lib.utils.db.CountRecordAdapter module
  • rewrite.lib.utils.db.DataRecordAdapter module
  • rewrite.lib.utils.db.PressureRecordAdapter module
  • rewrite.lib.utils.db.RecordAdapter module
  • rewrite.lib.utils.db.TemperatureRecordAdapter module
  • Module contents

Submodules

rewrite.lib.utils.WriterToMongoDB module

class rewrite.lib.utils.WriterToMongoDB.WriterToMongoDB(logger=None)

Bases: object

Writes incoming data to the MongoDB for storage

DBWriter()

runDaemon()

rewrite.lib.utils.ReaderFromMongoDB module

class rewrite.lib.utils.ReaderFromMongoDB.ReaderFromMongoDB(logger=None)

Bases: object

Class that read data from MongoDB and sends it as if it were coming from a DAQ card. This is a basic version, which can be extended. Inits the MongoDB connection and the zeromq socket. This needs to start before any analysis.

clear_queues()

Fake function. Just for API compatibility

do(arg)

Fake function. Just for API compatibility

get_temp_and_pressure()

Fake function. Just for API compatibility

read_scalars()

Fake function. Just for API compatibility

reset_scalars()

Fake function. Just for API compatibility

run()

Get data from a certain timeframe from the db and then sends it through the socket.

setRunning(state)

Fake function. Just for API compatibility

set_threashold(ch0, ch1, ch2, ch3)

Fake function. Just for API compatibility

setup_channel(ch0, ch1, ch2, ch3, coincidence)

Fake function. Just for API compatibility

start_reading_data()

Fake function. Just for API compatibility

stop_reading_data()

Fake function. Just for API compatibility

Module contents