improv.watcher

Module Contents

Classes

BasicWatcher	Actor that monitors stored objects from the other actors
Watcher	Monitors the store as separate process

Attributes

logger

improv.watcher.logger

class improv.watcher.BasicWatcher(*args, inputs=None)

Bases: improv.actor.Actor

Actor that monitors stored objects from the other actors and saves objects that have been flagged by those actors

setup()

set up tasks and polling based on inputs which will be used for asynchronous polling of input queues

run()

continually run the watcher to check all of the input queues for objects to save

watchrun()

set up async loop for polling

async watch()

function for asynchronous polling of input queues loops through each of the queues in watchin and checks if an object is present and then saves the object if found

class improv.watcher.Watcher(name, client)

Monitors the store as separate process TODO: Facilitate Watcher being used in multiple processes (shared list)

setLinks(links)

run()

saveObj(obj, name)

checkStoreInterface2()