nicolabs/mosquitto
1
0
Fork 0
mirror of https://github.com/eclipse-mosquitto/mosquitto.git synced 2026-05-21 12:24:29 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions
mosquitto/plugins/persist-sqlite/persist_sqlite.h

76 lines
2.9 KiB
C
Raw Normal View History

Sqlite persistence plugin.
2021-12-11 23:37:41 +01:00
/*
Rename of mosquitto_msg_store struct. struct mosquitto_msg_store -> struct mosquitto_base_msg This is the base message which client messages and retained messages refer to. The base messages are still held in the message store. This change comes about because the persistence interface exposes these message types. Prior to this commit the different messages were "msg", "client_msg", and "retain". After this commit there is "base_msg", "client_msg", and and "retain_msg" in the persist interface.
2022-02-22 17:57:24 +01:00
Copyright (c) 2021,2022 Roger Light <roger@atchoo.org>
Sqlite persistence plugin.
2021-12-11 23:37:41 +01:00
All rights reserved. This program and the accompanying materials
are made available under the terms of the Eclipse Public License 2.0
and Eclipse Distribution License v1.0 which accompany this distribution.
The Eclipse Public License is available at
https://www.eclipse.org/legal/epl-2.0/
and the Eclipse Distribution License is available at
http://www.eclipse.org/org/documents/edl-v10.php.
SPDX-License-Identifier: EPL-2.0 OR BSD-3-Clause
Contributors:
Roger Light - initial implementation and documentation.
*/
#ifndef PERSIST_SQLITE_H
#define PERSIST_SQLITE_H
#include <sqlite3.h>
persist-sqlite: commit transactions once every 5 seconds
2022-02-12 00:38:50 +01:00
#include <time.h>
Sqlite persistence plugin.
2021-12-11 23:37:41 +01:00
#ifndef UNUSED
# define UNUSED(A) (void)(A)
#endif
struct mosquitto_sqlite {
char *db_file;
sqlite3 *db;
sqlite3_stmt *client_add_stmt;
sqlite3_stmt *client_remove_stmt;
sqlite3_stmt *client_update_stmt;
sqlite3_stmt *subscription_add_stmt;
sqlite3_stmt *subscription_remove_stmt;
sqlite3_stmt *subscription_clear_stmt;
sqlite3_stmt *client_msg_add_stmt;
sqlite3_stmt *client_msg_remove_stmt;
sqlite3_stmt *client_msg_update_stmt;
sqlite3_stmt *client_msg_clear_stmt;
Optimise persist client msg clearing.
2022-03-18 11:51:28 +01:00
sqlite3_stmt *client_msg_clear_all_stmt;
Rename of mosquitto_msg_store struct. struct mosquitto_msg_store -> struct mosquitto_base_msg This is the base message which client messages and retained messages refer to. The base messages are still held in the message store. This change comes about because the persistence interface exposes these message types. Prior to this commit the different messages were "msg", "client_msg", and "retain". After this commit there is "base_msg", "client_msg", and and "retain_msg" in the persist interface.
2022-02-22 17:57:24 +01:00
sqlite3_stmt *base_msg_add_stmt;
sqlite3_stmt *base_msg_remove_stmt;
sqlite3_stmt *base_msg_load_stmt;
Rename persist retain_add to retain_set
2022-03-01 21:30:26 +01:00
sqlite3_stmt *retain_msg_set_stmt;
Rename of mosquitto_msg_store struct. struct mosquitto_msg_store -> struct mosquitto_base_msg This is the base message which client messages and retained messages refer to. The base messages are still held in the message store. This change comes about because the persistence interface exposes these message types. Prior to this commit the different messages were "msg", "client_msg", and "retain". After this commit there is "base_msg", "client_msg", and and "retain_msg" in the persist interface.
2022-02-22 17:57:24 +01:00
sqlite3_stmt *retain_msg_remove_stmt;
persist-sqlite: commit transactions once every 5 seconds
2022-02-12 00:38:50 +01:00
time_t last_transaction;
Sqlite persistence plugin.
2021-12-11 23:37:41 +01:00
int synchronous;
Persist-sqlite: add flush_period and page_size options Signed-off-by: Abilio Marques <abiliojr@gmail.com>
2022-04-29 07:35:47 +02:00
unsigned int event_count;
unsigned int flush_period;
unsigned int page_size;
Sqlite persistence plugin.
2021-12-11 23:37:41 +01:00
};
int persist_sqlite__init(struct mosquitto_sqlite *ms);
void persist_sqlite__cleanup(struct mosquitto_sqlite *ms);
int persist_sqlite__restore_cb(int event, void *event_data, void *userdata);
int persist_sqlite__client_add_cb(int event, void *event_data, void *userdata);
int persist_sqlite__client_update_cb(int event, void *event_data, void *userdata);
int persist_sqlite__client_remove_cb(int event, void *event_data, void *userdata);
int persist_sqlite__client_msg_add_cb(int event, void *event_data, void *userdata);
int persist_sqlite__client_msg_clear_cb(int event, void *event_data, void *userdata);
int persist_sqlite__client_msg_remove_cb(int event, void *event_data, void *userdata);
int persist_sqlite__client_msg_update_cb(int event, void *event_data, void *userdata);
Rename of mosquitto_msg_store struct. struct mosquitto_msg_store -> struct mosquitto_base_msg This is the base message which client messages and retained messages refer to. The base messages are still held in the message store. This change comes about because the persistence interface exposes these message types. Prior to this commit the different messages were "msg", "client_msg", and "retain". After this commit there is "base_msg", "client_msg", and and "retain_msg" in the persist interface.
2022-02-22 17:57:24 +01:00
int persist_sqlite__base_msg_add_cb(int event, void *event_data, void *userdata);
int persist_sqlite__base_msg_load_cb(int event, void *event_data, void *userdata);
int persist_sqlite__base_msg_remove_cb(int event, void *event_data, void *userdata);
Rename persist retain_add to retain_set
2022-03-01 21:30:26 +01:00
int persist_sqlite__retain_msg_set_cb(int event, void *event_data, void *userdata);
Rename of mosquitto_msg_store struct. struct mosquitto_msg_store -> struct mosquitto_base_msg This is the base message which client messages and retained messages refer to. The base messages are still held in the message store. This change comes about because the persistence interface exposes these message types. Prior to this commit the different messages were "msg", "client_msg", and "retain". After this commit there is "base_msg", "client_msg", and and "retain_msg" in the persist interface.
2022-02-22 17:57:24 +01:00
int persist_sqlite__retain_msg_remove_cb(int event, void *event_data, void *userdata);
Sqlite persistence plugin.
2021-12-11 23:37:41 +01:00
int persist_sqlite__subscription_add_cb(int event, void *event_data, void *userdata);
int persist_sqlite__subscription_remove_cb(int event, void *event_data, void *userdata);
persist-sqlite: commit transactions once every 5 seconds
2022-02-12 00:38:50 +01:00
int persist_sqlite__tick_cb(int event, void *event_data, void *userdata);
Sqlite persistence plugin.
2021-12-11 23:37:41 +01:00
#endif
Reference in a new issue Copy permalink