Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/arrudagates/ponder
/ functions
Functions
142 in github.com/arrudagates/ponder
⨍
Functions
142
◇
Types & classes
23
Method
name
Sets the server name identifier
rmqtt-net/src/builder.rs:188
Method
new
(tx: &Sender<(String, String)>)
src/main.rs:32
Method
new
( scx: ServerContext, ha_mqtt_client: AsyncClient, discovery_prefix: String, p
src/device.rs:83
Method
new
( scx: ServerContext, ha_mqtt_client: AsyncClient, discovery_prefix: String, p
src/device_manager.rs:28
Method
new
Creates a new Dispatcher instance
rmqtt-net/src/stream.rs:37
Method
new
Creates a new builder with default configuration values
rmqtt-net/src/builder.rs:144
Method
nodelay
Enables/disables TCP_NODELAY option
rmqtt-net/src/builder.rs:206
Method
on_discovery
(&self)
src/device_manager.rs:164
Method
on_publish
(&mut self, topic: String, payload_serialized: String)
src/device_manager.rs:46
Method
on_set_property
(&mut self, id: String, prop: String, value: String)
src/device_manager.rs:171
Method
poll_next
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
rmqtt-net/src/stream.rs:272
Method
pre_write_xform_set_property
(&self, v: String)
src/devices/RAC_056905_WW.rs:152
Method
read_callback
(&self, _v: String)
src/devices/RAC_056905_WW.rs:145
Method
read_xform
(&self, v: u32, raw_clip_state: &HashMap<u16, u32>)
src/devices/RAC_056905_WW.rs:95
Method
readable
(&self)
src/devices/RAC_056905_WW.rs:71
Method
recv_connect
(&mut self, tm: Duration)
rmqtt-net/src/stream.rs:252
Method
reuseaddr
Configures SO_REUSEADDR socket option
rmqtt-net/src/builder.rs:212
Method
reuseport
Configures SO_REUSEPORT socket option
rmqtt-net/src/builder.rs:218
Method
send_auth
(&mut self, auth: Auth)
rmqtt-net/src/stream.rs:418
Method
send_connect
(&mut self, connect: rmqtt_codec::v3::Connect)
rmqtt-net/src/stream.rs:194
Method
send_connect_ack
( &mut self, return_code: ConnectAckReason, session_present: bool,
rmqtt-net/src/stream.rs:200
Method
send_disconnect
(&mut self)
rmqtt-net/src/stream.rs:141
Method
send_ping_request
(&mut self)
rmqtt-net/src/stream.rs:211
Method
send_ping_response
(&mut self)
rmqtt-net/src/stream.rs:217
Method
send_publish
(&mut self, publish: Box<Publish>)
rmqtt-net/src/stream.rs:148
Method
send_publish_ack
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:154
Method
send_publish_complete
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:172
Method
send_publish_received
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:160
Method
send_publish_release
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:166
Method
send_subscribe_ack
( &mut self, packet_id: NonZeroU16, status: Vec<rmqtt_codec::v3::Subscribe
rmqtt-net/src/stream.rs:178
Method
send_timeout
Sets network send timeout duration
rmqtt-net/src/builder.rs:284
Method
send_unsubscribe_ack
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:188
Method
session_expiry_interval
Configures session expiration interval
rmqtt-net/src/builder.rs:320
Method
shared_subscription
Enables shared subscription support
rmqtt-net/src/builder.rs:350
Method
start
(&mut self)
src/main.rs:144
Method
stop
(&mut self)
src/main.rs:150
Method
tls_cross_certificate
Enables mutual TLS authentication
rmqtt-net/src/builder.rs:374
Method
to_reason_code
(&self)
rmqtt-net/src/error.rs:58
Method
writable
(&self)
src/devices/RAC_056905_WW.rs:83
Method
write_attach
(&self, raw: u32)
src/devices/RAC_056905_WW.rs:219
Method
write_callback
(&self, _v: String)
src/devices/RAC_056905_WW.rs:213
Method
write_xform
(&self, v: String)
src/devices/RAC_056905_WW.rs:165
← previous
101–142 of 142, ranked by callers