juturna package

Subpackages

• juturna.components package
  • Subpackages
    • juturna.components.exceptions package
      • Module contents
  • Module contents
    • Message
      • Message.created_at
      • Message.creator
      • Message.id
      • Message.meta
      • Message.payload
      • Message.timeit()
      • Message.timer()
      • Message.timers
      • Message.to_dict()
      • Message.to_json()
      • Message.version
    • Node
      • Node.SKIP_UPDATE
      • Node.add_destination()
      • Node.clear_destination()
      • Node.clear_destinations()
      • Node.clear_source()
      • Node.compile_template()
      • Node.configuration
      • Node.configure()
      • Node.destinations
      • Node.destroy()
      • Node.dump_json()
      • Node.flush_telemetry()
      • Node.health
      • Node.join()
      • Node.kill()
      • Node.link_state()
      • Node.link_state_resolver()
      • Node.link_telemetry()
      • Node.link_update_observer()
      • Node.origins
      • Node.prepare_template()
      • Node.put()
      • Node.set_on_config()
      • Node.set_source()
      • Node.signal_kill()
      • Node.start()
      • Node.static_path
      • Node.status
      • Node.stop()
      • Node.transmit()
      • Node.update()
      • Node.warmup()
    • Pipeline
      • Pipeline.DAG
      • Pipeline.destroy()
      • Pipeline.from_json()
      • Pipeline.kill()
      • Pipeline.name
      • Pipeline.pipe_id
      • Pipeline.pipe_path
      • Pipeline.start()
      • Pipeline.status
      • Pipeline.stop()
      • Pipeline.update_node()
      • Pipeline.warmup()
    • PipelineAlreadyRunningError
    • PipelineBusyError
    • PipelineDestroyedError
    • PipelineNotReadyError
    • PipelineNotRunningError
    • PipelineStateError
    • PipelineStoppedError
    • State
• juturna.meta package
  • Module contents
• juturna.names package
  • Module contents
    • ComponentStatus
      • ComponentStatus.CONFIGURED
      • ComponentStatus.NEW
      • ComponentStatus.RUNNING
      • ComponentStatus.STOPPED
    • PipelineStatus
      • PipelineStatus.DESTROYED
      • PipelineStatus.NEW
      • PipelineStatus.READY
      • PipelineStatus.RUNNING
      • PipelineStatus.STOPPED
    • PixelFormat
      • PixelFormat.ABGR
      • PixelFormat.ARGB
      • PixelFormat.BGR24
      • PixelFormat.BGRA
      • PixelFormat.GBRP
      • PixelFormat.GRAY
      • PixelFormat.GRAY8
      • PixelFormat.NV12
      • PixelFormat.NV21
      • PixelFormat.PAL8
      • PixelFormat.RGB24
      • PixelFormat.RGBA
      • PixelFormat.YUV420P
      • PixelFormat.YUV444P
      • PixelFormat.YUYV422
      • PixelFormat.has_alpha
      • PixelFormat.is_bgr
      • PixelFormat.is_grayscale
      • PixelFormat.is_rgb
      • PixelFormat.is_yuv
    • ServiceStatus
      • ServiceStatus.REQUEST_KO
      • ServiceStatus.REQUEST_OK
• juturna.payloads package
  • Module contents
    • AudioPayload
      • AudioPayload.audio
      • AudioPayload.audio_format
      • AudioPayload.channels
      • AudioPayload.end
      • AudioPayload.sampling_rate
      • AudioPayload.serialize()
      • AudioPayload.size_bytes
      • AudioPayload.start
    • BasePayload
      • BasePayload.clone()
      • BasePayload.serialize()
    • Batch
      • Batch.messages
      • Batch.serialize()
      • Batch.size_bytes
    • BytesPayload
      • BytesPayload.cnt
      • BytesPayload.serialize()
      • BytesPayload.size_bytes
    • Draft
      • Draft.clear()
      • Draft.compile()
    • ImagePayload
      • ImagePayload.depth
      • ImagePayload.height
      • ImagePayload.image
      • ImagePayload.pixel_format
      • ImagePayload.serialize()
      • ImagePayload.size_bytes
      • ImagePayload.timestamp
      • ImagePayload.width
    • ObjectPayload
      • ObjectPayload.clear()
      • ObjectPayload.from_dict()
      • ObjectPayload.pop()
      • ObjectPayload.popitem()
      • ObjectPayload.setdefault()
      • ObjectPayload.size_bytes
      • ObjectPayload.update()
    • VideoPayload
      • VideoPayload.codec
      • VideoPayload.end
      • VideoPayload.frames_per_second
      • VideoPayload.serialize()
      • VideoPayload.size_bytes
      • VideoPayload.start
      • VideoPayload.video
• juturna.telemetry package
  • Subpackages
    • juturna.telemetry.browser package
      • Module contents
    • juturna.telemetry.csv package
      • Module contents
    • juturna.telemetry.memory package
      • Module contents
  • Module contents
    • TelemetryContext
      • TelemetryContext.pipe_path
      • TelemetryContext.transport
      • TelemetryContext.worker
    • TelemetryManager
      • TelemetryManager.record_telemetry()
      • TelemetryManager.records()
      • TelemetryManager.requires
      • TelemetryManager.start()
      • TelemetryManager.stop()
    • check_pipeline_telemetry()
    • get_telemetry()
    • tag_records()
• juturna.transport package
  • Subpackages
    • juturna.transport.browser package
      • Module contents
    • juturna.transport.threads package
      • Module contents
  • Module contents
    • BrowserTransport
      • BrowserTransport.attach_queue()
      • BrowserTransport.capabilities
      • BrowserTransport.connect()
      • BrowserTransport.is_current()
      • BrowserTransport.new_condition()
      • BrowserTransport.new_event()
      • BrowserTransport.new_lock()
      • BrowserTransport.new_queue()
      • BrowserTransport.node_scope()
      • BrowserTransport.queue_handle()
      • BrowserTransport.remote_destination()
      • BrowserTransport.spawn()
    • Condition
      • Condition.notify_all()
      • Condition.wait_for()
    • Empty
    • Event
      • Event.clear()
      • Event.is_set()
      • Event.set()
      • Event.wait()
    • Full
    • Lock
    • Queue
      • Queue.empty()
      • Queue.full()
      • Queue.get()
      • Queue.get_nowait()
      • Queue.put()
      • Queue.put_nowait()
      • Queue.qsize()
    • ThreadingTransport
      • ThreadingTransport.capabilities
      • ThreadingTransport.is_current()
      • ThreadingTransport.new_condition()
      • ThreadingTransport.new_event()
      • ThreadingTransport.new_lock()
      • ThreadingTransport.new_queue()
      • ThreadingTransport.node_scope()
      • ThreadingTransport.remote_destination()
      • ThreadingTransport.spawn()
    • TransportBackend
      • TransportBackend.capabilities
      • TransportBackend.is_current()
      • TransportBackend.new_condition()
      • TransportBackend.new_event()
      • TransportBackend.new_lock()
      • TransportBackend.new_queue()
      • TransportBackend.node_scope()
      • TransportBackend.remote_destination()
      • TransportBackend.spawn()
    • WorkerHandle
      • WorkerHandle.is_alive()
      • WorkerHandle.join()
      • WorkerHandle.name
      • WorkerHandle.start()
    • get_transport()
• juturna.utils package
  • Subpackages
    • juturna.utils.jt_utils package
      • Module contents
    • juturna.utils.log_utils package
      • Module contents
    • juturna.utils.net_utils package
      • Module contents
    • juturna.utils.proc_utils package
      • Module contents
  • Module contents

Module contents