blob: ad47dc23aab6e9ceceb827cc72ae72775906846d (
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
|
// SPDX-License-Identifier: GPL-3.0-or-later
#ifndef NETDATA_PLUGINSD_FUNCTIONS_H
#define NETDATA_PLUGINSD_FUNCTIONS_H
#include "pluginsd_internals.h"
struct inflight_function {
nd_uuid_t transaction;
int code;
int timeout_s;
STRING *function;
BUFFER *payload;
HTTP_ACCESS access;
const char *source;
BUFFER *result_body_wb;
usec_t *stop_monotonic_ut; // pointer to caller data
usec_t started_monotonic_ut;
usec_t sent_monotonic_ut;
PARSER *parser;
bool sent_successfully;
struct {
rrd_function_result_callback_t cb;
void *data;
} result;
struct {
rrd_function_progress_cb_t cb;
void *data;
} progress;
};
PARSER_RC pluginsd_function(char **words, size_t num_words, PARSER *parser);
PARSER_RC pluginsd_function_result_begin(char **words, size_t num_words, PARSER *parser);
PARSER_RC pluginsd_function_progress(char **words, size_t num_words, PARSER *parser);
void pluginsd_inflight_functions_init(PARSER *parser);
void pluginsd_inflight_functions_cleanup(PARSER *parser);
void pluginsd_inflight_functions_garbage_collect(PARSER *parser, usec_t now_ut);
int pluginsd_function_execute_cb(struct rrd_function_execute *rfe, void *data);
#endif //NETDATA_PLUGINSD_FUNCTIONS_H
|
