blob: 6dc323bddc104a68c6fbb9f71b9603d9a499fc2b (
plain)
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
// SPDX-License-Identifier: GPL-3.0-or-later
#ifndef NETDATA_STREAM_PATH_H
#define NETDATA_STREAM_PATH_H
#include "stream-capabilities.h"
#define STREAM_PATH_JSON_MEMBER "streaming_path"
typedef enum __attribute__((packed)) {
STREAM_PATH_FLAG_NONE = 0,
STREAM_PATH_FLAG_ACLK = (1 << 0),
} STREAM_PATH_FLAGS;
typedef struct stream_path {
STRING *hostname; // the hostname of the agent
ND_UUID host_id; // the machine guid of the agent
ND_UUID node_id; // the cloud node id of the agent
ND_UUID claim_id; // the cloud claim id of the agent
time_t since; // the timestamp of the last update
time_t first_time_t; // the oldest timestamp in the db
int16_t hops; // -1 = stale node, 0 = localhost, >0 the hops count
STREAM_PATH_FLAGS flags; // ACLK or NONE for the moment
STREAM_CAPABILITIES capabilities; // streaming connection capabilities
uint32_t start_time; // median time in ms the agent needs to start
uint32_t shutdown_time; // median time in ms the agent needs to shutdown
} STREAM_PATH;
typedef struct rrdhost_stream_path {
SPINLOCK spinlock;
uint16_t size;
uint16_t used;
STREAM_PATH *array;
} RRDHOST_STREAM_PATH;
struct rrdhost;
void stream_path_send_to_parent(struct rrdhost *host);
void stream_path_send_to_child(struct rrdhost *host);
void rrdhost_stream_path_to_json(BUFFER *wb, struct rrdhost *host, const char *key, bool add_version);
void rrdhost_stream_path_clear(struct rrdhost *host, bool destroy);
void stream_path_retention_updated(struct rrdhost *host);
void stream_path_node_id_updated(struct rrdhost *host);
void stream_path_child_disconnected(struct rrdhost *host);
void stream_path_parent_disconnected(struct rrdhost *host);
STREAM_PATH rrdhost_stream_path_fetch(struct rrdhost *host);
bool stream_path_set_from_json(struct rrdhost *host, const char *json, bool from_parent);
#endif //NETDATA_STREAM_PATH_H
|
