Index

A

args module

attribute_request_id (modules.mqtt.GatewayMqttClient attribute)

C

calc_file_hash() (modules.file_writer.GatewayFileWriter method) check() (modules.sqlite.SqliteConnection method)

close() (modules.sqlite.SqliteConnection method) connected (modules.mqtt.GatewayMqttClient attribute) CONTROLLER_MESSAGES (modules.sqlite.SqliteTables attribute)

D

db_schemas.controller_archive_table module db_schemas.controller_messages_table module db_schemas.pending_messages_table module

debug() (in module modules.logging) did_file_change() (modules.file_writer.GatewayFileWriter method) do_table_values_exist() (modules.sqlite.SqliteConnection method) does_table_exist() (modules.sqlite.SqliteConnection method)

E

error() (in module modules.logging) execute() (modules.sqlite.SqliteConnection method)

execute_fetch() (modules.git_client.GatewayGitClient method) execute_reset_to_commit() (modules.git_client.GatewayGitClient method) expand_file_path() (modules.file_writer.GatewayFileWriter method)

F

fatal_error() (in module utils.misc) file_exists() (in module utils.misc)

files (modules.file_writer.GatewayFileWriter attribute) forced_shutdown_handler() (in module main)

G

GatewayFileWriter (class in modules.file_writer) GatewayGitClient (class in modules.git_client) GatewayMqttClient (class in modules.mqtt) get_commit_for_tag() (modules.git_client.GatewayGitClient method) get_commit_from_hash_or_tag() (modules.git_client.GatewayGitClient method) get_current_commit() (modules.git_client.GatewayGitClient method)

get_device_name() (in module self_provisioning) get_files() (modules.file_writer.GatewayFileWriter method) get_instance_maybe() (in module utils.misc) get_last_controller_health_check_ts() (in module main) get_maybe() (in module utils.misc) get_tb_file_hashes() (modules.file_writer.GatewayFileWriter method) graceful_exit() (modules.mqtt.GatewayMqttClient method)

H

hashes (modules.file_writer.GatewayFileWriter attribute)

HEALTH_CHECK (modules.sqlite.SqliteTables attribute)

I

info() (in module modules.logging) init() (modules.mqtt.GatewayMqttClient method)

initialized (modules.mqtt.GatewayMqttClient attribute) is_table_empty() (modules.sqlite.SqliteConnection method)

L

log() (in module modules.logging)

M

main module message_queue (modules.mqtt.GatewayMqttClient attribute) module args db_schemas.controller_archive_table db_schemas.controller_messages_table db_schemas.pending_messages_table main modules.file_writer modules.git_client modules.logging modules.mqtt modules.sqlite on_mqtt_msg.check_for_file_content_update on_mqtt_msg.check_for_file_hashes_update on_mqtt_msg.check_for_files_definition_update on_mqtt_msg.check_for_ota_updates on_mqtt_msg.on_rpc_request self_provisioning utils.controller_restart utils.misc utils.paths

modules.file_writer module modules.git_client module modules.logging module modules.mqtt module modules.sqlite module

O

on_mqtt_msg.check_for_file_content_update module on_mqtt_msg.check_for_file_hashes_update module on_mqtt_msg.check_for_files_definition_update module on_mqtt_msg.check_for_ota_updates module

on_mqtt_msg.on_rpc_request module on_msg_check_for_file_content_update() (in module on_mqtt_msg.check_for_file_content_update) on_msg_check_for_file_hashes_update() (in module on_mqtt_msg.check_for_file_hashes_update) on_msg_check_for_files_definition_update() (in module on_mqtt_msg.check_for_files_definition_update) on_msg_check_for_ota_update() (in module on_mqtt_msg.check_for_ota_updates) on_rpc_request() (in module on_mqtt_msg.on_rpc_request)

P

parse_args() (in module args) PENDING_MQTT_MESSAGES (modules.sqlite.SqliteTables attribute) publish_log() (modules.mqtt.GatewayMqttClient method)

publish_message_raw() (modules.mqtt.GatewayMqttClient method) publish_sw_state() (modules.mqtt.GatewayMqttClient method) publish_telemetry() (modules.mqtt.GatewayMqttClient method)

R

read_file() (modules.file_writer.GatewayFileWriter method) read_file_raw() (modules.file_writer.GatewayFileWriter method) request_attributes() (modules.mqtt.GatewayMqttClient method) reset_db_conn() (modules.sqlite.SqliteConnection method) restart_controller_if_needed() (in module utils.controller_restart) rpc_archive_discard_messages() (in module on_mqtt_msg.on_rpc_request) rpc_archive_republish_messages() (in module on_mqtt_msg.on_rpc_request)

rpc_exit() (in module on_mqtt_msg.on_rpc_request) rpc_init_files() (in module on_mqtt_msg.on_rpc_request) rpc_ping() (in module on_mqtt_msg.on_rpc_request) rpc_reboot() (in module on_mqtt_msg.on_rpc_request) rpc_restart_controller() (in module on_mqtt_msg.on_rpc_request) rpc_run_command() (in module on_mqtt_msg.on_rpc_request) rpc_shutdown() (in module on_mqtt_msg.on_rpc_request)

S

self_provisioning module self_provisioning_get_access_token() (in module self_provisioning) send_rpc_method_error() (in module on_mqtt_msg.on_rpc_request) send_rpc_response() (in module on_mqtt_msg.on_rpc_request)

set_files() (modules.file_writer.GatewayFileWriter method) set_tb_hashes() (modules.file_writer.GatewayFileWriter method) shutdown_handler() (in module main) SqliteConnection (class in modules.sqlite) SqliteTables (class in modules.sqlite)

T

tb_hashes (modules.file_writer.GatewayFileWriter attribute)

U

update_sys_info_attribute() (modules.mqtt.GatewayMqttClient method) utils.controller_restart module

utils.misc module utils.paths module

V

verify_commit_hash_or_tag_exists() (modules.git_client.GatewayGitClient method)

verify_start_end_timestamp_params() (in module on_mqtt_msg.on_rpc_request)

W

warn() (in module modules.logging)

write_file_content_to_client_attribute() (in module modules.file_writer)