Index

A

accuracy (core.model.ModelMetrics property) ALGO_DEFLATE (core.crypto.qat.QATZip attribute)

algorithm (core.crypto.qat.QATZip property) api_get_pipelines() (in module userv.pipeline_server)

B

buffer_len (core.inferqueue.InferQueueClientBase property)

C

calculate_fps() (userv.inference.InferenceTask method) CameraSource (class in core.stream) check_table_object_exist() (core.rtdb.RedisDB method) (core.rtdb.RuntimeDatabaseBase method) clean_infer_engine() (core.pipeline.PipelineManager method) cleanup() (userv.inference.InferenceService method) (userv.streaming.StreamingService method) (userv.uapp.MicroAppBase method) close() (core.stream.CameraSource method) (core.stream.FileSource method) (core.stream.StreamProvider method) close_session() (core.crypto.qat.QATZip method) comp_lvl (core.crypto.qat.QATZip property) compress() (core.crypto.qat.QATZip method) connect() (core.inferqueue.InferQueueClientBase method) (core.inferqueue.KafkaInferQueueClient method) (core.inferqueue.RedisInferQueueClient method) (core.rtdb.RedisDB method) (core.rtdb.RuntimeDatabaseBase method) (core.streambroker.KafkaStreamBrokerClient method) (core.streambroker.RedisStreamBrokerClient method) (core.streambroker.StreamBrokerClientBase method) core module core.crypto.qat module core.engines module core.engines.tensorflow_engine module

core.filedb module core.frame module core.infereng module core.inferqueue module core.metrics module core.model module core.pipeline module core.processors module core.processors.category_list module core.processors.postprocessor module core.processors.preprocessor module core.rtdb module core.stream module core.streambroker module COUNTER (core.metrics.MetricType attribute) create_metric() (core.metrics.MetricsManager method) create_stream_from_type() (in module core.stream)

D

db (userv.inference.InferenceService property) (userv.pipeline_server.PipelineService property) (userv.streaming.StreamingService property) decompress() (core.crypto.qat.QATZip method) decrypt() (core.frame.Frame method) (core.frame.FrameCipherBase method) (core.frame.QATFrameCipher method) DEFAULT_FPS (core.stream.StreamProvider attribute) DEFAULT_HEIGHT (core.stream.StreamProvider attribute) DEFAULT_TARGET_FPS (core.stream.FileSource attribute) DEFAULT_WIDTH (core.stream.StreamProvider attribute) del_table_object() (core.rtdb.RedisDB method) (core.rtdb.RuntimeDatabaseBase method)

details (core.model.ModelInfo property) device (core.engines.tensorflow_engine.TFModelConfig property) (core.infereng.InferenceInfo property) DIR_BOTH (core.crypto.qat.QATZip attribute) DIR_COMPRESS (core.crypto.qat.QATZip attribute) DIR_DECOMPRESS (core.crypto.qat.QATZip attribute) direction (core.crypto.qat.QATZip property) drawing (core.engines.tensorflow_engine.TFModelConfig property) drop() (core.inferqueue.InferQueueClientBase method) (core.inferqueue.KafkaInferQueueClient method) (core.inferqueue.RedisInferQueueClient method) dtype (core.engines.tensorflow_engine.TFModelConfig property) (core.model.ModelDetails property)

E

encrypt() (core.frame.Frame method) (core.frame.FrameCipherBase method) (core.frame.QATFrameCipher method) entry() (in module userv.inference) (in module userv.streaming)

ErrorMessage (class in core.metrics) execute() (userv.inference.InferenceTask method) (userv.streaming.StreamingTask method) (userv.uapp.MicroServiceTask method) EXPANSION_RATIO (core.crypto.qat.QATZip attribute) export_fps_metrics() (userv.inference.InferenceTask method)

F

f1_score (core.model.ModelMetrics property) FaceRecognitionPostprocessor (class in core.processors.postprocessor) file_db (core.stream.FileSource property) FileDatabase (class in core.filedb)

FileSource (class in core.stream) Frame (class in core.frame) FrameCipherBase (class in core.frame) framework (core.model.ModelDetails property) from_blob() (core.frame.Frame static method)

G

GAUGE (core.metrics.MetricType attribute) get_all_table_objects_dict() (core.rtdb.RedisDB method) (core.rtdb.RuntimeDatabaseBase method) get_env() (userv.uapp.MicroAppBase static method) get_file() (core.filedb.FileDatabase method) (core.filedb.LocalFileDatabase method) get_frame() (core.inferqueue.InferQueueClientBase method) (core.inferqueue.KafkaInferQueueClient method) (core.inferqueue.RedisInferQueueClient method)

get_metric() (core.metrics.MetricsManager method) get_metrics() (core.metrics.MetricsManager method) get_sequence() (core.frame.Frame class method) get_table_object_dict() (core.rtdb.RedisDB method) (core.rtdb.RuntimeDatabaseBase method)

H

health_check() (in module userv.pipeline_server)

HISTOGRAM (core.metrics.MetricType attribute)

