Zabbix

/*

** Copyright (C) 2001-2025 Zabbix SIA

**

** This program is free software: you can redistribute it and/or modify it under the terms of

** the GNU Affero General Public License as published by the Free Software Foundation, version 3.

**

** This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;

** without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

** See the GNU Affero General Public License for more details.

**

** You should have received a copy of the GNU Affero General Public License along with this program.

** If not, see <https://www.gnu.org/licenses/>.

**/

​

#include "zbxhistory.h"

#include "history.h"

​

#include "zbxalgo.h"

#include "zbxdb.h"

#include "zbxjson.h"

#include "zbxstr.h"

#include "zbxnum.h"

#include "zbxtime.h"

#include "zbxvariant.h"

#include "zbx_dbversion_constants.h"

​

#ifdef HAVE_LIBCURL

​

#include "zbxcurl.h"

#include "zbxcacheconfig.h"

​

#define     ZBX_HISTORY_STORAGE_DOWN    10000 /* Timeout in milliseconds */

​

#define     ZBX_IDX_JSON_ALLOCATE       256

#define     ZBX_JSON_ALLOCATE       2048

​

const char  *value_type_str[] = {"dbl", "str", "log", "uint", "text"};

​

static zbx_uint32_t ZBX_ELASTIC_SVERSION = ZBX_DBVERSION_UNDEFINED;

​

typedef struct

{

    char    *base_url;

    char    *post_url;

    char    *buf;

    CURL    *handle;

}

zbx_elastic_data_t;

​

typedef struct

{

    unsigned char       initialized;

    zbx_vector_ptr_t    ifaces;

​

    CURLM           *handle;

}

zbx_elastic_writer_t;

​

static zbx_elastic_writer_t writer;

​

typedef struct

{

    char    *data;