FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
netdata/database/sqlite/sqlite_aclk_chart.h at master · sourcecodes2/netdata · GitHub
sourcecodes2
/
netdata
Public
forked from
netdata/netdata
Notifications
You must be signed in to change notification settings
Fork
0
Star
0
Code
Pull requests
0
Actions
Projects
Security and quality
0
Insights
Additional navigation options
Code
Pull requests
Actions
Projects
Security and quality
Insights
Expand file tree
Breadcrumbs
netdata
/
database
/
sqlite
/
sqlite_aclk_chart.h
Copy path
More file actions
More file actions
Latest commit
History
History
History
37 lines (31 loc) · 1.87 KB
Breadcrumbs
netdata
/
database
/
sqlite
/
sqlite_aclk_chart.h
Copy path
File metadata and controls
37 lines (31 loc) · 1.87 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
// SPDX-License-Identifier: GPL-3.0-or-later
#ifndef
NETDATA_SQLITE_ACLK_CHART_H
#define
NETDATA_SQLITE_ACLK_CHART_H
typedef
enum
payload_type
{
ACLK_PAYLOAD_CHART
,
ACLK_PAYLOAD_DIMENSION
,
ACLK_PAYLOAD_DIMENSION_ROTATED
}
ACLK_PAYLOAD_TYPE
;
extern
sqlite3
*
db_meta
;
#ifndef
RRDSET_MINIMUM_LIVE_COUNT
#define
RRDSET_MINIMUM_LIVE_COUNT
3
#endif
extern
int
queue_chart_to_aclk
(
RRDSET
*
st
);
extern
int
queue_dimension_to_aclk
(
RRDDIM
*
rd
);
extern
void
sql_create_aclk_table
(
RRDHOST
*
host
,
uuid_t
*
host_uuid
,
uuid_t
*
node_id
);
extern
int
sql_queue_alarm_to_aclk
(
RRDHOST
*
host
,
ALARM_ENTRY
*
ae
);
int
aclk_add_chart_event
(
struct
aclk_database_worker_config
*
wc
,
struct
aclk_database_cmd
cmd
);
int
aclk_add_dimension_event
(
struct
aclk_database_worker_config
*
wc
,
struct
aclk_database_cmd
cmd
);
int
aclk_send_chart_config
(
struct
aclk_database_worker_config
*
wc
,
struct
aclk_database_cmd
cmd
);
void
aclk_ack_chart_sequence_id
(
char
*
node_id
,
uint64_t
last_sequence_id
);
void
aclk_get_chart_config
(
char
*
*
hash_id_list
);
void
aclk_send_chart_event
(
struct
aclk_database_worker_config
*
wc
,
struct
aclk_database_cmd
cmd
);
void
aclk_start_streaming
(
char
*
node_id
,
uint64_t
seq_id
,
time_t
created_at
,
uint64_t
batch_id
);
void
sql_chart_deduplicate
(
struct
aclk_database_worker_config
*
wc
,
struct
aclk_database_cmd
cmd
);
void
sql_check_rotation_state
(
struct
aclk_database_worker_config
*
wc
,
struct
aclk_database_cmd
cmd
);
void
sql_get_last_chart_sequence
(
struct
aclk_database_worker_config
*
wc
);
void
aclk_receive_chart_reset
(
struct
aclk_database_worker_config
*
wc
,
struct
aclk_database_cmd
cmd
);
void
aclk_receive_chart_ack
(
struct
aclk_database_worker_config
*
wc
,
struct
aclk_database_cmd
cmd
);
void
aclk_process_dimension_deletion
(
struct
aclk_database_worker_config
*
wc
,
struct
aclk_database_cmd
cmd
);
uint32_t
sql_get_pending_count
(
struct
aclk_database_worker_config
*
wc
);
#endif
//NETDATA_SQLITE_ACLK_CHART_H
Back
|
FazBrowse Home
|
New Git URL