gst-plugin-zenoh 0.3.2

High-performance GStreamer plugin for distributed media streaming using Zenoh protocol
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

# ZenohDemux

A GStreamer element that demultiplexes Zenoh streams by key expression, creating dynamic source pads for each unique key.

## Usage

```bash
gst-launch-1.0 zenohdemux key-expr="sensors/**" name=demux \
  demux. ! queue ! fakesink
```

## Properties

| Property | Type | Default | Description |
|----------|------|---------|-------------|
| `key-expr` | String | *required* | Zenoh key expression (supports wildcards) |
| `config` | String | `null` | Path to Zenoh configuration file |
| `priority` | Integer | `5` | Priority (1-7, lower=higher) |
| `reliability` | String | `"best-effort"` | Expected reliability mode |
| `pad-naming` | Enum | `full-path` | Pad naming strategy (see below) |
| `apply-buffer-meta` | Boolean | `true` | Apply PTS, DTS, duration, flags from sender |

### Pad Naming Strategies

| Value | Description | Example |
|-------|-------------|---------|
| `full-path` | Full key expression | `sensors_device1_temperature` |
| `last-segment` | Last path segment only | `temperature` |
| `hash` | Hash of key expression | `a1b2c3d4` |

### Statistics (read-only)

| Property | Type | Description |
|----------|------|-------------|
| `bytes-received` | UInt64 | Total bytes received |
| `messages-received` | UInt64 | Total buffers received |
| `errors` | UInt64 | Receive errors |
| `pads-created` | UInt64 | Dynamic pads created |

## Examples

```bash
# Demux all sensors with full-path naming
gst-launch-1.0 zenohdemux key-expr="sensors/**" name=demux \
  demux. ! queue ! filesink location=data.bin

# Use last-segment naming for cleaner pad names
gst-launch-1.0 zenohdemux key-expr="sensors/**" pad-naming=last-segment name=demux \
  demux. ! queue ! fakesink

# Multi-camera demux with hash naming
gst-launch-1.0 zenohdemux key-expr="cameras/**" pad-naming=hash name=demux \
  demux. ! queue ! videoconvert ! autovideosink
```

## How It Works

1. Subscribe to a wildcard key expression (e.g., `sensors/**`)
2. For each unique key received, create a new source pad
3. Route data to the appropriate pad based on its key expression
4. Downstream elements can connect to specific pads

## Rust API

```rust
use gstzenoh::{ZenohDemux, PadNaming};

// Constructor
let demux = ZenohDemux::new("sensors/**");

// Builder
let demux = ZenohDemux::builder("sensors/**")
    .pad_naming(PadNaming::LastSegment)
    .apply_buffer_meta(true)
    .build();

// Setters
demux.set_pad_naming(PadNaming::Hash);

// Getters
let pads = demux.pads_created();
let bytes = demux.bytes_received();
```