pulsar.cache package

Submodules

pulsar.cache.persistence module

class pulsar.cache.persistence.PersistenceStore(filename, require_sync=True)

Bases: object

close()

pulsar.cache.util module

class pulsar.cache.util.Time

Bases: object

Time utilities of now that can be instrumented for testing.

classmethod now()

Return the current datetime.

pulsar.cache.util.atomicish_move(source, destination, tmp_suffix='_TMP')

Move source to destination without risk of partial moves.

> from tempfile import mkdtemp > from os.path import join, exists > temp_dir = mkdtemp() > source = join(temp_dir, “the_source”) > destination = join(temp_dir, “the_dest”) > open(source, “wb”).write(b”Hello World!”) > assert exists(source) > assert not exists(destination) > atomicish_move(source, destination) > assert not exists(source) > assert exists(destination)

Module contents

class pulsar.cache.Cache(cache_directory='file_cache')

Bases: PersistenceStore

Maintain a cache of uploaded files.

cache_file(local_path, ip, path)

Move a file from a temporary staging area into the cache.

cache_required(ip, path)

destination(token)

file_available(ip, path)