tinvest_signal_engine.models

tinvest_signal_engine.models

Доменные модели потока: нормализованное событие и сигнал детектора.

---

tinvest_signal_engine.serialization

tinvest_signal_engine.serialization

Утилиты времени, JSON-совместимых структур и котировок из payload.

kafka_json_serializer

kafka_json_serializer(value: Any) -> bytes

Kafka value_serializer for dict payloads on the hot path.

Source code in src/tinvest_signal_engine/serialization.py

def kafka_json_serializer(value: Any) -> bytes:
    """Kafka ``value_serializer`` for dict payloads on the hot path."""
    if isinstance(value, dict):
        return orjson.dumps(value, default=_orjson_default)
    if isinstance(value, (bytes, bytearray, memoryview)):
        return bytes(value)
    return orjson.dumps(value, default=_orjson_default)