@@ -780,6 +780,17 @@ Documentation not found.
780
780
AWS_ERROR_MQTT_CONNECTION_RESUBSCRIBE_NO_TOPICS = 5163
781
781
AWS_ERROR_MQTT_CONNECTION_SUBSCRIBE_FAILURE = 5164
782
782
AWS_ERROR_MQTT_ACK_REASON_CODE_FAILURE = 5165
783
+ AWS_ERROR_MQTT_PROTOCOL_ADAPTER_FAILING_REASON_CODE = 5166
784
+ AWS_ERROR_MQTT_REQUEST_RESPONSE_CLIENT_SHUT_DOWN = 5167
785
+ AWS_ERROR_MQTT_REQUEST_RESPONSE_TIMEOUT = 5168
786
+ AWS_ERROR_MQTT_REQUEST_RESPONSE_NO_SUBSCRIPTION_CAPACITY = 5169
787
+ AWS_ERROR_MQTT_REQUEST_RESPONSE_SUBSCRIBE_FAILURE = 5170
788
+ AWS_ERROR_MQTT_REQUEST_RESPONSE_INTERNAL_ERROR = 5171
789
+ AWS_ERROR_MQTT_REQUEST_RESPONSE_PUBLISH_FAILURE = 5172
790
+ AWS_ERROR_MQTT_REUQEST_RESPONSE_STREAM_ALREADY_ACTIVATED = 5173
791
+ AWS_ERROR_MQTT_REQUEST_RESPONSE_MODELED_SERVICE_ERROR = 5174
792
+ AWS_ERROR_MQTT_REQUEST_RESPONSE_PAYLOAD_PARSE_ERROR = 5175
793
+ AWS_ERROR_MQTT_REQUEST_RESPONSE_INVALID_RESPONSE_PATH = 5176
783
794
AWS_ERROR_END_MQTT_RANGE = 6143
784
795
end
785
796
@@ -796,6 +807,7 @@ Documentation not found.
796
807
AWS_LS_MQTT5_CLIENT = 5124
797
808
AWS_LS_MQTT5_CANARY = 5125
798
809
AWS_LS_MQTT5_TO_MQTT3_ADAPTER = 5126
810
+ AWS_LS_MQTT_REQUEST_RESPONSE = 5127
799
811
end
800
812
801
813
"""
@@ -915,6 +927,247 @@ function aws_mqtt_client_get_topic_for_outstanding_publish_packet(connection, pa
915
927
ccall ((:aws_mqtt_client_get_topic_for_outstanding_publish_packet , libaws_c_mqtt), Cint, (Ptr{aws_mqtt_client_connection}, UInt16, Ptr{aws_allocator}, Ptr{Ptr{aws_string}}), connection, packet_id, allocator, result)
916
928
end
917
929
930
+ """
931
+ Documentation not found.
932
+ """
933
+ mutable struct aws_mqtt_request_response_client end
934
+
935
+ """
936
+ aws_mqtt_request_operation_response_path
937
+
938
+ Documentation not found.
939
+ """
940
+ struct aws_mqtt_request_operation_response_path
941
+ topic:: aws_byte_cursor
942
+ correlation_token_json_path:: aws_byte_cursor
943
+ end
944
+
945
+ # typedef void ( aws_mqtt_request_operation_completion_fn ) ( const struct aws_byte_cursor * response_topic , const struct aws_byte_cursor * payload , int error_code , void * user_data )
946
+ """
947
+ Documentation not found.
948
+ """
949
+ const aws_mqtt_request_operation_completion_fn = Cvoid
950
+
951
+ """
952
+ aws_mqtt_request_operation_options
953
+
954
+ Documentation not found.
955
+ """
956
+ struct aws_mqtt_request_operation_options
957
+ subscription_topic_filters:: Ptr{aws_byte_cursor}
958
+ subscription_topic_filter_count:: Csize_t
959
+ response_paths:: Ptr{aws_mqtt_request_operation_response_path}
960
+ response_path_count:: Csize_t
961
+ publish_topic:: aws_byte_cursor
962
+ serialized_request:: aws_byte_cursor
963
+ correlation_token:: aws_byte_cursor
964
+ completion_callback:: Ptr{aws_mqtt_request_operation_completion_fn}
965
+ user_data:: Ptr{Cvoid}
966
+ end
967
+
968
+ """
969
+ aws_rr_streaming_subscription_event_type
970
+
971
+ Documentation not found.
972
+ """
973
+ @cenum aws_rr_streaming_subscription_event_type:: UInt32 begin
974
+ ARRSSET_SUBSCRIPTION_ESTABLISHED = 0
975
+ ARRSSET_SUBSCRIPTION_LOST = 1
976
+ ARRSSET_SUBSCRIPTION_HALTED = 2
977
+ end
978
+
979
+ # typedef void ( aws_mqtt_streaming_operation_subscription_status_fn ) ( enum aws_rr_streaming_subscription_event_type status , int error_code , void * user_data )
980
+ """
981
+ Documentation not found.
982
+ """
983
+ const aws_mqtt_streaming_operation_subscription_status_fn = Cvoid
984
+
985
+ # typedef void ( aws_mqtt_streaming_operation_incoming_publish_fn ) ( struct aws_byte_cursor payload , struct aws_byte_cursor topic , void * user_data )
986
+ """
987
+ Documentation not found.
988
+ """
989
+ const aws_mqtt_streaming_operation_incoming_publish_fn = Cvoid
990
+
991
+ # typedef void ( aws_mqtt_streaming_operation_terminated_fn ) ( void * user_data )
992
+ """
993
+ Documentation not found.
994
+ """
995
+ const aws_mqtt_streaming_operation_terminated_fn = Cvoid
996
+
997
+ """
998
+ aws_mqtt_streaming_operation_options
999
+
1000
+ Documentation not found.
1001
+ """
1002
+ struct aws_mqtt_streaming_operation_options
1003
+ topic_filter:: aws_byte_cursor
1004
+ subscription_status_callback:: Ptr{aws_mqtt_streaming_operation_subscription_status_fn}
1005
+ incoming_publish_callback:: Ptr{aws_mqtt_streaming_operation_incoming_publish_fn}
1006
+ terminated_callback:: Ptr{aws_mqtt_streaming_operation_terminated_fn}
1007
+ user_data:: Ptr{Cvoid}
1008
+ end
1009
+
1010
+ # typedef void ( aws_mqtt_request_response_client_initialized_callback_fn ) ( void * user_data )
1011
+ """
1012
+ Documentation not found.
1013
+ """
1014
+ const aws_mqtt_request_response_client_initialized_callback_fn = Cvoid
1015
+
1016
+ # typedef void ( aws_mqtt_request_response_client_terminated_callback_fn ) ( void * user_data )
1017
+ """
1018
+ Documentation not found.
1019
+ """
1020
+ const aws_mqtt_request_response_client_terminated_callback_fn = Cvoid
1021
+
1022
+ """
1023
+ aws_mqtt_request_response_client_options
1024
+
1025
+ Documentation not found.
1026
+ """
1027
+ struct aws_mqtt_request_response_client_options
1028
+ max_request_response_subscriptions:: Csize_t
1029
+ max_streaming_subscriptions:: Csize_t
1030
+ operation_timeout_seconds:: UInt32
1031
+ initialized_callback:: Ptr{aws_mqtt_request_response_client_initialized_callback_fn}
1032
+ terminated_callback:: Ptr{aws_mqtt_request_response_client_terminated_callback_fn}
1033
+ user_data:: Ptr{Cvoid}
1034
+ end
1035
+
1036
+ """
1037
+ aws_mqtt_request_response_client_new_from_mqtt311_client(allocator, client, options)
1038
+
1039
+ Documentation not found.
1040
+ ### Prototype
1041
+ ```c
1042
+ struct aws_mqtt_request_response_client *aws_mqtt_request_response_client_new_from_mqtt311_client( struct aws_allocator *allocator, struct aws_mqtt_client_connection *client, const struct aws_mqtt_request_response_client_options *options);
1043
+ ```
1044
+ """
1045
+ function aws_mqtt_request_response_client_new_from_mqtt311_client (allocator, client, options)
1046
+ ccall ((:aws_mqtt_request_response_client_new_from_mqtt311_client , libaws_c_mqtt), Ptr{aws_mqtt_request_response_client}, (Ptr{aws_allocator}, Ptr{aws_mqtt_client_connection}, Ptr{aws_mqtt_request_response_client_options}), allocator, client, options)
1047
+ end
1048
+
1049
+ """
1050
+ aws_mqtt_request_response_client_new_from_mqtt5_client(allocator, client, options)
1051
+
1052
+ Documentation not found.
1053
+ ### Prototype
1054
+ ```c
1055
+ struct aws_mqtt_request_response_client *aws_mqtt_request_response_client_new_from_mqtt5_client( struct aws_allocator *allocator, struct aws_mqtt5_client *client, const struct aws_mqtt_request_response_client_options *options);
1056
+ ```
1057
+ """
1058
+ function aws_mqtt_request_response_client_new_from_mqtt5_client (allocator, client, options)
1059
+ ccall ((:aws_mqtt_request_response_client_new_from_mqtt5_client , libaws_c_mqtt), Ptr{aws_mqtt_request_response_client}, (Ptr{aws_allocator}, Ptr{aws_mqtt5_client}, Ptr{aws_mqtt_request_response_client_options}), allocator, client, options)
1060
+ end
1061
+
1062
+ """
1063
+ aws_mqtt_request_response_client_acquire(client)
1064
+
1065
+ Documentation not found.
1066
+ ### Prototype
1067
+ ```c
1068
+ struct aws_mqtt_request_response_client *aws_mqtt_request_response_client_acquire( struct aws_mqtt_request_response_client *client);
1069
+ ```
1070
+ """
1071
+ function aws_mqtt_request_response_client_acquire (client)
1072
+ ccall ((:aws_mqtt_request_response_client_acquire , libaws_c_mqtt), Ptr{aws_mqtt_request_response_client}, (Ptr{aws_mqtt_request_response_client},), client)
1073
+ end
1074
+
1075
+ """
1076
+ aws_mqtt_request_response_client_release(client)
1077
+
1078
+ Documentation not found.
1079
+ ### Prototype
1080
+ ```c
1081
+ struct aws_mqtt_request_response_client *aws_mqtt_request_response_client_release( struct aws_mqtt_request_response_client *client);
1082
+ ```
1083
+ """
1084
+ function aws_mqtt_request_response_client_release (client)
1085
+ ccall ((:aws_mqtt_request_response_client_release , libaws_c_mqtt), Ptr{aws_mqtt_request_response_client}, (Ptr{aws_mqtt_request_response_client},), client)
1086
+ end
1087
+
1088
+ """
1089
+ aws_mqtt_request_response_client_submit_request(client, request_options)
1090
+
1091
+ Documentation not found.
1092
+ ### Prototype
1093
+ ```c
1094
+ int aws_mqtt_request_response_client_submit_request( struct aws_mqtt_request_response_client *client, const struct aws_mqtt_request_operation_options *request_options);
1095
+ ```
1096
+ """
1097
+ function aws_mqtt_request_response_client_submit_request (client, request_options)
1098
+ ccall ((:aws_mqtt_request_response_client_submit_request , libaws_c_mqtt), Cint, (Ptr{aws_mqtt_request_response_client}, Ptr{aws_mqtt_request_operation_options}), client, request_options)
1099
+ end
1100
+
1101
+ """
1102
+ Documentation not found.
1103
+ """
1104
+ mutable struct aws_mqtt_rr_client_operation end
1105
+
1106
+ """
1107
+ aws_mqtt_request_response_client_create_streaming_operation(client, streaming_options)
1108
+
1109
+ Documentation not found.
1110
+ ### Prototype
1111
+ ```c
1112
+ struct aws_mqtt_rr_client_operation *aws_mqtt_request_response_client_create_streaming_operation( struct aws_mqtt_request_response_client *client, const struct aws_mqtt_streaming_operation_options *streaming_options);
1113
+ ```
1114
+ """
1115
+ function aws_mqtt_request_response_client_create_streaming_operation (client, streaming_options)
1116
+ ccall ((:aws_mqtt_request_response_client_create_streaming_operation , libaws_c_mqtt), Ptr{aws_mqtt_rr_client_operation}, (Ptr{aws_mqtt_request_response_client}, Ptr{aws_mqtt_streaming_operation_options}), client, streaming_options)
1117
+ end
1118
+
1119
+ """
1120
+ aws_mqtt_request_response_client_get_event_loop(client)
1121
+
1122
+ Documentation not found.
1123
+ ### Prototype
1124
+ ```c
1125
+ struct aws_event_loop *aws_mqtt_request_response_client_get_event_loop( struct aws_mqtt_request_response_client *client);
1126
+ ```
1127
+ """
1128
+ function aws_mqtt_request_response_client_get_event_loop (client)
1129
+ ccall ((:aws_mqtt_request_response_client_get_event_loop , libaws_c_mqtt), Ptr{aws_event_loop}, (Ptr{aws_mqtt_request_response_client},), client)
1130
+ end
1131
+
1132
+ """
1133
+ aws_mqtt_rr_client_operation_activate(operation)
1134
+
1135
+ Documentation not found.
1136
+ ### Prototype
1137
+ ```c
1138
+ int aws_mqtt_rr_client_operation_activate(struct aws_mqtt_rr_client_operation *operation);
1139
+ ```
1140
+ """
1141
+ function aws_mqtt_rr_client_operation_activate (operation)
1142
+ ccall ((:aws_mqtt_rr_client_operation_activate , libaws_c_mqtt), Cint, (Ptr{aws_mqtt_rr_client_operation},), operation)
1143
+ end
1144
+
1145
+ """
1146
+ aws_mqtt_rr_client_operation_acquire(operation)
1147
+
1148
+ Documentation not found.
1149
+ ### Prototype
1150
+ ```c
1151
+ struct aws_mqtt_rr_client_operation *aws_mqtt_rr_client_operation_acquire( struct aws_mqtt_rr_client_operation *operation);
1152
+ ```
1153
+ """
1154
+ function aws_mqtt_rr_client_operation_acquire (operation)
1155
+ ccall ((:aws_mqtt_rr_client_operation_acquire , libaws_c_mqtt), Ptr{aws_mqtt_rr_client_operation}, (Ptr{aws_mqtt_rr_client_operation},), operation)
1156
+ end
1157
+
1158
+ """
1159
+ aws_mqtt_rr_client_operation_release(operation)
1160
+
1161
+ Documentation not found.
1162
+ ### Prototype
1163
+ ```c
1164
+ struct aws_mqtt_rr_client_operation *aws_mqtt_rr_client_operation_release( struct aws_mqtt_rr_client_operation *operation);
1165
+ ```
1166
+ """
1167
+ function aws_mqtt_rr_client_operation_release (operation)
1168
+ ccall ((:aws_mqtt_rr_client_operation_release , libaws_c_mqtt), Ptr{aws_mqtt_rr_client_operation}, (Ptr{aws_mqtt_rr_client_operation},), operation)
1169
+ end
1170
+
918
1171
"""
919
1172
aws_mqtt5_client_session_behavior_type
920
1173
0 commit comments