Index _ | A | B | C | D | F | G | I | K | M | N | P | R | S | U _ __call__() (kafkit.fastapi.dependencies.aiokafkaproducer.AioKafkaProducerDependency method) (kafkit.fastapi.dependencies.pydanticschemamanager.PydanticSchemaManagerDependency method) (kafkit.fastapi.dependencies.registryapi.RegistryApiDependency method) (kafkit.registry.Serializer method) A AioKafkaProducerDependency (class in kafkit.fastapi.dependencies.aiokafkaproducer) B BACKWARD (kafkit.registry.sansio.CompatibilityType attribute) BACKWARD_TRANSITIVE (kafkit.registry.sansio.CompatibilityType attribute) C CompatibilityType (class in kafkit.registry.sansio) create_ssl_context() (in module kafkit.ssl) D decipher_response() (in module kafkit.registry.sansio) decode_body() (in module kafkit.registry.sansio) delete() (kafkit.registry.sansio.RegistryApi method) deserialize() (kafkit.registry.Deserializer method) (kafkit.registry.manager.PydanticSchemaManager method) Deserializer (class in kafkit.registry) F FORWARD (kafkit.registry.sansio.CompatibilityType attribute) FORWARD_TRANSITIVE (kafkit.registry.sansio.CompatibilityType attribute) FULL (kafkit.registry.sansio.CompatibilityType attribute) FULL_TRANSITIVE (kafkit.registry.sansio.CompatibilityType attribute) G get() (kafkit.registry.sansio.RegistryApi method) (kafkit.registry.sansio.SubjectCache method) get_id() (kafkit.registry.sansio.SubjectCache method) get_schema() (kafkit.registry.sansio.SubjectCache method) get_schema_by_id() (kafkit.registry.sansio.RegistryApi method) get_schema_by_subject() (kafkit.registry.sansio.RegistryApi method) I id (kafkit.registry.MessageInfo attribute) initialize() (kafkit.fastapi.dependencies.aiokafkaproducer.AioKafkaProducerDependency method) (kafkit.fastapi.dependencies.pydanticschemamanager.PydanticSchemaManagerDependency method) (kafkit.fastapi.dependencies.registryapi.RegistryApiDependency method) insert() (kafkit.registry.sansio.SchemaCache method) (kafkit.registry.sansio.SubjectCache method) K kafka_producer_dependency (in module kafkit.fastapi.dependencies.aiokafkaproducer) KafkaConnectionSettings (class in kafkit.settings) KafkaSaslMechanism (class in kafkit.settings) KafkaSecurityProtocol (class in kafkit.settings) kafkit.fastapi.dependencies.aiokafkaproducer module kafkit.fastapi.dependencies.pydanticschemamanager module kafkit.fastapi.dependencies.registryapi module kafkit.registry module kafkit.registry.aiohttp module kafkit.registry.httpx module kafkit.registry.manager module kafkit.registry.sansio module kafkit.settings module kafkit.ssl module M make_headers() (in module kafkit.registry.sansio) message (kafkit.registry.MessageInfo attribute) MessageInfo (class in kafkit.registry) MockRegistryApi (class in kafkit.registry.sansio) module kafkit.fastapi.dependencies.aiokafkaproducer kafkit.fastapi.dependencies.pydanticschemamanager kafkit.fastapi.dependencies.registryapi kafkit.registry kafkit.registry.aiohttp kafkit.registry.httpx kafkit.registry.manager kafkit.registry.sansio kafkit.settings kafkit.ssl N NONE (kafkit.registry.sansio.CompatibilityType attribute) P patch() (kafkit.registry.sansio.RegistryApi method) PLAIN (kafkit.settings.KafkaSaslMechanism attribute) PLAINTEXT (kafkit.settings.KafkaSecurityProtocol attribute) PolySerializer (class in kafkit.registry) post() (kafkit.registry.sansio.RegistryApi method) put() (kafkit.registry.sansio.RegistryApi method) pydantic_schema_manager_dependency (in module kafkit.fastapi.dependencies.pydanticschemamanager) PydanticSchemaManager (class in kafkit.registry.manager) PydanticSchemaManagerDependency (class in kafkit.fastapi.dependencies.pydanticschemamanager) Python Enhancement Proposals PEP 440, [1] PEP 484 PEP 8 R RecordNameSchemaManager (class in kafkit.registry.manager) register() (kafkit.registry.Serializer class method) register_model() (kafkit.registry.manager.PydanticSchemaManager method) register_models() (kafkit.registry.manager.PydanticSchemaManager method) register_schema() (kafkit.registry.sansio.RegistryApi method) register_schemas() (kafkit.registry.manager.RecordNameSchemaManager method) registry_api_dependency (in module kafkit.fastapi.dependencies.registryapi) RegistryApi (class in kafkit.registry.aiohttp) (class in kafkit.registry.httpx) (class in kafkit.registry.sansio) RegistryApiDependency (class in kafkit.fastapi.dependencies.registryapi) RegistryBadRequestError RegistryBrokenError RegistryError RegistryHttpError RegistryRedirectionError S schema (kafkit.registry.MessageInfo attribute) schema_cache (kafkit.registry.sansio.RegistryApi attribute) SchemaCache (class in kafkit.registry.sansio) SCRAM_SHA_256 (kafkit.settings.KafkaSaslMechanism attribute) SCRAM_SHA_512 (kafkit.settings.KafkaSaslMechanism attribute) serialize() (kafkit.registry.manager.PydanticSchemaManager method) (kafkit.registry.manager.RecordNameSchemaManager method) (kafkit.registry.PolySerializer method) Serializer (class in kafkit.registry) set_subject_compatibility() (kafkit.registry.sansio.RegistryApi method) SSL (kafkit.settings.KafkaSecurityProtocol attribute) ssl_context (kafkit.settings.KafkaConnectionSettings attribute) stop() (kafkit.fastapi.dependencies.aiokafkaproducer.AioKafkaProducerDependency method) subject_cache (kafkit.registry.sansio.RegistryApi attribute) SubjectCache (class in kafkit.registry.sansio) U UnmanagedSchemaError