minos.networks.testing.brokers.collections.queues

Classes

MockedBrokerQueueDatabaseOperationFactory

For testing purposes.

class MockedBrokerQueueDatabaseOperationFactory[source]

Bases: BrokerQueueDatabaseOperationFactory

For testing purposes.

build_create()[source]

For testing purposes

Return type: DatabaseOperation

build_mark_processed(id_)[source]

For testing purposes

Parameters: id_ (int) –
Return type: DatabaseOperation

build_delete(id_)[source]

For testing purposes

Parameters: id_ (int) –
Return type: DatabaseOperation

build_mark_processing(ids)[source]

For testing purposes

Parameters: ids (Iterable[int]) –
Return type: DatabaseOperation

build_count(retry, *args, **kwargs)[source]

For testing purposes

Parameters: retry (int) –
Return type: DatabaseOperation

build_submit(topic, data)[source]

For testing purposes

Parameters

topic (str) –
data (bytes) –

Return type

DatabaseOperation

build_query(retry, records, *args, **kwargs)[source]

For testing purposes

Parameters

retry (int) –
records (int) –

Return type

DatabaseOperation