uv_mutex_t mutex;

uv_cond_t cond;

volatile unsigned completed;

"after insert on aclk_chart_payload_%s " \

"begin insert into aclk_chart_%s (uuid, unique_id, type, status, date_created) values " \

" (new.uuid, new.unique_id, new.type, 'pending', strftime('%%s')) on conflict(uuid, status) " \

" do update set unique_id = new.unique_id, update_count = update_count + 1; " \

"end;"

"alert_unique_id, date_created, date_submitted, " \

"unique(alert_unique_id)); " \

"insert into aclk_alert_%s (alert_unique_id, date_created) " \

"select unique_id alert_unique_id, strftime('%%s') date_created from health_log_%s where new_status <> 0 and new_status <> -2 order by unique_id asc on conflict (alert_unique_id) do nothing;"

ACLK_DATABASE_NOOP = 0,

ACLK_DATABASE_ADD_ALERT,

ACLK_DATABASE_ADD_CHART,

ACLK_DATABASE_ADD_DIMENSION,

ACLK_DATABASE_ALARM_HEALTH_LOG,

ACLK_DATABASE_CHART_ACK,

ACLK_DATABASE_CHECK,

ACLK_DATABASE_CHECK_ROTATION,

ACLK_DATABASE_CLEANUP,

ACLK_DATABASE_DEDUP_CHART,

ACLK_DATABASE_DELETE_HOST,

ACLK_DATABASE_NODE_INFO,

ACLK_DATABASE_PUSH_ALERT,

ACLK_DATABASE_PUSH_ALERT_CONFIG,

ACLK_DATABASE_PUSH_CHART,

ACLK_DATABASE_PUSH_CHART_CONFIG,

ACLK_DATABASE_RESET_CHART,

ACLK_DATABASE_RESET_NODE,

ACLK_DATABASE_SHUTDOWN,

ACLK_DATABASE_STATUS_CHART,

ACLK_DATABASE_SYNC_CHART_SEQ,

ACLK_DATABASE_TIMER,

ACLK_DATABASE_UPD_STATS,

ACLK_DATABASE_MAX_OPCODE

long sequence_id;

long last_sequence_id;

char *payload;

struct aclk_chart_payload_t *next;

enum aclk_database_opcode opcode;

void *data;

void *data_param;

int count;

uint64_t param1;

struct aclk_completion *completion;

uv_thread_t thread;

char uuid_str[GUID_LEN + 1];

char node_id[GUID_LEN + 1];

char host_guid[GUID_LEN + 1];

uint64_t chart_sequence_id; // last chart_sequence_id

time_t chart_timestamp; // last chart timestamp

time_t cleanup_after; // Start a cleanup after this timestamp

time_t startup_time; // When the sync thread started

uint64_t batch_id; // batch id to use

uint64_t alerts_batch_id; // batch id for alerts to use

uint64_t alerts_start_seq_id; // cloud has asked to start streaming from

uint64_t alert_sequence_id; // last alert sequence_id

uv_loop_t *loop;

RRDHOST *host;

uv_async_t async;

/* FIFO command queue */

uv_mutex_t cmd_mutex;

uv_cond_t cmd_cond;

volatile unsigned queue_size;

struct aclk_database_cmdqueue cmd_queue;

int error;

int chart_updates;

int alert_updates;

time_t batch_created;

struct aclk_database_worker_config *next;