pipeline

Submodules

• base_pipeline
  • BasePipeline
    • BasePipeline.__init__()
• base_task
  • PipelineTaskParams
    • PipelineTaskParams.loop
  • BasePipelineTask
    • BasePipelineTask.has_finished()
    • BasePipelineTask.stop_when_done()
    • BasePipelineTask.cancel()
    • BasePipelineTask.run()
    • BasePipelineTask.queue_frame()
    • BasePipelineTask.queue_frames()
• llm_switcher
  • LLMSwitcher
    • LLMSwitcher.__init__()
    • LLMSwitcher.llms
    • LLMSwitcher.active_llm
    • LLMSwitcher.run_inference()
    • LLMSwitcher.register_function()
    • LLMSwitcher.register_direct_function()
• parallel_pipeline
  • ParallelPipeline
    • ParallelPipeline.__init__()
    • ParallelPipeline.processors
    • ParallelPipeline.entry_processors
    • ParallelPipeline.processors_with_metrics()
    • ParallelPipeline.setup()
    • ParallelPipeline.cleanup()
    • ParallelPipeline.process_frame()
• pipeline
  • PipelineSource
    • PipelineSource.__init__()
    • PipelineSource.process_frame()
  • PipelineSink
    • PipelineSink.__init__()
    • PipelineSink.process_frame()
  • Pipeline
    • Pipeline.__init__()
    • Pipeline.processors
    • Pipeline.entry_processors
    • Pipeline.processors_with_metrics()
    • Pipeline.setup()
    • Pipeline.cleanup()
    • Pipeline.process_frame()
• runner
  • PipelineRunner
    • PipelineRunner.__init__()
    • PipelineRunner.run()
    • PipelineRunner.stop_when_done()
    • PipelineRunner.cancel()
• service_switcher
  • ServiceSwitcherStrategy
    • ServiceSwitcherStrategy.__init__()
    • ServiceSwitcherStrategy.services
    • ServiceSwitcherStrategy.active_service
    • ServiceSwitcherStrategy.handle_frame()
    • ServiceSwitcherStrategy.handle_error()
  • ServiceSwitcherStrategyManual
    • ServiceSwitcherStrategyManual.handle_frame()
  • ServiceSwitcherStrategyFailover
    • ServiceSwitcherStrategyFailover.handle_error()
  • ServiceSwitcher
    • ServiceSwitcher.__init__()
    • ServiceSwitcher.strategy
    • ServiceSwitcher.services
    • ServiceSwitcher.push_frame()
    • ServiceSwitcher.process_frame()
• sync_parallel_pipeline
  • FrameOrder
    • FrameOrder.ARRIVAL
    • FrameOrder.PIPELINE
  • SyncFrame
  • SyncParallelPipelineSource
    • SyncParallelPipelineSource.__init__()
    • SyncParallelPipelineSource.process_frame()
  • SyncParallelPipelineSink
    • SyncParallelPipelineSink.__init__()
    • SyncParallelPipelineSink.process_frame()
  • SyncParallelPipeline
    • SyncParallelPipeline.__init__()
    • SyncParallelPipeline.processors
    • SyncParallelPipeline.entry_processors
    • SyncParallelPipeline.processors_with_metrics()
    • SyncParallelPipeline.setup()
    • SyncParallelPipeline.cleanup()
    • SyncParallelPipeline.process_frame()
• task
  • IdleFrameObserver
    • IdleFrameObserver.__init__()
    • IdleFrameObserver.on_push_frame()
  • PipelineParams
    • PipelineParams.audio_in_sample_rate
    • PipelineParams.audio_out_sample_rate
    • PipelineParams.enable_heartbeats
    • PipelineParams.enable_metrics
    • PipelineParams.enable_usage_metrics
    • PipelineParams.heartbeats_period_secs
    • PipelineParams.heartbeats_monitor_secs
    • PipelineParams.report_only_initial_ttfb
    • PipelineParams.send_initial_empty_metrics
    • PipelineParams.start_metadata
  • PipelineTask
    • PipelineTask.__init__()
    • PipelineTask.params
    • PipelineTask.app_resources
    • PipelineTask.pipeline
    • PipelineTask.turn_tracking_observer
    • PipelineTask.turn_trace_observer
    • PipelineTask.rtvi
    • PipelineTask.reached_upstream_types
    • PipelineTask.reached_downstream_types
    • PipelineTask.add_observer()
    • PipelineTask.remove_observer()
    • PipelineTask.set_reached_upstream_filter()
    • PipelineTask.set_reached_downstream_filter()
    • PipelineTask.add_reached_upstream_filter()
    • PipelineTask.add_reached_downstream_filter()
    • PipelineTask.has_finished()
    • PipelineTask.stop_when_done()
    • PipelineTask.cancel()
    • PipelineTask.run()
    • PipelineTask.queue_frame()
    • PipelineTask.queue_frames()
• task_observer
  • Proxy
    • Proxy.queue
    • Proxy.task
    • Proxy.observer
  • TaskObserver
    • TaskObserver.__init__()
    • TaskObserver.add_observer()
    • TaskObserver.remove_observer()
    • TaskObserver.start()
    • TaskObserver.stop()
    • TaskObserver.cleanup()
    • TaskObserver.on_pipeline_started()
    • TaskObserver.on_process_frame()
    • TaskObserver.on_push_frame()