ascetic_ddd.faker.domain.distributors.m2o.interfaces

Classes

IExternalSource(*args, **kwargs)

IM2ODistributor(*args, **kwargs)

IM2ODistributorFactory(*args, **kwargs)

Exceptions

ICursor

class ascetic_ddd.faker.domain.distributors.m2o.interfaces.IM2ODistributor(*args, **kwargs)[source]

Bases: IObservable, Generic[T]

abstractmethod async next(session, specification=None)[source]

Returns next value from distribution. Raises ICursor(num) when mean is reached, signaling caller to create new value. num is sequence position (for SequenceDistributor) or None.

Return type:

TypeVar(T, covariant=True)

Parameters:
session : ISession

specification : ISpecification[__SPHINX_IMMATERIAL_TYPE_VAR__V_T] | None

abstractmethod async append(session, value)[source]

Appends value to the distributor.

Parameters:
session : ISession

value : __SPHINX_IMMATERIAL_TYPE_VAR__V_T

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

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

abstractmethod bind_external_source(external_source)[source]

Binds an external data source (repository).

Return type:

None

Parameters:
external_source : Any

class ascetic_ddd.faker.domain.distributors.m2o.interfaces.IM2ODistributorFactory(*args, **kwargs)[source]

Bases: Protocol[T]

exception ascetic_ddd.faker.domain.distributors.m2o.interfaces.ICursor[source]

Bases: Generic[T], StopAsyncIteration

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

value : __SPHINX_IMMATERIAL_TYPE_VAR__V_T

class ascetic_ddd.faker.domain.distributors.m2o.interfaces.IExternalSource(*args, **kwargs)[source]

Bases: IObservable, Protocol[T]