search.datamanager

Attributes

`_DATAMANAGERS`
`_DATAMANAGERS`

Classes

`TaskQueue`	Built-in mutable sequence.
`IndexerDataManager`	Flushes pending indexing tasks to the database.
`IndexerSavepoint`

Module Contents

class search.datamanager.TaskQueue(max_size: int = 0)[source]

Bases: list[onegov.search.indexer.Task]

Built-in mutable sequence.

If no argument is given, the constructor creates a new empty list. The argument must be an iterable if specified.

max_size = 0[source]

append(value: onegov.search.indexer.Task) → None[source]: Append object to the end of the list.

search.datamanager._DATAMANAGERS: weakref.WeakKeyDictionary[sqlalchemy.orm.Session, IndexerDataManager][source]

search.datamanager._DATAMANAGERS[source]

class search.datamanager.IndexerDataManager(session: sqlalchemy.orm.Session, indexer: onegov.search.indexer.Indexer, max_queue_size: int = 0)[source]

Flushes pending indexing tasks to the database.

transaction_manager[source]

queue: TaskQueue | None[source]

session: sqlalchemy.orm.Session | None[source]

indexer: onegov.search.indexer.Indexer | None[source]

classmethod get_queue(session: sqlalchemy.orm.Session | None, indexer: onegov.search.indexer.Indexer, max_queue_size: int = 0) → TaskQueue | None[source]

_finish() → None[source]

sortKey() → str[source]

commit(transaction: transaction.interfaces.ITransaction) → None[source]

abort(transaction: transaction.interfaces.ITransaction) → None[source]

tpc_begin(transaction: transaction.interfaces.ITransaction) → None[source]

tpc_vote(transaction: transaction.interfaces.ITransaction) → None[source]

tpc_abort(transaction: transaction.interfaces.ITransaction) → None[source]

tpc_finish(transaction: transaction.interfaces.ITransaction) → None[source]

savepoint() → IndexerSavepoint[source]

class search.datamanager.IndexerSavepoint(queue: TaskQueue)[source]

queue[source]

saved_size[source]

rollback() → None[source]