minos.networks.testing.brokers.subscribers.queues

Classes

MockedBrokerSubscriberQueueDatabaseOperationFactory

For testing purposes

class MockedBrokerSubscriberQueueDatabaseOperationFactory[source]

Bases: BrokerSubscriberQueueDatabaseOperationFactory, MockedBrokerQueueDatabaseOperationFactory

For testing purposes

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

For testing purposes

Parameters

retry (int) –
topics (Iterable[str]) –

Return type

DatabaseOperation

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

For testing purposes

Parameters

retry (int) –
records (int) –
topics (Iterable[str]) –

Return type

DatabaseOperation

build_create()

For testing purposes

Return type: DatabaseOperation

build_delete(id_)

For testing purposes

Parameters: id_ (int) –
Return type: DatabaseOperation

build_mark_processed(id_)

For testing purposes

Parameters: id_ (int) –
Return type: DatabaseOperation

build_mark_processing(ids)

For testing purposes

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

build_submit(topic, data)

For testing purposes

Parameters

topic (str) –
data (bytes) –

Return type

DatabaseOperation