I

id (core.infereng.InferenceInfo property) (core.model.ModelInfo property) (core.pipeline.Pipeline property) increment_counter() (core.metrics.MetricsManager method) infer_broker_connector (userv.inference.InferenceService property) infer_engine_info (userv.streaming.StreamingService property) infer_engine_manager (userv.inference.InferenceService property) (userv.streaming.StreamingService property) INFER_ENGINE_TABLE (userv.pipeline_server.PipelineService attribute) infer_info (userv.inference.InferenceService property) infer_queue_available() (core.inferqueue.InferQueueClientBase method) (core.inferqueue.KafkaInferQueueClient method) (core.inferqueue.RedisInferQueueClient method) infer_queue_connector (userv.inference.InferenceService property) (userv.streaming.StreamingService property)

inference_engine (userv.inference.InferenceService property) InferenceEngine (class in core.infereng) InferenceInfo (class in core.infereng) InferenceService (class in userv.inference) InferenceTask (class in userv.inference) InferEngineManager (class in core.infereng) InferQueueClientBase (class in core.inferqueue) init() (userv.inference.InferenceService method) (userv.streaming.StreamingService method) (userv.uapp.MicroAppBase method) init_session() (core.crypto.qat.QATZip method) input_size (core.engines.tensorflow_engine.TensorFlowEngine property) (core.infereng.InferenceInfo property) inst() (userv.pipeline_server.PipelineService class method) INVALID_METRIC_TYPE (core.metrics.ErrorMessage attribute) is_task_stopping (userv.uapp.MicroServiceTask property)

K

KafkaInferQueueClient (class in core.inferqueue)

KafkaStreamBrokerClient (class in core.streambroker)

L

LAST (core.crypto.qat.QATZip attribute) last_sequence (core.frame.Frame attribute) latency_decorator() (core.metrics.MetricsManager method) LEVEL_BEST (core.crypto.qat.QATZip attribute)

LEVEL_FAST (core.crypto.qat.QATZip attribute) LocalFileDatabase (class in core.filedb) lock() (core.rtdb.RedisDB method) loss (core.model.ModelMetrics property)

M

MAX_RECONNECTION_TIMES (core.inferqueue.InferQueueClientBase attribute) (core.rtdb.RuntimeDatabaseBase attribute) (core.streambroker.StreamBrokerClientBase attribute) METRIC_DOES_NOT_EXIST (core.metrics.ErrorMessage attribute) METRIC_EXISTS (core.metrics.ErrorMessage attribute) METRIC_TYPE_MISMATCH (core.metrics.ErrorMessage attribute) metrics (core.model.ModelInfo property) MetricsManager (class in core.metrics) MetricType (class in core.metrics) MicroAppBase (class in userv.uapp) MicroServiceTask (class in userv.uapp) Model (class in core.model) model (userv.inference.InferenceService property) model_binary (core.model.Model property) model_id (core.infereng.InferenceInfo property) model_info (core.model.Model property) model_provider (userv.inference.InferenceService property) ModelDetails (class in core.model) ModelInfo (class in core.model) ModelMetrics (class in core.model) module core core.crypto.qat core.engines core.engines.tensorflow_engine core.filedb core.frame core.infereng core.inferqueue core.metrics core.model core.pipeline core.processors core.processors.category_list core.processors.postprocessor core.processors.preprocessor core.rtdb core.stream core.streambroker userv userv.inference userv.pipeline_server userv.streaming userv.uapp userv.websocket_server

N

name (core.model.ModelDetails property) (core.stream.StreamProvider property) (userv.uapp.MicroServiceTask property)

normalize() (core.frame.Frame method)

O

ObjectDetectionPostprocessor (class in core.processors.postprocessor) observe_histogram() (core.metrics.MetricsManager method) observe_summary() (core.metrics.MetricsManager method)

open() (core.stream.CameraSource method) (core.stream.FileSource method) (core.stream.StreamProvider method) output_layer (core.engines.tensorflow_engine.TFModelConfig property)

P

path (core.engines.tensorflow_engine.TFModelConfig property) (core.model.ModelInfo property) pathname (core.stream.StreamProvider property) Pipeline (class in core.pipeline) pipeline (userv.streaming.StreamingService property) pipeline_id (core.frame.Frame property) pipeline_manager (userv.inference.InferenceService property) (userv.streaming.StreamingService property) PIPELINE_TABLE (core.pipeline.PipelineManager attribute) (userv.pipeline_server.PipelineService attribute) PipelineManager (class in core.pipeline) pipelines (userv.pipeline_server.PipelineService property) pipelines_have_changed (userv.pipeline_server.PipelineService property) PipelineService (class in userv.pipeline_server) postprocess() (core.engines.tensorflow_engine.TensorFlowEngine method) (core.engines.tensorflow_engine.TensorFlowPostprocessor method) (core.infereng.InferenceEngine method) (core.processors.postprocessor.FaceRecognitionPostprocessor method) (core.processors.postprocessor.ObjectDetectionPostprocessor method) (core.processors.postprocessor.Postprocessor method)

