blob: 04f42305789917a17017861db22eea81716a9781 (
plain)
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
84
85
86
87
88
89
90
|
{ pkgs, lib, ... }:
{
name = "zenohd";
meta.maintainers = [ lib.maintainers.markuskowa ];
nodes = {
router =
{
pkgs,
config,
...
}:
{
networking.firewall.allowedTCPPorts = [
7447 # zenohd default port
config.services.zenohd.settings.plugins.mqtt.port
config.services.zenohd.settings.plugins.webserver.http_port
];
services.zenohd = {
enable = true;
plugins = with pkgs; [
zenoh-plugin-mqtt
zenoh-plugin-webserver
];
backends = with pkgs; [
zenoh-backend-filesystem
zenoh-backend-rocksdb
];
settings = {
plugins = {
mqtt = {
port = 1883;
allow = ".*";
};
webserver.http_port = 8000;
storage_manager = {
volumes = {
fs = { };
rocksdb = { };
};
storages = {
mem = {
key_expr = "mem/**";
volume = "memory";
};
fs = {
key_expr = "fs/**";
volume = {
id = "fs";
dir = "zenoh-fs";
strip_prefix = "fs";
};
};
rocksdb = {
key_expr = "rocksdb/**";
volume = {
id = "rocksdb";
dir = "zenoh-rocksdb";
strip_prefix = "rocksdb";
create_db = true;
};
};
};
};
};
};
};
};
client = {
environment.systemPackages = [
pkgs.mosquitto
];
};
};
testScript = ''
router.wait_for_unit("zenohd.service")
client.wait_for_unit("multi-user.target")
for be in ["fs", "rocksdb", "mem" ]:
client.succeed(f"mosquitto_pub -q 1 -h router -t {be}/test -m hello")
client.succeed(f"curl router:8000/{be}/test | grep hello")
'';
}
|
