ascetic_ddd.faker.domain.providers.interfaces

Classes

IAggregateProvider()

IAggregateRepository(*args, **kwargs)

ICloningShunt()

ICompositeValueProvider()

IDependentInputOutput()

IDependentProvider()

IEntityProvider()

IInputOutput()

ILifecycleAble()

INameable()

IProvidable()

IReferenceProvider()

ISetupable()

IValueProvider()

class ascetic_ddd.faker.domain.providers.interfaces.INameable[source]

Bases: object

abstract property provider_name : str
class ascetic_ddd.faker.domain.providers.interfaces.ICloningShunt[source]

Bases: object

class ascetic_ddd.faker.domain.providers.interfaces.ILifecycleAble[source]

Bases: object

abstractmethod reset(visited=None)[source]
Return type:

None

Parameters:
visited : set | None

abstractmethod clone(shunt=None)[source]
Return type:

Self

Parameters:
shunt : ICloningShunt | None

class ascetic_ddd.faker.domain.providers.interfaces.ISetupable[source]

Bases: object

abstractmethod async setup(session)[source]
Parameters:
session : ISession

abstractmethod async cleanup(session)[source]
Parameters:
session : ISession

class ascetic_ddd.faker.domain.providers.interfaces.IProvidable[source]

Bases: object

abstractmethod async populate(session)[source]
Return type:

None

Parameters:
session : ISession

abstractmethod is_complete()[source]
Return type:

bool

abstractmethod is_transient()[source]
Return type:

bool

class ascetic_ddd.faker.domain.providers.interfaces.IInputOutput[source]

Bases: Generic[InputT, OutputT]

abstractmethod output()[source]
Return type:

TypeVar(OutputT)

abstractmethod require(criteria)[source]
Return type:

None

Parameters:
criteria : dict[str, Any]

abstract property on_required : ISyncSignal[CriteriaRequiredEvent]
abstract property on_populated : IAsyncSignal[OutputPopulatedEvent[OutputT]]
abstractmethod state()[source]
Return type:

TypeVar(InputT)

abstractmethod export(output)[source]
Return type:

TypeVar(InputT)

Parameters:
output : __SPHINX_IMMATERIAL_TYPE_VAR__V_OutputT

abstractmethod async append(session, value)[source]
Parameters:
session : ISession

value : __SPHINX_IMMATERIAL_TYPE_VAR__V_OutputT

class ascetic_ddd.faker.domain.providers.interfaces.IValueProvider[source]

Bases: IInputOutput[InputT, OutputT], IProvidable, INameable, ILifecycleAble, ISetupable, Generic[InputT, OutputT]

class ascetic_ddd.faker.domain.providers.interfaces.ICompositeValueProvider[source]

Bases: IValueProvider[CompositeInputT, CompositeOutputT], Generic[CompositeInputT, CompositeOutputT]

abstract property providers : dict[str, IValueProvider[Any, Any]]
abstract property dependent_providers : dict[str, IDependentProvider[Any, Any, Any, Any]]
class ascetic_ddd.faker.domain.providers.interfaces.IEntityProvider[source]

Bases: ICompositeValueProvider[AggInputT, AggOutputT], Generic[AggInputT, AggOutputT, IdInputT, IdOutputT]

abstract property id_provider : IValueProvider[IdInputT, IdOutputT]
class ascetic_ddd.faker.domain.providers.interfaces.IAggregateRepository(*args, **kwargs)[source]

Bases: Protocol[AggOutputT]

property table : str
property on_inserted : IAsyncSignal[AggregateInsertedEvent[AggOutputT]]
property on_updated : IAsyncSignal[AggregateUpdatedEvent[AggOutputT]]
async insert(session, agg)[source]
Parameters:
session : ISession

agg : __SPHINX_IMMATERIAL_TYPE_VAR__V_AggOutputT

async get(session, id_)[source]
Return type:

Optional[TypeVar(AggOutputT, bound= object)]

Parameters:
session : ISession

id_ : IAccessible[Any]

async update(session, agg)[source]
Parameters:
session : ISession

agg : __SPHINX_IMMATERIAL_TYPE_VAR__V_AggOutputT

async find(session, specification)[source]
Return type:

Iterable[TypeVar(AggOutputT, bound= object)]

Parameters:
session : ISession

specification : ISpecification

async setup(session)[source]
Parameters:
session : ISession

async cleanup(session)[source]
Parameters:
session : ISession

class ascetic_ddd.faker.domain.providers.interfaces.IAggregateProvider[source]

Bases: IEntityProvider[AggInputT, AggOutputT, IdInputT, IdOutputT], Generic[AggInputT, AggOutputT, IdInputT, IdOutputT]

abstract property repository : IAggregateRepository[AggOutputT]
class ascetic_ddd.faker.domain.providers.interfaces.IReferenceProvider[source]

Bases: IValueProvider[IdInputT, IdOutputT], Generic[IdInputT, IdOutputT, AggInputT, AggOutputT]

abstract property aggregate_provider : IAggregateProvider[AggInputT, AggOutputT, IdInputT, IdOutputT]
class ascetic_ddd.faker.domain.providers.interfaces.IDependentInputOutput[source]

Bases: Generic[InputT, OutputT]

abstractmethod create()[source]
Return type:

list[TypeVar(OutputT)]

abstractmethod require(criteria, weights=None)[source]
Return type:

None

Parameters:
criteria : list[dict]

weights : list[float] | None

abstract property on_required : ISyncSignal[DependentCriteriaRequiredEvent]
abstract property on_populated : IAsyncSignal[OutputPopulatedEvent[list[OutputT]]]
abstractmethod state()[source]
Return type:

list[TypeVar(InputT)]

abstractmethod export(output)[source]
Return type:

TypeVar(InputT)

Parameters:
output : __SPHINX_IMMATERIAL_TYPE_VAR__V_OutputT

class ascetic_ddd.faker.domain.providers.interfaces.IDependentProvider[source]

Bases: IDependentInputOutput[IdInputT, IdOutputT], IProvidable, INameable, ILifecycleAble, ISetupable, Generic[IdInputT, IdOutputT, AggInputT, AggOutputT]

abstract property aggregate_providers : list[IAggregateProvider[AggInputT, AggOutputT, IdInputT, IdOutputT]]
abstractmethod set_dependency_id(dependency_id)[source]
Return type:

None

Parameters:
dependency_id : __SPHINX_IMMATERIAL_TYPE_VAR__V_IdInputT