spreadflow_observer_fs.protocol module

class spreadflow_observer_fs.protocol.MessageFactory(port_name=u'default')

Bases: object

CHUNK_SIZE = 8

replace(paths, metadata)

update(deletable_paths, insertable_paths, insertable_meta)

class spreadflow_observer_fs.protocol.Repository

Bases: object

replace(repo)

update(deletes, inserts)