MCPcopy Create free account

hub / github.com/arrudagates/ponder / functions

Functions142 in github.com/arrudagates/ponder

Methodname
Sets the server name identifier
rmqtt-net/src/builder.rs:188
Methodnew
(tx: &Sender<(String, String)>)
src/main.rs:32
Methodnew
( scx: ServerContext, ha_mqtt_client: AsyncClient, discovery_prefix: String, p
src/device.rs:83
Methodnew
( scx: ServerContext, ha_mqtt_client: AsyncClient, discovery_prefix: String, p
src/device_manager.rs:28
Methodnew
Creates a new Dispatcher instance
rmqtt-net/src/stream.rs:37
Methodnew
Creates a new builder with default configuration values
rmqtt-net/src/builder.rs:144
Methodnodelay
Enables/disables TCP_NODELAY option
rmqtt-net/src/builder.rs:206
Methodon_discovery
(&self)
src/device_manager.rs:164
Methodon_publish
(&mut self, topic: String, payload_serialized: String)
src/device_manager.rs:46
Methodon_set_property
(&mut self, id: String, prop: String, value: String)
src/device_manager.rs:171
Methodpoll_next
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
rmqtt-net/src/stream.rs:272
Methodpre_write_xform_set_property
(&self, v: String)
src/devices/RAC_056905_WW.rs:152
Methodread_callback
(&self, _v: String)
src/devices/RAC_056905_WW.rs:145
Methodread_xform
(&self, v: u32, raw_clip_state: &HashMap<u16, u32>)
src/devices/RAC_056905_WW.rs:95
Methodreadable
(&self)
src/devices/RAC_056905_WW.rs:71
Methodrecv_connect
(&mut self, tm: Duration)
rmqtt-net/src/stream.rs:252
Methodreuseaddr
Configures SO_REUSEADDR socket option
rmqtt-net/src/builder.rs:212
Methodreuseport
Configures SO_REUSEPORT socket option
rmqtt-net/src/builder.rs:218
Methodsend_auth
(&mut self, auth: Auth)
rmqtt-net/src/stream.rs:418
Methodsend_connect
(&mut self, connect: rmqtt_codec::v3::Connect)
rmqtt-net/src/stream.rs:194
Methodsend_connect_ack
( &mut self, return_code: ConnectAckReason, session_present: bool,
rmqtt-net/src/stream.rs:200
Methodsend_disconnect
(&mut self)
rmqtt-net/src/stream.rs:141
Methodsend_ping_request
(&mut self)
rmqtt-net/src/stream.rs:211
Methodsend_ping_response
(&mut self)
rmqtt-net/src/stream.rs:217
Methodsend_publish
(&mut self, publish: Box<Publish>)
rmqtt-net/src/stream.rs:148
Methodsend_publish_ack
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:154
Methodsend_publish_complete
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:172
Methodsend_publish_received
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:160
Methodsend_publish_release
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:166
Methodsend_subscribe_ack
( &mut self, packet_id: NonZeroU16, status: Vec<rmqtt_codec::v3::Subscribe
rmqtt-net/src/stream.rs:178
Methodsend_timeout
Sets network send timeout duration
rmqtt-net/src/builder.rs:284
Methodsend_unsubscribe_ack
(&mut self, packet_id: NonZeroU16)
rmqtt-net/src/stream.rs:188
Methodsession_expiry_interval
Configures session expiration interval
rmqtt-net/src/builder.rs:320
Methodshared_subscription
Enables shared subscription support
rmqtt-net/src/builder.rs:350
Methodstart
(&mut self)
src/main.rs:144
Methodstop
(&mut self)
src/main.rs:150
Methodtls_cross_certificate
Enables mutual TLS authentication
rmqtt-net/src/builder.rs:374
Methodto_reason_code
(&self)
rmqtt-net/src/error.rs:58
Methodwritable
(&self)
src/devices/RAC_056905_WW.rs:83
Methodwrite_attach
(&self, raw: u32)
src/devices/RAC_056905_WW.rs:219
Methodwrite_callback
(&self, _v: String)
src/devices/RAC_056905_WW.rs:213
Methodwrite_xform
(&self, v: String)
src/devices/RAC_056905_WW.rs:165
← previous101–142 of 142, ranked by callers