MCPcopy Create free account

hub / github.com/bschwind/mqtt-broker / functions

Functions149 in github.com/bschwind/mqtt-broker

⨍ Functions 149◇ Types & classes 84
↓ 66 callersMethodcalc_size
(&self, _protocol_version: ProtocolVersion)
mqtt-v5/src/types.rs:142
↓ 64 callersMethodencode
(&self, bytes: &mut BytesMut)
mqtt-v5/src/encoder.rs:44
↓ 36 callersMethodinsert
(&mut self, topic_filter: &TopicFilter, value: T)
mqtt-v5-broker/src/tree.rs:25
↓ 28 callersMethodproperty_size
(&self, protocol_version: ProtocolVersion)
mqtt-v5/src/types.rs:786
↓ 27 callersMethodsend
Attempt to send a `ClientMessage` to the client via the channel handle. If the channel is closed, the handle is removed from the session.
mqtt-v5-broker/src/broker.rs:157
↓ 20 callersFunctiondecode_mqtt
( bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/decoder.rs:1169
↓ 17 callersFunctionencode_mqtt
(packet: &Packet, bytes: &mut BytesMut, protocol_version: ProtocolVersion)
mqtt-v5/src/encoder.rs:547
↓ 17 callersFunctionencode_string
(value: &str, bytes: &mut BytesMut)
mqtt-v5/src/encoder.rs:33
↓ 16 callersFunctionencode_variable_int
(value: u32, bytes: &mut BytesMut)
mqtt-v5/src/encoder.rs:9
↓ 16 callersMethodnext
(&mut self)
mqtt-v5/src/topic.rs:252
↓ 14 callersFunctionassert_subscribers
( tree: &SubscriptionTree<T>, topic: &str, subscribers: &[T], )
mqtt-v5-broker/src/tree.rs:250
↓ 11 callersMethodis_empty
(&self)
mqtt-v5-broker/src/tree.rs:42
↓ 11 callersMethodremove
(&mut self, topic_filter: &TopicFilter, counter: u64)
mqtt-v5-broker/src/tree.rs:37
↓ 9 callersMethodlevels
(&'a self)
mqtt-v5/src/topic.rs:238
↓ 8 callersFunctionnormal_test
(encoded_variable_int: &[u8], expected_variable_int: u32)
mqtt-v5/src/decoder.rs:1222
↓ 6 callersFunctionspawn
Process MQTT connect on `stream` and spawn a task for this connection TOOD(flxo): Move to dedicated module `io`?
mqtt-v5-broker/src/client.rs:39
↓ 4 callersMethodpublish_message
(&mut self, packet: PublishPacket)
mqtt-v5-broker/src/broker.rs:511
↓ 3 callersFunctionencode_binary_data
(value: &[u8], bytes: &mut BytesMut)
mqtt-v5/src/encoder.rs:38
↓ 3 callersFunctiontry_decode_properties
( bytes: &mut Cursor<&mut BytesMut>, mut closure: F, )
mqtt-v5/src/decoder.rs:312
↓ 2 callersMethodcalculate_size
(&self, protocol_version: ProtocolVersion)
mqtt-v5/src/types.rs:88
↓ 2 callersFunctiondecode_variable_int
(bytes: &mut Cursor<&mut BytesMut>)
mqtt-v5/src/decoder.rs:99
↓ 2 callersMethodfilter
(&'a self)
mqtt-v5/src/topic.rs:229
↓ 2 callersMethodhas_leading_dollar
(&self)
mqtt-v5/src/topic.rs:40
↓ 2 callersMethodmatching_subscribers
(&self, topic: &Topic)
mqtt-v5-broker/src/tree.rs:33
↓ 2 callersFunctionprocess_filter
If Ok, returns (level_count, contains_wildcards).
mqtt-v5/src/topic.rs:80
↓ 2 callersMethodresend_packets
(&mut self)
mqtt-v5-broker/src/broker.rs:120
↓ 2 callersMethodrun
(self)
mqtt-v5-broker/src/client.rs:468
↓ 2 callersMethodsender
(&self)
mqtt-v5-broker/src/broker.rs:213
↓ 2 callersFunctionspawn_framed
TOOD(flxo): Move to dedicated module `io`?
mqtt-v5-broker/src/client.rs:48
↓ 2 callersMethodtopic_name
(&self)
mqtt-v5/src/topic.rs:27
↓ 1 callersFunctiondecode_authenticate
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:1076
↓ 1 callersFunctiondecode_connect
(bytes: &mut Cursor<&mut BytesMut>)
mqtt-v5/src/decoder.rs:340
↓ 1 callersFunctiondecode_connect_ack
( bytes: &mut Cursor<&mut BytesMut>, protocol_version: ProtocolVersion, )
mqtt-v5/src/decoder.rs:466
↓ 1 callersFunctiondecode_disconnect
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:1029
↓ 1 callersFunctiondecode_publish
( bytes: &mut Cursor<&mut BytesMut>, first_byte: u8, remaining_packet_length: u32, protocol_ve
mqtt-v5/src/decoder.rs:549
↓ 1 callersFunctiondecode_publish_ack
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:656
↓ 1 callersFunctiondecode_publish_complete
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:770
↓ 1 callersFunctiondecode_publish_received
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:694
↓ 1 callersFunctiondecode_publish_release
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:732
↓ 1 callersFunctiondecode_subscribe
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:808
↓ 1 callersFunctiondecode_subscribe_ack
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:899
↓ 1 callersFunctiondecode_unsubscribe
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:940
↓ 1 callersFunctiondecode_unsubscribe_ack
( bytes: &mut Cursor<&mut BytesMut>, remaining_packet_length: u32, protocol_version: ProtocolVersi
mqtt-v5/src/decoder.rs:988
↓ 1 callersMethodencode
(&mut self, packet: Packet, bytes: &mut BytesMut)
mqtt-v5/src/lib.rs:53
↓ 1 callersFunctionencode_authenticate
( packet: &AuthenticatePacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:529
↓ 1 callersFunctionencode_connect
(packet: &ConnectPacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion)
mqtt-v5/src/encoder.rs:207
↓ 1 callersFunctionencode_connect_ack
( packet: &ConnectAckPacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:282
↓ 1 callersFunctionencode_disconnect
( packet: &DisconnectPacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:511
↓ 1 callersFunctionencode_publish
(packet: &PublishPacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion)
mqtt-v5/src/encoder.rs:319
↓ 1 callersFunctionencode_publish_ack
( packet: &PublishAckPacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:343
↓ 1 callersFunctionencode_publish_complete
( packet: &PublishCompletePacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:397
↓ 1 callersFunctionencode_publish_received
( packet: &PublishReceivedPacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:361
↓ 1 callersFunctionencode_publish_release
( packet: &PublishReleasePacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:379
↓ 1 callersFunctionencode_subscribe
( packet: &SubscribePacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:415
↓ 1 callersFunctionencode_subscribe_ack
( packet: &SubscribeAckPacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:452
↓ 1 callersFunctionencode_unsubscribe
( packet: &UnsubscribePacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:472
↓ 1 callersFunctionencode_unsubscribe_ack
( packet: &UnsubscribeAckPacket, bytes: &mut BytesMut, protocol_version: ProtocolVersion, )
mqtt-v5/src/encoder.rs:491
↓ 1 callersMethodfixed_header_flags
(&self)
mqtt-v5/src/types.rs:1247
↓ 1 callersMethodhandle_disconnect
(&mut self, client_id: String, will_disconnect_logic: WillDisconnectLogic)
mqtt-v5-broker/src/broker.rs:451
↓ 1 callersMethodhandle_new_client
( &mut self, connect_packet: ConnectPacket, client_msg_sender: Sender<ClientMessage>,
mqtt-v5-broker/src/broker.rs:265
↓ 1 callersMethodhandle_publish
(&mut self, client_id: String, packet: PublishPacket)
mqtt-v5-broker/src/broker.rs:539
↓ 1 callersMethodhandle_publish_ack
(&mut self, client_id: String, packet: PublishAckPacket)
mqtt-v5-broker/src/broker.rs:591
↓ 1 callersMethodhandle_publish_complete
(&mut self, client_id: String, packet: PublishCompletePacket)
mqtt-v5-broker/src/broker.rs:639
↓ 1 callersMethodhandle_publish_received
(&mut self, client_id: String, packet: PublishReceivedPacket)
mqtt-v5-broker/src/broker.rs:616
↓ 1 callersMethodhandle_publish_release
(&mut self, client_id: String, packet: PublishReleasePacket)
mqtt-v5-broker/src/broker.rs:597
↓ 1 callersMethodhandle_subscribe
(&mut self, client_id: String, packet: SubscribePacket)
mqtt-v5-broker/src/broker.rs:355
↓ 1 callersMethodhandle_unsubscribe
(&mut self, client_id: String, packet: UnsubscribePacket)
mqtt-v5-broker/src/broker.rs:408
↓ 1 callersMethodhandshake
(mut self)
mqtt-v5-broker/src/client.rs:190
↓ 1 callersFunctioninit_logging
()
mqtt-v5-broker/src/main.rs:39
↓ 1 callersMethodinto_new_session
Turn self, an existing Session, into a new session suitable for a client which just connected.
mqtt-v5-broker/src/broker.rs:73
↓ 1 callersMethodpublish_final_will
(&mut self, client_id: String, final_will: FinalWill)
mqtt-v5-broker/src/broker.rs:649
↓ 1 callersMethodremove_outgoing_publish
(&mut self, packet_id: u16)
mqtt-v5-broker/src/broker.rs:113
↓ 1 callersMethodrun
(mut self)
mqtt-v5-broker/src/broker.rs:663
↓ 1 callersFunctionrun_client
(broker_tx: Sender<BrokerMessage>)
mqtt-v5-broker/src/broker.rs:713
↓ 1 callersFunctionspawn_websocket
TOOD(flxo): Move to dedicated module `io`?
mqtt-v5-broker/src/client.rs:85
↓ 1 callersMethodstore_outgoing_publish
( &mut self, mut publish: PublishPacket, subscriber_qos: QoS, )
mqtt-v5-broker/src/broker.rs:89
↓ 1 callersMethodtake_over_existing_client
( &mut self, client_id: &str, new_client_clean_start: bool, )
mqtt-v5-broker/src/broker.rs:217
↓ 1 callersFunctiontcp_server_loop
(broker_tx: Sender<BrokerMessage>)
mqtt-v5-broker/src/main.rs:17
↓ 1 callersMethodto_byte
(&self)
mqtt-v5/src/types.rs:1227
↓ 1 callersFunctionupgrade_ws_stream
TOOD(flxo): Move to dedicated module `io`?
mqtt-v5-broker/src/client.rs:63
↓ 1 callersFunctionwebsocket_server_loop
(broker_tx: Sender<BrokerMessage>)
mqtt-v5-broker/src/main.rs:28
↓ 1 callersMethodwill_delay_duration
(&self)
mqtt-v5/src/types.rs:766
Functionauthenticate_roundtrip
()
mqtt-v5/src/encoder.rs:859
Functionconnect_ack_roundtrip
()
mqtt-v5/src/encoder.rs:616
Functionconnect_roundtrip
()
mqtt-v5/src/encoder.rs:585
Methoddecode
(&mut self, buf: &mut BytesMut)
mqtt-v5/src/lib.rs:42
Functiondecode_binary_data
(bytes: &mut Cursor<&mut BytesMut>)
mqtt-v5/src/decoder.rs:135
Functiondecode_binary_data_with_size
( bytes: &mut Cursor<&mut BytesMut>, size: usize, )
mqtt-v5/src/decoder.rs:149
Functiondecode_packet
( protocol_version: ProtocolVersion, packet_type: &PacketType, bytes: &mut Cursor<&mut BytesMut>,
mqtt-v5/src/decoder.rs:1123
Functiondecode_properties
( bytes: &mut Cursor<&mut BytesMut>, mut closure: F, )
mqtt-v5/src/decoder.rs:302
Functiondecode_property
( property_id: u32, bytes: &mut Cursor<&mut BytesMut>, )
mqtt-v5/src/decoder.rs:163
Functiondecode_string
(bytes: &mut Cursor<&mut BytesMut>)
mqtt-v5/src/decoder.rs:118
Methoddefault
()
mqtt-v5/src/lib.rs:32
Methoddefault
()
mqtt-v5-broker/src/broker.rs:201
Functiondisconnect_roundtrip
()
mqtt-v5/src/encoder.rs:842
Methodencode
(&self, bytes: &mut BytesMut)
mqtt-v5/src/types.rs:118
Methodencode_to_bytes
(&self, bytes: &mut BytesMut)
mqtt-v5/src/types.rs:69
Methodfmt
(&self, f: &mut std::fmt::Formatter<'_>)
mqtt-v5/src/topic.rs:60
Methodfrom
(_err: websocket_codec::Error)
mqtt-v5/src/types.rs:44
Methodfrom
(err: std::io::Error)
mqtt-v5/src/lib.rs:103
next →1–100 of 149, ranked by callers