minos.plugins.aiopg.factories.networks.subscribers.queues

Classes

AiopgBrokerSubscriberQueueDatabaseOperationFactory

Aiopg Broker Subscriber Queue Database Operation Factory class.

class AiopgBrokerSubscriberQueueDatabaseOperationFactory[source]

Bases: BrokerSubscriberQueueDatabaseOperationFactory, AiopgBrokerQueueDatabaseOperationFactory

Aiopg Broker Subscriber Queue Database Operation Factory class.

build_table_name()[source]

Get the table name.

Returns: A str value.
Return type: str

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

Build the “count not processed” query.

Returns

Parameters

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

Return type

DatabaseOperation

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

build_create()

Build the “create table” query.

Returns: A SQL instance.
Return type: DatabaseOperation

build_delete(id_)

Build the “delete processed” query.

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

build_mark_processed(id_)

Build the “update not processed” query.

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

build_mark_processing(ids)

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

build_submit(topic, data)

Build the “insert” query.

Returns

A SQL instance.

Parameters

topic (str) –
data (bytes) –

Return type

DatabaseOperation