telemetry_service.h

Go to the documentation of this file.

 
#ifndef TELEMETRY_SERVICE_H
#define TELEMETRY_SERVICE_H
 
#include "freertos/FreeRTOS.h"
#include "mqtt_bridge.h"
#include "telemetry_pipeline.h"
 
#define TELEMETRY_SERVICE_TASK_NAME              ("TELE_SRVC") 
#define TELEMETRY_SERVICE_TASK_STACK_DEPTH       (4096U)       
#define TELEMETRY_SERVICE_TASK_PRIORITY          (4U)          
#define TELEMETRY_SERVICE_TASK_CPU_AFFINITY      (1U)          
#define TELEMETRY_SERVICE_TASK_NOTIFY_STOP_BIT   (1U << 0)     
#define TELEMETRY_SERVICE_TASK_NOTIFY_LIVE_BIT   (1U << 1)     
#define TELEMETRY_SERVICE_TASK_NOTIFY_REPLAY_BIT (1U << 2)     
#define TELEMETRY_SERVICE_TASK_NOTIFY_ONLINE_BIT (1U << 3)     
typedef enum {
    TELEMETRY_SERVICE_TOPICS_LIVE   = 0U, 
    TELEMETRY_SERVICE_TOPICS_REPLAY = 1U, 
    TELEMETRY_SERVICE_TOPICS_STATUS = 2U, 
    TELEMETRY_SERVICE_TOPICS_MAX          
} telemetry_service_topics_t;
 
bool telemetry_service_init (mqtt_bridge_config_t *mqtt_bridge_config_ptr, bool (*replay_check_cb) (void));
 
bool telemetry_service_enqueue_live (const telemetry_pipeline_record_t *payload_ptr);
 
bool telemetry_service_publish_live (const telemetry_pipeline_record_t *payload_ptr);
 
bool telemetry_service_publish_replay (const telemetry_pipeline_record_t *payload_ptr);
 
bool telemetry_service_publish_status (const telemetry_pipeline_record_t *payload_ptr);
 
void telemetry_service_notify_replay_available (void);
 
void telemetry_service_set_online (bool online);
 
bool telemetry_service_is_online (void);
 
void telemetry_service_deinit (void);
 
#endif