minos.networks.brokers.subscribers.filtered.validators.duplicates.memory

Classes

InMemoryBrokerSubscriberDuplicateValidator

In Memory Broker Subscriber Duplicate Detector class.
class InMemoryBrokerSubscriberDuplicateValidator[source]

Bases: BrokerSubscriberDuplicateValidator

In Memory Broker Subscriber Duplicate Detector class.

__init__(seen=None, *args, **kwargs)[source]
Parameters

seen (Optional[Iterable[tuple[str, uuid.UUID]]]) –

property seen: set[tuple[str, uuid.UUID]]

Get the seen pairs.

Returns

A set of tuple instances in which the first value is a str and the second an UUID.

property already_destroyed: bool

Already Destroy getter.

Returns

A boolean value.

property already_setup: bool

Already Setup getter.

Returns

A boolean value.

async destroy()

Destroy miscellaneous repository things.

Returns

This method does not return anything.

Return type

None

classmethod from_config(config=None, **kwargs)

Build a new instance from config.

Parameters

  • config (Optional[Union[Config, Path]]) – Config instance. If None is provided, default config is chosen.

  • kwargs – Additional named arguments.

Returns

A instance of the called class.

Return type

S

classmethod get_builder()

Get the builder class.

Returns

A Builder instance.

Return type

Builder[Ins]

async is_valid(message)

Check if the given message is valid.

Parameters

message (BrokerMessage) – The message to be checked.

Returns

True if it is valid or False otherwise.

Return type

bool

classmethod set_builder(builder)

Set a builder class.

Parameters

builder (Union[Builder[Ins], type[minos.common.builders.Builder[~Ins]]]) – The builder class to be set.

Returns

This method does not return anything.

Return type

None

async setup()

Setup miscellaneous repository things.

Returns

This method does not return anything.

Return type

None