WatchBuffer

class HSTB.kluster.monitor.WatchBuffer(event, timed_func, runtime=1)

Bases: Thread

Employ this thread to run the provided function every (runtime) seconds. Use the provided event to stop the thread.

See DirectoryMonitor for usage. We use this thread in that class to monitor the file buffer, to see when incoming files have finished being written (and are then ready to be read)

Methods Summary

run()

Run the timed function every x runtime seconds

Methods Documentation

run()

Run the timed function every x runtime seconds