juturna.nodes.sink package#

Module contents#

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

Bases: BaseNode[ObjectPayload, None]

Send data to a HTTP endpoint

property configuration: dict#

set_on_config(prop: str, value: str)#

update(message: Message[ObjectPayload])#

warmup()#

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

Bases: BaseNode

Transmit data to a websocket endpoint

destroy()#

update(message: Message)#

warmup()#

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: BaseNode[ImagePayload, None]

Sink node for video streaming

property ffmpeg_launcher: Path#

start()#: Start the node and begin processing. This method is called automatically when the parent pipeline is started. If you override this method in your custom node class, make sure to call the parent method to ensure the bridge is started correctly.

stop()#: Stop the node and begin processing. This method is called automatically when the parent pipeline is stopped. If you override this method in your custom node class, make sure to call the parent method to ensure the bridge is stopped correctly.

update(message: Message[ImagePayload])#

warmup()#