minos.networks.brokers.subscribers.queued.queues.database.factories

Classes

BrokerSubscriberQueueDatabaseOperationFactory

Broker Subscriber Queue Database Operation Factory class.

class BrokerSubscriberQueueDatabaseOperationFactory[source]

Bases: BrokerQueueDatabaseOperationFactory, ABC

Broker Subscriber Queue Database Operation Factory class.

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

Build the “count not processed” query.

Returns

Parameters

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

Return type

DatabaseOperation

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

Build the “select not processed” query.

Returns

A SQL instance.

Parameters

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

Return type

DatabaseOperation

abstract build_create()

Build the “create table” query.

Returns: A SQL instance.
Return type: DatabaseOperation

abstract build_delete(id_)

Build the “delete processed” query.

Returns: A SQL instance.
Parameters: id_ (int) –
Return type: DatabaseOperation

abstract build_mark_processed(id_)

Build the “update not processed” query.

Returns: A SQL instance.
Parameters: id_ (int) –
Return type: DatabaseOperation

abstract build_mark_processing(ids)

Returns: A SQL instance.
Parameters: ids (Iterable[int]) –
Return type: DatabaseOperation

abstract build_submit(topic, data)

Build the “insert” query.

Returns

A SQL instance.

Parameters

topic (str) –
data (bytes) –

Return type

DatabaseOperation