processors

Subpackages

• aggregators
  • Submodules
    • dtmf_aggregator
      • DTMFAggregator
    • gated
      • GatedAggregator
    • gated_llm_context
      • GatedLLMContextAggregator
    • llm_context
      • is_given()
      • LLMSpecificMessage
      • LLMContext
    • llm_context_summarizer
      • SummaryAppliedEvent
      • LLMContextSummarizer
    • llm_response
      • LLMFullResponseAggregator
    • llm_response_universal
      • LLMUserAggregatorParams
      • LLMAssistantAggregatorParams
      • UserTurnStoppedMessage
      • AssistantTurnStoppedMessage
      • AssistantThoughtMessage
      • LLMContextAggregator
      • LLMUserAggregator
      • LLMAssistantAggregator
      • LLMContextAggregatorPair
    • llm_text_processor
      • LLMTextProcessor
    • sentence
      • SentenceAggregator
• audio
  • Submodules
    • audio_buffer_processor
      • AudioBufferProcessor
    • vad_processor
      • VADProcessor
• filters
  • Submodules
    • frame_filter
      • FrameFilter
    • function_filter
      • FunctionFilter
    • identity_filter
      • IdentityFilter
    • null_filter
      • NullFilter
    • wake_check_filter
      • WakeCheckFilter
    • wake_notifier_filter
      • WakeNotifierFilter
• frameworks
  • Subpackages
    • rtvi
      • RTVIClientMessageFrame
      • RTVIFunctionCallReportLevel
      • RTVIObserver
      • RTVIObserverParams
      • RTVIProcessor
      • RTVIServerMessageFrame
      • RTVIServerResponseFrame
      • Submodules
  • Submodules
    • langchain
    • strands_agents
      • StrandsAgentsProcessor
• gstreamer
  • Submodules
    • pipeline_source
      • GStreamerPipelineSource
• metrics
  • Submodules
    • frame_processor_metrics
      • FrameProcessorMetrics
    • sentry
      • SentryMetrics

Submodules

• async_generator
  • AsyncGeneratorProcessor
    • AsyncGeneratorProcessor.__init__()
    • AsyncGeneratorProcessor.process_frame()
    • AsyncGeneratorProcessor.generator()
• consumer_processor
  • ConsumerProcessor
    • ConsumerProcessor.__init__()
    • ConsumerProcessor.process_frame()
• frame_processor
  • FrameDirection
    • FrameDirection.DOWNSTREAM
    • FrameDirection.UPSTREAM
  • FrameProcessorSetup
    • FrameProcessorSetup.clock
    • FrameProcessorSetup.task_manager
    • FrameProcessorSetup.observer
    • FrameProcessorSetup.pipeline_task
    • FrameProcessorSetup.tool_resources
  • FrameProcessorQueue
    • FrameProcessorQueue.HIGH_PRIORITY
    • FrameProcessorQueue.LOW_PRIORITY
    • FrameProcessorQueue.__init__()
    • FrameProcessorQueue.put()
    • FrameProcessorQueue.get()
  • FrameProcessor
    • FrameProcessor.__init__()
    • FrameProcessor.id
    • FrameProcessor.name
    • FrameProcessor.processors
    • FrameProcessor.entry_processors
    • FrameProcessor.next
    • FrameProcessor.previous
    • FrameProcessor.metrics_enabled
    • FrameProcessor.usage_metrics_enabled
    • FrameProcessor.report_only_initial_ttfb
    • FrameProcessor.task_manager
    • FrameProcessor.pipeline_task
    • FrameProcessor.processors_with_metrics()
    • FrameProcessor.can_generate_metrics()
    • FrameProcessor.set_core_metrics_data()
    • FrameProcessor.start_ttfb_metrics()
    • FrameProcessor.stop_ttfb_metrics()
    • FrameProcessor.start_processing_metrics()
    • FrameProcessor.stop_processing_metrics()
    • FrameProcessor.start_llm_usage_metrics()
    • FrameProcessor.start_tts_usage_metrics()
    • FrameProcessor.start_text_aggregation_metrics()
    • FrameProcessor.stop_text_aggregation_metrics()
    • FrameProcessor.stop_all_metrics()
    • FrameProcessor.create_task()
    • FrameProcessor.cancel_task()
    • FrameProcessor.setup()
    • FrameProcessor.cleanup()
    • FrameProcessor.link()
    • FrameProcessor.get_clock()
    • FrameProcessor.get_event_loop()
    • FrameProcessor.queue_frame()
    • FrameProcessor.pause_processing_frames()
    • FrameProcessor.pause_processing_system_frames()
    • FrameProcessor.resume_processing_frames()
    • FrameProcessor.resume_processing_system_frames()
    • FrameProcessor.process_frame()
    • FrameProcessor.push_error()
    • FrameProcessor.push_error_frame()
    • FrameProcessor.push_frame()
    • FrameProcessor.broadcast_interruption()
    • FrameProcessor.push_interruption_task_frame_and_wait()
    • FrameProcessor.broadcast_frame()
    • FrameProcessor.broadcast_frame_instance()
    • FrameProcessor.has_queued_frame()
• idle_frame_processor
  • IdleFrameProcessor
    • IdleFrameProcessor.__init__()
    • IdleFrameProcessor.process_frame()
    • IdleFrameProcessor.cleanup()
• logger
  • FrameLogger
    • FrameLogger.__init__()
    • FrameLogger.process_frame()
• producer_processor
  • identity_transformer()
  • ProducerProcessor
    • ProducerProcessor.__init__()
    • ProducerProcessor.add_consumer()
    • ProducerProcessor.process_frame()
• text_transformer
  • StatelessTextTransformer
    • StatelessTextTransformer.__init__()
    • StatelessTextTransformer.process_frame()