minos.networks.testing.brokers.publishers.queues

Classes

MockedBrokerPublisherQueueDatabaseOperationFactory

For testing purposes

class MockedBrokerPublisherQueueDatabaseOperationFactory[source]

Bases: BrokerPublisherQueueDatabaseOperationFactory, MockedBrokerQueueDatabaseOperationFactory

For testing purposes

build_count(retry, *args, **kwargs)

For testing purposes

Parameters

retry (int) –

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_query(retry, records, *args, **kwargs)

For testing purposes

Parameters
  • retry (int) –

  • records (int) –

Return type

DatabaseOperation

build_submit(topic, data)

For testing purposes

Parameters
Return type

DatabaseOperation