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

**/

​

#ifndef ZABBIX_DBSYNC_H

#define ZABBIX_DBSYNC_H

​

#include "dbconfig.h"

​

#include "zbxalgo.h"

#include "zbxdb.h"

​

/* no changes */

#define ZBX_DBSYNC_ROW_NONE 0

/*  a new object must be added to configuration cache */

#define ZBX_DBSYNC_ROW_ADD  1

/* a cached object must be updated in configuration cache */

#define ZBX_DBSYNC_ROW_UPDATE   2

/* a cached object must be removed from configuration cache */

#define ZBX_DBSYNC_ROW_REMOVE   3

​

#define ZBX_DBSYNC_UPDATE_HOSTS         __UINT64_C(0x0001)

#define ZBX_DBSYNC_UPDATE_ITEMS         __UINT64_C(0x0002)

#define ZBX_DBSYNC_UPDATE_FUNCTIONS     __UINT64_C(0x0004)

#define ZBX_DBSYNC_UPDATE_TRIGGERS      __UINT64_C(0x0008)

#define ZBX_DBSYNC_UPDATE_TRIGGER_DEPENDENCY    __UINT64_C(0x0010)

#define ZBX_DBSYNC_UPDATE_HOST_GROUPS       __UINT64_C(0x0020)

#define ZBX_DBSYNC_UPDATE_MAINTENANCE_GROUPS    __UINT64_C(0x0040)

#define ZBX_DBSYNC_UPDATE_MACROS        __UINT64_C(0x0080)

​

#define ZBX_DBSYNC_TRIGGER_ERROR    0x80

​

​

#define ZBX_DBSYNC_TYPE_DIFF        0

#define ZBX_DBSYNC_TYPE_CHANGELOG   1

​

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

 *                                                                            *

 * Purpose: applies necessary preprocessing before row is compared/used       *

 *                                                                            *

 * Parameter: row - [IN] the row to preprocess                                *

 *                                                                            *

 * Return value: the preprocessed row                                         *

 *                                                                            *

 * Comments: The row preprocessing can be used to expand user macros in       *

 *           some columns.                                                    *

 *                                                                            *

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

typedef char **(*zbx_dbsync_preproc_row_func_t)(zbx_dbsync_t *sync, char **row);

​

typedef struct

{

    /* a row tag, describing the changes (see ZBX_DBSYNC_ROW_* defines) */

    unsigned char   tag;

​

    /* the identifier of the object represented by the row */

    zbx_uint64_t    rowid;

​

    /* the column values, NULL if the tag is ZBX_DBSYNC_ROW_REMOVE */

    char        **row;

}

zbx_dbsync_row_t;

​

struct zbx_dbsync

{

    /* the synchronization mode (see ZBX_DBSYNC_* defines) */

    unsigned char           mode;

​

​

    unsigned char           type;

​

    /* the number of columns in diff */

    int             columns_num;

​

    /* the current row */

    int             row_index;

​

    /* the changed rows */

    zbx_vector_ptr_t        rows;

​

    /* the database result set for ZBX_DBSYNC_ALL mode */