Postprocessor (class in core.processors.postprocessor) precision (core.model.ModelMetrics property) predict() (core.infereng.InferenceEngine method) prepare() (core.stream.StreamProcessor method) preprocess() (core.engines.tensorflow_engine.TensorFlowEngine method) (core.engines.tensorflow_engine.TensorFlowPreprocessor method) (core.infereng.InferenceEngine method) (core.processors.preprocessor.Preprocessor method) Preprocessor (class in core.processors.preprocessor) process_frame() (userv.inference.InferenceTask method) (userv.streaming.StreamingTask method) provider (core.stream.StreamProcessor property) (userv.streaming.StreamingService property) publish_frame() (core.inferqueue.InferQueueClientBase method) (core.inferqueue.KafkaInferQueueClient method) (core.inferqueue.RedisInferQueueClient method) (core.streambroker.KafkaStreamBrokerClient method) (core.streambroker.RedisStreamBrokerClient method) (core.streambroker.StreamBrokerClientBase method)

Q

QATFrameCipher (class in core.frame)

QATZip (class in core.crypto.qat) queue_topic (core.infereng.InferenceInfo property)

R

raw (core.frame.Frame property) raw_fps (core.stream.StreamProvider property) raw_size (core.stream.StreamProvider property) read_raw_frame() (core.stream.CameraSource method) (core.stream.FileSource method) (core.stream.StreamProvider method) recall (core.model.ModelMetrics property) RedisDB (class in core.rtdb) RedisInferQueueClient (class in core.inferqueue) RedisStreamBrokerClient (class in core.streambroker) register_engine() (core.infereng.InferEngineManager method)

register_infer_queue() (core.inferqueue.InferQueueClientBase method) (core.inferqueue.KafkaInferQueueClient method) (core.inferqueue.RedisInferQueueClient method) register_pipeline() (core.pipeline.PipelineManager method) reset_frame_counts() (userv.inference.InferenceTask method) run() (userv.inference.InferenceService method) (userv.streaming.StreamingService method) (userv.uapp.MicroAppBase method) (userv.uapp.MicroServiceTask method) (userv.websocket_server.StreamWebSocketServer method) run_and_wait_task() (userv.uapp.MicroAppBase method) RuntimeDatabaseBase (class in core.rtdb)

S

save_table_object_dict() (core.rtdb.RedisDB method) (core.rtdb.RuntimeDatabaseBase method) search_engine() (core.infereng.InferEngineManager method) sequence (core.frame.Frame property) set_gauge() (core.metrics.MetricsManager method) set_infer_fps() (core.pipeline.PipelineManager method) set_session() (core.crypto.qat.QATZip method) sse() (in module userv.pipeline_server) stop() (userv.inference.InferenceTask method) (userv.streaming.StreamingTask method) (userv.uapp.MicroAppBase method) (userv.uapp.MicroServiceTask method)

stop_all_tasks() (userv.uapp.MicroServiceTask class method) StreamBrokerClientBase (class in core.streambroker) StreamingService (class in userv.streaming) StreamingTask (class in userv.streaming) StreamProcessor (class in core.stream) StreamProvider (class in core.stream) StreamWebSocketServer (class in userv.websocket_server) SUMMARY (core.metrics.MetricType attribute) SW_BACKUP (core.crypto.qat.QATZip attribute)

T

target (core.engines.tensorflow_engine.TFModelConfig property) (core.model.ModelDetails property) target_fps (core.stream.FileSource property) (core.stream.StreamProvider property) teardown_session() (core.crypto.qat.QATZip method) TensorFlowEngine (class in core.engines.tensorflow_engine)

TensorFlowPostprocessor (class in core.engines.tensorflow_engine) TensorFlowPreprocessor (class in core.engines.tensorflow_engine) TFModelConfig (class in core.engines.tensorflow_engine) timestamp_infer_end (core.frame.Frame property) timestamp_new_frame (core.frame.Frame property) to_blob() (core.frame.Frame method)

U

unlock() (core.rtdb.RedisDB method) unregister_engine() (core.infereng.InferEngineManager method) unregister_infer_queue() (core.inferqueue.InferQueueClientBase method) (core.inferqueue.KafkaInferQueueClient method) (core.inferqueue.RedisInferQueueClient method) unregister_pipeline() (core.pipeline.PipelineManager method) update_frame_counts() (userv.inference.InferenceTask method) uploaded_date (core.model.ModelInfo property) userv module

userv.inference module userv.pipeline_server module userv.streaming module userv.uapp module userv.websocket_server module

V

verify() (core.engines.tensorflow_engine.TensorFlowEngine method) (core.infereng.InferenceEngine method) (core.stream.CameraSource method) (core.stream.FileSource method) (core.stream.StreamProvider method)

version (core.model.ModelDetails property)

W

wait_all_tasks_end() (userv.uapp.MicroServiceTask class method)

Z

zip_tool (userv.inference.InferenceService property) (userv.streaming.StreamingService property)