minos.aggregate.entities.refs.resolvers

Classes

Ref Resolver class.

class RefResolver[source]

Bases: object

Ref Resolver class.

__init__(broker_pool=None, pool_factory=None, **kwargs)[source]

Parameters

broker_pool (Optional[BrokerClientPool]) –
pool_factory (Optional[PoolFactory]) –

async resolve(data, **kwargs)[source]

Resolve Ref instances.

Parameters

data (Any) – The data to be resolved.
kwargs – Additional named arguments.

Returns

The data instance with model references already resolved.

Return type

static build_topic_name(entity)[source]

Build the topic name based on the name of the entity.

Parameters: entity (Union[type, str]) – The name of the entity to be resolved.
Returns: The topic name.
Return type: str