1234567891011121314151617 |
- #ifndef MQTT_CACHE_H
- #define MQTT_CACHE_H
- #include "mqtt_ringbuffer.h"
- int mqtt_cache_open(const char* dir, const char* table_name, void** handle);
- int mqtt_cache_read_one_payload(void *handle, const char *table_name, mqtt_ringbuffer_element_t *e, int *idx);
- int mqtt_cache_write_one_payload(void *handle, const char *table_name, mqtt_ringbuffer_element_t e);
- int mqtt_cache_delete_one_payload(void* handle, const char* table_name,int rowid);
- int mqtt_cache_get_payload_nb(void* handle, const char* table_name, int* nb);
- int mqtt_cache_get_memory_size(void* handle, long* size);
- void mqtt_cache_close(void* handle);
- int mqtt_cache_free_memory(void* handle);
- #endif /* MQTT_CACHE_H */
|