swh.scheduler.elasticsearch_memory module

Memory Elastic Search backend

class swh.scheduler.elasticsearch_memory.BasicSerializer(*args, **kwargs)

Bases: object

For memory elastic search implementation (not for production)

dumps(*args, **kwargs)

class swh.scheduler.elasticsearch_memory.BasicTransport(*args, **kwargs)

Bases: object

For memory elastic search implementation, (not for production)

class swh.scheduler.elasticsearch_memory.MemoryElasticsearch(*args, **kwargs)

Bases: object

Memory Elasticsearch instance (for test purposes)

Partial implementation oriented towards index storage (and not search)

For now, its sole client is the scheduler for task archival purposes.

create(index, **kwargs)

close(index, **kwargs)

Close index

open(index, **kwargs)

Open index

bulk(body, **kwargs)

Bulk insert document in index

mget(*args, body, index, **kwargs)

Bulk indexed documents retrieval

stats(index, **kwargs)

exists(index, **kwargs)

put_mapping(index, body, **kwargs)

get_mapping(index, **kwargs)

put_settings(index, body, **kwargs)

get_settings(index, **kwargs)