minos.saga.messages module¶

class minos.saga.messages.SagaRequest(target, content=None)[source]¶

Bases: object

Saga Request class.

async content(**kwargs)[source]¶

Get the content of the request.

property target: str¶

Get the target of the request.

class minos.saga.messages.SagaResponse(content=None, related_services=None, status=None, uuid=None, *args, **kwargs)[source]¶

Bases: object

Saga Response class.

__init__(content=None, related_services=None, status=None, uuid=None, *args, **kwargs)[source]¶

async content(**kwargs)[source]¶

Get the response content.

classmethod from_message(message)[source]¶

Build a new SagaResponse from a BrokerMessage.

Parameters: message (minos.networks.brokers.messages.BrokerMessage) – The BrokerMessage instance.
Return type: minos.saga.messages.SagaResponse
Returns: A SagaResponse.

property ok: bool¶

Check if the response is okay.

property related_services: set[str]¶

Get the microservice name that generated the response.

Get the status code of the response.

property uuid: uuid.UUID¶

Get the identifier of the saga execution that must receive the response.

class minos.saga.messages.SagaResponseStatus(value)[source]¶

Bases: enum.IntEnum

Saga Response Status class.

classmethod from_raw(raw)[source]¶

Build a new instance from raw.