swh.scheduler.elasticsearch_memory module

Memory Elastic Search backend

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

Bases: object

For memory elastic search implementation (not for production)

dumps(*args, **kwargs)[source]
class swh.scheduler.elasticsearch_memory.BasicTransport(*args, **kwargs)[source]

Bases: object

For memory elastic search implementation, (not for production)

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

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)[source]
close(index, **kwargs)[source]

Close index

open(index, **kwargs)[source]

Open index

bulk(body, **kwargs)[source]

Bulk insert document in index

mget(*args, body, index, **kwargs)[source]

Bulk indexed documents retrieval

stats(index, **kwargs)[source]
exists(index, **kwargs)[source]
put_mapping(index, body, **kwargs)[source]
get_mapping(index, **kwargs)[source]
put_settings(index, body, **kwargs)[source]
get_settings(index, **kwargs)[source]