pipecat-ai

API Reference

  • Adapters
  • Audio
  • Clocks
  • Extensions
  • Frames
  • Metrics
  • Observers
  • Pipeline
  • Processors
  • Runner
  • Serializers
  • Services
  • Transcriptions
  • Transports
  • Turns
  • Utils
pipecat-ai
  • network
  • View page source

network

Network bus implementations for distributed workers.

Each adapter has its own optional dependency. Imports are lazy so the package can be loaded with only the extras you need; importing a specific bus without its extra raises a clear error from that submodule.

Submodules

  • pgmq
    • PgmqBus
      • PgmqBus.__init__()
      • PgmqBus.start()
      • PgmqBus.stop()
      • PgmqBus.publish()
  • pgmq_backends
    • BackendMessage
      • BackendMessage.msg_id
      • BackendMessage.message
    • DirectPgmqBackend
      • DirectPgmqBackend.__init__()
      • DirectPgmqBackend.join()
      • DirectPgmqBackend.publish()
      • DirectPgmqBackend.read()
      • DirectPgmqBackend.archive()
      • DirectPgmqBackend.leave()
    • IsolatedPgmqBackend
      • IsolatedPgmqBackend.__init__()
      • IsolatedPgmqBackend.join()
      • IsolatedPgmqBackend.publish()
      • IsolatedPgmqBackend.read()
      • IsolatedPgmqBackend.archive()
      • IsolatedPgmqBackend.leave()
    • PgmqBackend
      • PgmqBackend.join()
      • PgmqBackend.publish()
      • PgmqBackend.read()
      • PgmqBackend.archive()
      • PgmqBackend.leave()
  • redis
    • RedisBus
      • RedisBus.__init__()
      • RedisBus.start()
      • RedisBus.stop()
      • RedisBus.publish()

© Copyright 2024-2026, Daily.