Functions — github.com/arnstein/aws-iot-device-sdk-rust

CodeHub MCPcopy Create free account

hub / github.com/arnstein/aws-iot-device-sdk-rust / functions

Functions33 in github.com/arnstein/aws-iot-device-sdk-rust

⨍ Functions 33 ◇ Types & classes 6

↓ 3 callersMethodget_receiver

Get a receiver of the incoming messages. Send this to any function that wants to read the incoming messages from IoT Core.

src/sync_client.rs:78

↓ 2 callersFunctionnormalize_key

(key_pem: Vec<u8>)

src/settings.rs:65

↓ 2 callersFunctionset_overrides

(settings: AWSIoTSettings)

src/settings.rs:191

↓ 2 callersMethodsubscribe

Subscribe to a topic.

src/sync_client.rs:52

↓ 1 callersFunctionasync_event_loop_listener

( (mut eventloop, incoming_event_sender): (EventLoop, Sender<Incoming>), )

src/async_client.rs:7

↓ 1 callersFunctionevent_loop_listener

( (mut connection, event_bus): (Connection, EventBus), )

src/sync_client.rs:9

↓ 1 callersFunctionget_mqtt_options

( settings: AWSIoTSettings, )

src/settings.rs:265

↓ 1 callersFunctionget_mqtt_options_async

( settings: AWSIoTSettings, )

src/settings.rs:234

↓ 1 callersFunctionmake_settings

tests/async_client_test.rs:5

↓ 1 callersFunctionmake_settings

tests/sync_client_test.rs:5

↓ 1 callersMethodpublish

Publish to topic.

src/sync_client.rs:61

↓ 1 callersMethodsubscribe

Subscribe to a topic.

src/async_client.rs:60

Functiondefault_overrides_are_all_none

tests/settings_test.rs:46

Functionerror_is_debug

tests/error_test.rs:25

(&self, f: &mut fmt::Formatter)

src/error.rs:20

(err: std::io::Error)

src/error.rs:50

Methodget_client

If you want to use the Rumqttc AsyncClient and EventLoop manually, this method can be used to get the AsyncClient.

src/async_client.rs:93

Methodget_client

If you want to use the Rumqttc Client and Connection manually, this method can be used to get the Client.

src/sync_client.rs:84

Methodget_receiver

Get a receiver of the incoming messages. Send this to any function that wants to read the incoming messages from IoT Core.

src/async_client.rs:87

Functionio_error_display

tests/error_test.rs:16

Functionio_error_preserves_source

tests/error_test.rs:6

examples/pubsub_async.rs:6

examples/pubsub_sync.rs:5

Functionmax_packet_size_stores_values

tests/settings_test.rs:61

Create new AWSIoTAsyncClient. Input argument should be the AWSIoTSettings. Returns a tuple where the first element is the AWSIoTAsyncClient, and the s

src/async_client.rs:33

(incoming_max_packet_size: usize, outgoing_max_packet_size: usize)

src/settings.rs:14

Create new AWSIoTClient. Input argument should be the AWSIoTSettings. Returns a tuple where the first element is the AWSIoTClient, and the second elem

src/sync_client.rs:35

Functionnew_client_fails_with_missing_certs

tests/async_client_test.rs:17

Functionnew_client_fails_with_missing_certs

tests/sync_client_test.rs:17

Functionnew_settings_stores_fields

tests/settings_test.rs:6

Functionnew_settings_with_overrides

tests/settings_test.rs:20

Publish to topic.

src/async_client.rs:69

src/error.rs:38