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 "history_compress.h"

​

#if defined(HAVE_POSTGRESQL)

​

#include "zbxdbhigh.h"

#include "zbxstr.h"

#include "zbxdb.h"

​

#define ZBX_TS_UNIX_NOW     "zbx_ts_unix_now"

#define ZBX_TS_UNIX_NOW_CREATE  "create or replace function "ZBX_TS_UNIX_NOW"() returns integer language sql" \

                " stable as $$ select extract(epoch from now())::integer $$"

​

#define COMPRESSION_TOLERANCE       (SEC_PER_HOUR * 2)

#define COMPRESSION_POLICY_REMOVE   "remove_compression_policy"

#define COMPRESSION_POLICY_ADD      "add_compression_policy"

​

/* Compression policy: chunks containing data older than provided data are compressed. */

#define POLICY_COMPRESS_AFTER       0

/* Compression policy: chunks with creation time older than this cut-off point are compressed. */

#define POLICY_COMPRESS_CREATED_BEFORE  1

​

typedef struct

{

    const char  *name;

    const char  *segmentby;

    const char  *orderby;

    int     compression_policy;

} zbx_history_table_compression_options_t;

​

static zbx_history_table_compression_options_t  compression_tables[] = {

    {"history",     "itemid",   "clock,ns", POLICY_COMPRESS_AFTER},

    {"history_uint",    "itemid",   "clock,ns", POLICY_COMPRESS_AFTER},

    {"history_str",     "itemid",   "clock,ns", POLICY_COMPRESS_AFTER},

    {"history_text",    "itemid",   "clock,ns", POLICY_COMPRESS_AFTER},

    {"history_log",     "itemid",   "clock,ns", POLICY_COMPRESS_AFTER},

    {"history_bin",     "itemid",   "clock,ns", POLICY_COMPRESS_AFTER},

    {"trends",      "itemid",   "clock",    POLICY_COMPRESS_AFTER},

    {"trends_uint",     "itemid",   "clock",    POLICY_COMPRESS_AFTER},

    /* Since auditlog table uses CUID from auditid field to partition table into chunks we need to use different */

    /* compression policy due to internal TimescaleDB bug. */

    {"auditlog",        "auditid",  "clock",    POLICY_COMPRESS_CREATED_BEFORE}

};

​

static unsigned char    compression_status_cache = 0;

static int      compress_older_cache = 0;

​

/******************************************************************************

 *                                                                            *

 * Purpose: check that hypertables are segmented                              *