SEDSnet 4.0.1

A memory safe, no_std-capable networking stack with routing, discovery, reliability, and Rust/C/Python bindings.
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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145

from typing import Any, Callable, Dict, Optional

class Packet:
    ...

class Router:
    def __init__(
        self,
        now_ms: Optional[Callable[[], int]] = None,
        handlers: Any = None,
        hostname: Optional[str] = None,
        address_mode: int = 0,
        requested_address: int = 0,
        timesync_enabled: bool = True,
        timesync_role: int = 0,
        timesync_priority: int = 100,
        timesync_source_timeout_ms: int = 5000,
        timesync_announce_interval_ms: int = 1000,
        timesync_request_interval_ms: int = 1000,
        timesync_consumer_promotion_enabled: bool = True,
        timesync_max_slew_ppm: int = 50000,
        e2e_mode: int = 255,
        e2e_key_id: int = 0,
        max_queue_budget: Optional[int] = None,
        max_recent_rx_ids: Optional[int] = None,
        starting_queue_size: Optional[int] = None,
        queue_grow_step: Optional[float] = None,
    ) -> None: ...
    @staticmethod
    def new_singleton(
        now_ms: Optional[Callable[[], int]] = None,
        handlers: Any = None,
        hostname: Optional[str] = None,
        address_mode: int = 0,
        requested_address: int = 0,
        timesync_enabled: bool = True,
        timesync_role: int = 0,
        timesync_priority: int = 100,
        timesync_source_timeout_ms: int = 5000,
        timesync_announce_interval_ms: int = 1000,
        timesync_request_interval_ms: int = 1000,
        timesync_consumer_promotion_enabled: bool = True,
        timesync_max_slew_ppm: int = 50000,
        e2e_mode: int = 255,
        e2e_key_id: int = 0,
        max_queue_budget: Optional[int] = None,
        max_recent_rx_ids: Optional[int] = None,
        starting_queue_size: Optional[int] = None,
        queue_grow_step: Optional[float] = None,
    ) -> "Router": ...
    @property
    def sender_id(self) -> str: ...
    def set_sender_id(self, sender_id: str) -> None: ...
    def configure_address(
        self,
        address_mode: int = 0,
        requested_address: int = 0,
    ) -> None: ...
    @property
    def current_address(self) -> int: ...
    def resolve_hostname(self, hostname: str) -> Optional[Dict[str, Any]]: ...
    def bind_p2p_port(
        self,
        port: int,
        callback: Callable[[Dict[str, Any], bytes], object],
    ) -> None: ...
    def clear_p2p_port(self, port: int) -> None: ...
    def send_p2p_to_hostname(
        self,
        hostname: str,
        dst_port: int,
        src_port: int,
        payload: bytes,
    ) -> None: ...
    def send_p2p_to_address(
        self,
        address: int,
        dst_port: int,
        src_port: int,
        payload: bytes,
    ) -> None: ...
    def bind_p2p_stream_port(
        self,
        port: int,
        callback: Callable[[Dict[str, Any], bytes], object],
    ) -> None: ...
    def clear_p2p_stream_port(self, port: int) -> None: ...
    def open_p2p_stream_to_hostname(
        self,
        hostname: str,
        dst_port: int,
        src_port: int,
    ) -> int: ...
    def open_p2p_stream_to_address(
        self,
        address: int,
        dst_port: int,
        src_port: int,
    ) -> int: ...
    def send_p2p_stream(self, stream_id: int, payload: bytes) -> None: ...
    def close_p2p_stream(self, stream_id: int) -> None: ...
    def reset_p2p_stream(self, stream_id: int) -> None: ...
    def configure_timesync(
        self,
        enabled: bool = True,
        role: int = 0,
        priority: int = 100,
        source_timeout_ms: int = 5000,
        announce_interval_ms: int = 1000,
        request_interval_ms: int = 1000,
        consumer_promotion_enabled: bool = True,
        max_slew_ppm: int = 50000,
    ) -> None: ...
    def export_memory_layout_json(self) -> str: ...

class Relay:
    def __init__(
        self,
        now_ms: Optional[Callable[[], int]] = None,
        max_queue_budget: Optional[int] = None,
        max_recent_rx_ids: Optional[int] = None,
        starting_queue_size: Optional[int] = None,
        queue_grow_step: Optional[float] = None,
    ) -> None: ...
    def export_memory_layout_json(self) -> str: ...
    ...

def unpack_packet_py(data: bytes) -> Packet: ...
def peek_header_py(data: bytes) -> Dict[str, Any]: ...
def runtime_device_identifier() -> str: ...
def set_runtime_device_identifier(value: str) -> str: ...
def runtime_tuning_config() -> Dict[str, int]: ...
def set_runtime_tuning_config(
    payload_compress_threshold: Optional[int] = None,
    static_string_length: Optional[int] = None,
    static_hex_length: Optional[int] = None,
    string_precision: Optional[int] = None,
    max_handler_retries: Optional[int] = None,
    reliable_retransmit_ms: Optional[int] = None,
    reliable_max_retries: Optional[int] = None,
    reliable_max_pending: Optional[int] = None,
    reliable_max_return_routes: Optional[int] = None,
    reliable_max_end_to_end_pending: Optional[int] = None,
    reliable_max_end_to_end_ack_cache: Optional[int] = None,
) -> Dict[str, int]: ...