summaryrefslogtreecommitdiffstats
path: root/aclk/schema-wrappers/chart_stream.h
blob: 9048668683453b9f8a237c30bf269c4f5012221e (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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
// SPDX-License-Identifier: GPL-3.0-or-later

#ifndef ACLK_SCHEMA_WRAPPER_CHART_STREAM_H
#define ACLK_SCHEMA_WRAPPER_CHART_STREAM_H

#ifdef __cplusplus
extern "C" {
#endif

#include "database/rrd.h"

typedef struct {
    char* claim_id;
    char* node_id;

    uint64_t seq_id;
    uint64_t batch_id;

    struct timeval seq_id_created_at;
} stream_charts_and_dims_t;

stream_charts_and_dims_t parse_stream_charts_and_dims(const char *data, size_t len);

typedef struct {
    char* claim_id;
    char* node_id;

    uint64_t last_seq_id;
} chart_and_dim_ack_t;

chart_and_dim_ack_t parse_chart_and_dimensions_ack(const char *data, size_t len);

enum chart_reset_reason {
    DB_EMPTY,
    SEQ_ID_NOT_EXISTS,
    TIMESTAMP_MISMATCH
};

typedef struct {
    char *claim_id;
    char *node_id;

    enum chart_reset_reason reason;
} chart_reset_t;

char *generate_reset_chart_messages(size_t *len, const chart_reset_t reset);

struct aclk_message_position {
    uint64_t sequence_id;
    struct timeval seq_id_creation_time;
    uint64_t previous_sequence_id;
};

struct chart_instance_updated {
    const char *id;
    const char *claim_id;
    const char *node_id;
    const char *name;

    DICTIONARY *chart_labels;

    RRD_MEMORY_MODE memory_mode;

    uint32_t update_every;
    const char * config_hash;

    struct aclk_message_position position;
};

void chart_instance_updated_destroy(struct chart_instance_updated *instance);

struct chart_dimension_updated {
    const char *id;
    const char *chart_id;
    const char *node_id;
    const char *claim_id;
    const char *name;
    struct timeval created_at;
    struct timeval last_timestamp;
    struct aclk_message_position position;
};

typedef struct {
    struct chart_instance_updated *charts;
    uint16_t chart_count;

    struct chart_dimension_updated *dims;
    uint16_t dim_count;

    uint64_t batch_id;
} charts_and_dims_updated_t;

struct interval_duration {
    uint32_t update_every;
    uint32_t retention;
};

struct retention_updated {
    char *claim_id;
    char *node_id;

    RRD_MEMORY_MODE memory_mode;

    struct interval_duration *interval_durations;
    int interval_duration_count;

    struct timeval rotation_timestamp;
};

char *generate_charts_and_dimensions_updated(size_t *len, char **payloads, size_t *payload_sizes, int *is_dim, struct aclk_message_position *new_positions, uint64_t batch_id);
char *generate_charts_updated(size_t *len, char **payloads, size_t *payload_sizes, struct aclk_message_position *new_positions);
char *generate_chart_instance_updated(size_t *len, const struct chart_instance_updated *update);
char *generate_chart_dimensions_updated(size_t *len, char **payloads, size_t *payload_sizes, struct aclk_message_position *new_positions);
char *generate_chart_dimension_updated(size_t *len, const struct chart_dimension_updated *dim);
char *generate_retention_updated(size_t *len, struct retention_updated *data);

#ifdef __cplusplus
}
#endif

#endif /* ACLK_SCHEMA_WRAPPER_CHART_STREAM_H */