diff options
Diffstat (limited to 'aclk/aclk_util.h')
| -rw-r--r-- | aclk/aclk_util.h | 121 |
1 files changed, 0 insertions, 121 deletions
diff --git a/aclk/aclk_util.h b/aclk/aclk_util.h deleted file mode 100644 index 38ef5b0bc..000000000 --- a/aclk/aclk_util.h +++ /dev/null @@ -1,121 +0,0 @@ -// SPDX-License-Identifier: GPL-3.0-or-later -#ifndef ACLK_UTIL_H -#define ACLK_UTIL_H - -#include "libnetdata/libnetdata.h" - -#ifdef ENABLE_ACLK -#include "mqtt_wss_client.h" - -#define CLOUD_EC_MALFORMED_NODE_ID 1 -#define CLOUD_EMSG_MALFORMED_NODE_ID "URL requests node_id but there is not enough chars following (for it to be valid uuid)." -#define CLOUD_EC_NODE_NOT_FOUND 2 -#define CLOUD_EMSG_NODE_NOT_FOUND "Node with requested node_id not found" -#define CLOUD_EC_ZLIB_ERROR 3 -#define CLOUD_EMSG_ZLIB_ERROR "Error during zlib compression" -#define CLOUD_EC_REQ_REPLY_TOO_BIG 4 -#define CLOUD_EMSG_REQ_REPLY_TOO_BIG "Request reply produces message bigger than allowed maximum" -#define CLOUD_EC_FAIL_TOPIC 5 -#define CLOUD_EMSG_FAIL_TOPIC "Internal Topic Error" -#define CLOUD_EC_SND_TIMEOUT 6 -#define CLOUD_EMSG_SND_TIMEOUT "Timeout sending binpacked message" - -// Helper stuff which should not have any further inside ACLK dependency -// and are supposed not to be needed outside of ACLK -extern usec_t aclk_session_newarch; - -extern int chart_batch_id; - -typedef enum { - ACLK_ENC_UNKNOWN = 0, - ACLK_ENC_JSON, - ACLK_ENC_PROTO -} aclk_encoding_type_t; - -typedef enum { - ACLK_TRP_UNKNOWN = 0, - ACLK_TRP_MQTT_3_1_1, - ACLK_TRP_MQTT_5 -} aclk_transport_type_t; - -typedef struct { - char *endpoint; - aclk_transport_type_t type; -} aclk_transport_desc_t; - -typedef struct { - int base; - int max_s; - int min_s; -} aclk_backoff_t; - -typedef struct { - char *auth_endpoint; - aclk_encoding_type_t encoding; - - aclk_transport_desc_t **transports; - size_t transport_count; - - char **capabilities; - size_t capability_count; - - aclk_backoff_t backoff; -} aclk_env_t; - -extern aclk_env_t *aclk_env; - -aclk_encoding_type_t aclk_encoding_type_t_from_str(const char *str); -aclk_transport_type_t aclk_transport_type_t_from_str(const char *str); - -void aclk_transport_desc_t_destroy(aclk_transport_desc_t *trp_desc); -void aclk_env_t_destroy(aclk_env_t *env); -int aclk_env_has_capa(const char *capa); - -enum aclk_topics { - ACLK_TOPICID_UNKNOWN = 0, - ACLK_TOPICID_CHART = 1, - ACLK_TOPICID_ALARMS = 2, - ACLK_TOPICID_METADATA = 3, - ACLK_TOPICID_COMMAND = 4, - ACLK_TOPICID_AGENT_CONN = 5, - ACLK_TOPICID_CMD_NG_V1 = 6, - ACLK_TOPICID_CREATE_NODE = 7, - ACLK_TOPICID_NODE_CONN = 8, - ACLK_TOPICID_CHART_DIMS = 9, - ACLK_TOPICID_CHART_CONFIGS_UPDATED = 10, - ACLK_TOPICID_CHART_RESET = 11, - ACLK_TOPICID_RETENTION_UPDATED = 12, - ACLK_TOPICID_NODE_INFO = 13, - ACLK_TOPICID_ALARM_LOG = 14, - ACLK_TOPICID_ALARM_CHECKPOINT = 15, - ACLK_TOPICID_ALARM_CONFIG = 16, - ACLK_TOPICID_ALARM_SNAPSHOT = 17, - ACLK_TOPICID_NODE_COLLECTORS = 18, - ACLK_TOPICID_CTXS_SNAPSHOT = 19, - ACLK_TOPICID_CTXS_UPDATED = 20 -}; - -typedef size_t aclk_topic_cache_iter_t; -#define ACLK_TOPIC_CACHE_ITER_T_INITIALIZER (0) - -const char *aclk_get_topic(enum aclk_topics topic); -int aclk_generate_topic_cache(struct json_object *json); -void free_topic_cache(void); -const char *aclk_topic_cache_iterate(aclk_topic_cache_iter_t *iter); -// TODO -// aclk_topics_reload //when claim id changes - -#ifdef ACLK_LOG_CONVERSATION_DIR -extern volatile int aclk_conversation_log_counter; -#define ACLK_GET_CONV_LOG_NEXT() __atomic_fetch_add(&aclk_conversation_log_counter, 1, __ATOMIC_SEQ_CST) -#endif - -unsigned long int aclk_tbeb_delay(int reset, int base, unsigned long int min, unsigned long int max); -#define aclk_tbeb_reset(x) aclk_tbeb_delay(1, 0, 0, 0) - -void aclk_set_proxy(char **ohost, int *port, char **uname, char **pwd, enum mqtt_wss_proxy_type *type); -#endif /* ENABLE_ACLK */ - -int base64_encode_helper(unsigned char *out, int *outl, const unsigned char *in, int in_len); - -#endif /* ACLK_UTIL_H */ |