minos.saga.messages

Classes

class SagaRequest[source]

Saga Request class.

__init__(target, content=None)[source]

Parameters

property target: str

Get the target of the request.

async content(**kwargs)[source]

Get the content of the request.

class SagaResponse[source]

Saga Response class.

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

Parameters

classmethod from_message(message)[source]

Build a new SagaResponse from a BrokerMessage.

async content(**kwargs)[source]

Get the response content.

property ok: bool

Check if the response is okay.

Get the status code of the response.

property related_services: set[str]

Get the microservice name that generated the response.

property uuid: uuid.UUID

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

class SagaResponseStatus[source]

Bases: IntEnum

Saga Response Status class.

classmethod from_raw(raw)[source]

Build a new instance from raw.