juturna.nodes.sink package

Module contents

class juturna.nodes.sink.NotifierHTTP(endpoint: str, timeout: int, content_type: str, **kwargs)

Bases: Node[ObjectPayload, None]

Send data to a HTTP endpoint

property configuration: dict

Fetch node configuration

set_on_config(prop: str, value: str)

Change the node configuration

update(message: Message[ObjectPayload])

Receive a message, transmit a message

warmup()

Warmup the node

class juturna.nodes.sink.NotifierWebsocket(endpoint: str, **kwargs)

Bases: Node[ObjectPayload, None]

Transmit data to a websocket endpoint

destroy()

Destroy the node

update(message: Message[ObjectPayload])

Receive a message, transmit a message

warmup()

Warmup the node

class juturna.nodes.sink.VideostreamFFMPEG(dst_host: str, dst_port: int, in_width: int, in_height: int, out_width: int, out_height: int, gop: int, process_log_level: str, ffmpeg_proc_path: str, **kwargs)

Bases: Node[ImagePayload, None]

Sink node for video streaming

property ffmpeg_launcher: Path

Fetch the FFmpeg launcher script

start()

Start the node

stop()

Stop the node

update(message: Message[ImagePayload])

Receive a message, transmit a message

warmup()

Warmup the node