API Reference
- demessaging package
BackendModuleBackendModule.backend_configBackendModule.compute()BackendModule.create_model()BackendModule.generate()BackendModule.get_api_info()BackendModule.handle_message()BackendModule.listen()BackendModule.model_computed_fieldsBackendModule.model_configBackendModule.model_fieldsBackendModule.model_json_schema()BackendModule.process_request()BackendModule.pulsarBackendModule.rootBackendModule.send_request()BackendModule.shell()BackendModule.test_connect()
configure()main()- Subpackages
- demessaging.backend package
main()- Submodules
- demessaging.backend.class_ module
BackendClassBackendClassConfigBackendClassConfig.ClassBackendClassConfig.annotationsBackendClassConfig.class_nameBackendClassConfig.docBackendClassConfig.field_paramsBackendClassConfig.init_docBackendClassConfig.json_schema_extraBackendClassConfig.method_configsBackendClassConfig.methodsBackendClassConfig.model_computed_fieldsBackendClassConfig.model_configBackendClassConfig.model_fieldsBackendClassConfig.modelsBackendClassConfig.nameBackendClassConfig.registryBackendClassConfig.reporter_argsBackendClassConfig.serializersBackendClassConfig.signatureBackendClassConfig.templateBackendClassConfig.update_from_cls()BackendClassConfig.validators
ClassAPIModel
- demessaging.backend.function module
BackendFunctionBackendFunctionConfigBackendFunctionConfig.annotationsBackendFunctionConfig.class_nameBackendFunctionConfig.docBackendFunctionConfig.field_paramsBackendFunctionConfig.functionBackendFunctionConfig.json_schema_extraBackendFunctionConfig.model_computed_fieldsBackendFunctionConfig.model_configBackendFunctionConfig.model_fieldsBackendFunctionConfig.nameBackendFunctionConfig.registryBackendFunctionConfig.reporter_argsBackendFunctionConfig.return_annotationBackendFunctionConfig.return_serializerBackendFunctionConfig.return_validatorsBackendFunctionConfig.returnsBackendFunctionConfig.serializersBackendFunctionConfig.signatureBackendFunctionConfig.templateBackendFunctionConfig.update_from_function()BackendFunctionConfig.validators
FunctionAPIModelReturnModelget_return_model()
- demessaging.backend.module module
BackendModuleBackendModule.backend_configBackendModule.compute()BackendModule.create_model()BackendModule.generate()BackendModule.get_api_info()BackendModule.handle_message()BackendModule.listen()BackendModule.model_computed_fieldsBackendModule.model_configBackendModule.model_fieldsBackendModule.model_json_schema()BackendModule.process_request()BackendModule.pulsarBackendModule.rootBackendModule.send_request()BackendModule.shell()BackendModule.test_connect()
BackendModuleConfigBackendModuleConfig.class_nameBackendModuleConfig.debugBackendModuleConfig.docBackendModuleConfig.importsBackendModuleConfig.json_schema_extraBackendModuleConfig.listen_configBackendModuleConfig.log_configBackendModuleConfig.membersBackendModuleConfig.messaging_configBackendModuleConfig.model_computed_fieldsBackendModuleConfig.model_configBackendModuleConfig.model_fieldsBackendModuleConfig.modelsBackendModuleConfig.moduleBackendModuleConfig.registryBackendModuleConfig.template
ModuleAPIModel
- demessaging.backend.utils module
- demessaging.backend.class_ module
- demessaging.config package
- Submodules
- demessaging.config.api module
- demessaging.config.backend module
BaseConfigClassConfigClassConfig.annotationsClassConfig.docClassConfig.field_paramsClassConfig.init_docClassConfig.json_schema_extraClassConfig.methodsClassConfig.model_computed_fieldsClassConfig.model_configClassConfig.model_fieldsClassConfig.nameClassConfig.registryClassConfig.reporter_argsClassConfig.serializersClassConfig.signatureClassConfig.templateClassConfig.validators
FunctionConfigFunctionConfig.annotationsFunctionConfig.docFunctionConfig.field_paramsFunctionConfig.json_schema_extraFunctionConfig.model_computed_fieldsFunctionConfig.model_configFunctionConfig.model_fieldsFunctionConfig.nameFunctionConfig.registryFunctionConfig.reporter_argsFunctionConfig.return_annotationFunctionConfig.return_serializerFunctionConfig.return_validatorsFunctionConfig.returnsFunctionConfig.serializersFunctionConfig.signatureFunctionConfig.templateFunctionConfig.validators
ListenConfigModuleConfigModuleConfig.debugModuleConfig.docModuleConfig.importsModuleConfig.json_schema_extraModuleConfig.listen_configModuleConfig.log_configModuleConfig.membersModuleConfig.messaging_configModuleConfig.model_computed_fieldsModuleConfig.model_configModuleConfig.model_fieldsModuleConfig.pulsar_configModuleConfig.registryModuleConfig.template
- demessaging.config.logging module
- demessaging.config.messaging module
BaseMessagingConfigBaseMessagingConfig.get_topic_url()BaseMessagingConfig.headerBaseMessagingConfig.max_payload_sizeBaseMessagingConfig.max_workersBaseMessagingConfig.model_computed_fieldsBaseMessagingConfig.model_configBaseMessagingConfig.model_fieldsBaseMessagingConfig.model_post_init()BaseMessagingConfig.producerBaseMessagingConfig.producer_connection_timeoutBaseMessagingConfig.producer_keep_aliveBaseMessagingConfig.queue_sizeBaseMessagingConfig.topicBaseMessagingConfig.validate_queue_size()
PulsarConfigPulsarConfig.get_topic_url()PulsarConfig.headerPulsarConfig.hostPulsarConfig.max_payload_sizePulsarConfig.max_workersPulsarConfig.model_computed_fieldsPulsarConfig.model_configPulsarConfig.model_fieldsPulsarConfig.model_post_init()PulsarConfig.namespacePulsarConfig.persistentPulsarConfig.portPulsarConfig.producer_connection_timeoutPulsarConfig.producer_keep_alivePulsarConfig.queue_sizePulsarConfig.tenantPulsarConfig.topic
WebsocketURLConfigWebsocketURLConfig.consumer_urlWebsocketURLConfig.get_topic_url()WebsocketURLConfig.headerWebsocketURLConfig.max_payload_sizeWebsocketURLConfig.max_workersWebsocketURLConfig.model_computed_fieldsWebsocketURLConfig.model_configWebsocketURLConfig.model_fieldsWebsocketURLConfig.model_post_init()WebsocketURLConfig.producer_connection_timeoutWebsocketURLConfig.producer_keep_aliveWebsocketURLConfig.producer_urlWebsocketURLConfig.queue_sizeWebsocketURLConfig.topicWebsocketURLConfig.websocket_url
- demessaging.config.registry module
- Submodules
- demessaging.messaging package
- Submodules
- demessaging.messaging.connection module
- demessaging.messaging.constants module
- demessaging.messaging.consumer module
MessageConsumerMessageConsumer.RECONNECT_TIMEOUT_SLEEPMessageConsumer.SOCKET_PING_INTERVALMessageConsumer.acknowledge()MessageConsumer.close_websocket_app()MessageConsumer.disconnect()MessageConsumer.extract_context()MessageConsumer.extract_message_type()MessageConsumer.extract_response_topic()MessageConsumer.handle_api_info()MessageConsumer.handle_info()MessageConsumer.handle_pong()MessageConsumer.handle_request_via_queue()MessageConsumer.is_valid_request()MessageConsumer.is_valid_value()MessageConsumer.on_message()MessageConsumer.on_producer_message()MessageConsumer.open_producer_app()MessageConsumer.producer_locksMessageConsumer.producer_threadsMessageConsumer.producer_timerMessageConsumer.producersMessageConsumer.request_semaphoreMessageConsumer.reset_close_timer()MessageConsumer.send_error()MessageConsumer.send_pong()MessageConsumer.send_response()MessageConsumer.setup_subscription()MessageConsumer.wait_for_request()MessageConsumer.wait_for_websocket_connection()
- demessaging.messaging.producer module
MessageProducerMessageProducer.RECONNECT_TIMEOUT_SLEEPMessageProducer.SOCKET_PING_INTERVALMessageProducer.connect()MessageProducer.disconnect()MessageProducer.in_appMessageProducer.is_connectedMessageProducer.on_in_message()MessageProducer.on_out_message()MessageProducer.out_appMessageProducer.response_topicMessageProducer.send_request()MessageProducer.setup_subscription()MessageProducer.subscription_nameMessageProducer.wait_for_connection()
- Submodules
- demessaging.serializers package
- demessaging.validators package
- demessaging.backend package
- Submodules