One Hat Cyber Team

Your IP: 216.73.216.23
Server IP: 178.33.27.10
Server: Linux cpanel.dev-unit.com 3.10.0-1160.108.1.el7.x86_64 #1 SMP Thu Jan 25 16:17:31 UTC 2024 x86_64
Server Software: Apache/2.4.57 (Unix) OpenSSL/1.0.2k-fips
PHP Version: 8.2.11
Buat File | Buat Folder

Dir : ~/usr/local/src/netdata/collectors/plugins.d/

View File Name : pluginsd_functions.h

// 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 {
    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