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

Classes

AiopgBrokerPublisherQueueDatabaseOperationFactory

Aiopg Broker Publisher Queue Query Factory class.

class AiopgBrokerPublisherQueueDatabaseOperationFactory[source]

Bases: BrokerPublisherQueueDatabaseOperationFactory, AiopgBrokerQueueDatabaseOperationFactory

Aiopg Broker Publisher Queue Query Factory class.

build_table_name()[source]

Get the table name.

Returns: A str value.
Return type: str

build_count(retry, *args, **kwargs)

Build the “count not processed” query.

Returns
Parameters: retry (int) –
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_query(retry, records, *args, **kwargs)

Build the “select not processed” query.

Returns

A SQL instance.

Parameters

retry (int) –
records (int) –

Return type

DatabaseOperation

build_submit(topic, data)

Build the “insert” query.

Returns

A SQL instance.

Parameters

topic (str) –
data (bytes) –

Return type

DatabaseOperation