aiot_linkconfig_api.h

浏览该文件的文档.

#ifndef _AIOT_LINK_CONFIG_H_
#define _AIOT_LINK_CONFIG_H_

#if defined(__cplusplus)
extern "C" {
#endif

#include <stdint.h>
#include "aiot_message_api.h"
#include "aiot_sysdep_api.h"

typedef enum {
    MQTT_PROTOCOL,
    HTTP_PROTOCOL,
} aiot_protocol_type_t;

typedef struct {
    void *(*init)(void *proto_config);
    int32_t (*connect)(void *handle);
    int32_t (*send_message)(void *handle, const aiot_msg_t *message);
    int32_t (*sub_topic)(void *handle, char *topic, uint8_t qos);
    int32_t (*unsub_topic)(void *handle, char *topic, uint8_t qos);
    int32_t (*disconnect)(void *handle);
    void (*deinit)(void **handle);
} aiot_protocol_t;

typedef struct {
    /* 协议处理的方法实现 */
    aiot_protocol_t *protocol;
    /* 对应协议的配置 */
    void *proto_config;
    /* 多连接配置, 起始connect_id */
    int32_t start_cid;
    /* 多连接配置，通道的个数 */
    int32_t channel_num;
} aiot_linkconfig_t;

aiot_linkconfig_t *aiot_linkconfig_init(aiot_protocol_t *protocol);

int32_t aiot_linkconfig_deinit(aiot_linkconfig_t **config);

int32_t aiot_linkconfig_host(aiot_linkconfig_t *config, char *host, uint16_t port);

int32_t aiot_linkconfig_cred_option(aiot_linkconfig_t *config, aiot_sysdep_network_cred_option_t option);

int32_t aiot_linkconfig_root_cert(aiot_linkconfig_t *config, const char *cert, uint32_t len);

int32_t aiot_linkconfig_client_cert_privkey(aiot_linkconfig_t *config, char *client_cert, uint32_t cert_len, char *client_privkey, uint32_t key_len);

int32_t aiot_linkconfig_connect_timeout(aiot_linkconfig_t *config, uint32_t timeout_ms);

int32_t aiot_linkconfig_recv_timeout(aiot_linkconfig_t *config, uint32_t timeout_ms);

int32_t aiot_linkconfig_send_timeout(aiot_linkconfig_t *config, uint32_t timeout_ms);

int32_t aiot_linkconfig_reconnect_enable(aiot_linkconfig_t *config, uint8_t enable);

int32_t aiot_linkconfig_multi_channel(aiot_linkconfig_t *config, uint32_t start_cid, uint32_t num);

int32_t aiot_linkconfig_mqtt_extclientid(aiot_linkconfig_t *config, char *extern_clientid);

int32_t aiot_linkconfig_mqtt_keepalive(aiot_linkconfig_t *config, uint16_t keep_alive_s);

int32_t aiot_linkconfig_mqtt_cleansession(aiot_linkconfig_t *config, uint8_t clean_session);

int32_t aiot_linkconfig_mqtt_heartbeat_interval(aiot_linkconfig_t *config, uint32_t interval_ms);

int32_t aiot_linkconfig_dynamic_register(aiot_linkconfig_t *config, char *product_secret, char *instance_id);

int32_t aiot_linkconfig_mqtt_auth(aiot_linkconfig_t *config, char *username, char *password, char *clientid);

#if defined(__cplusplus)
}
#endif

#endif