minos.aggregate.transactions.entries module¶

class minos.aggregate.transactions.entries.TransactionEntry(uuid=None, status=None, event_offset=None, destination_uuid=None, updated_at=None, autocommit=True, event_repository=<dependency_injector.wiring.Provide object>, transaction_repository=<dependency_injector.wiring.Provide object>)[source]¶

Bases: object

Transaction Entry class.

__init__(uuid=None, status=None, event_offset=None, destination_uuid=None, updated_at=None, autocommit=True, event_repository=<dependency_injector.wiring.Provide object>, transaction_repository=<dependency_injector.wiring.Provide object>)[source]¶

async commit()[source]¶

Commit transaction changes.

Return type: None
Returns: This method does not return anything.

property destination: Optional[minos.aggregate.transactions.entries.TransactionEntry]¶

Get the destination transaction if there is anyone, otherwise None is returned.

Return type: typing.Optional[minos.aggregate.transactions.entries.TransactionEntry]
Returns: A TransactionEntry or None.

destination_uuid¶

event_offset¶

async reject()[source]¶

Reject transaction changes.

Return type: None
Returns: This method does not return anything.

async reserve()[source]¶

Reserve transaction changes to be ensured that they can be applied.

Return type: None
Returns: This method does not return anything.

async save(*, event_offset=None, status=None)[source]¶

Saves the transaction into the repository.

Parameters

event_offset (typing.Optional[int]) – The event offset.
status (typing.Optional[minos.aggregate.transactions.entries.TransactionStatus]) – The status.

Return type

None

Returns

This method does not return anything.

status¶

updated_at¶

uuid¶

property uuids: tuple[uuid.UUID, ...]¶

Get the sequence of transaction identifiers, from the outer one (NULL_UUID) to the one related with self.

Return type: tuple[uuid.UUID, …]
Returns: A tuple of UUID values.

async validate()[source]¶

Check if the transaction is committable.

Return type: bool
Returns: True if the transaction is valid or False otherwise.

class minos.aggregate.transactions.entries.TransactionStatus(value)[source]¶

Bases: str, enum.Enum

Transaction Status Enum.

COMMITTED = 'committed'¶

COMMITTING = 'committing'¶

PENDING = 'pending'¶

REJECTED = 'rejected'¶

RESERVED = 'reserved'¶

RESERVING = 'reserving'¶

classmethod value_of(value)[source]¶

Get the status based on its text representation.

Return type: minos.aggregate.transactions.entries.TransactionStatus