35 lines
687 B
C
35 lines
687 B
C
|
#include <MESA/Maat_rule.h>
|
||
|
|
#include <librdkafka/rdkafka.h>
|
||
|
|
#include "kni_entry.h"
|
||
|
|
|
||
|
|
|
||
|
|
struct kni_log
|
||
|
|
{
|
||
|
|
const struct streaminfo *stream;
|
||
|
|
const Maat_rule_t*result;
|
||
|
|
size_t result_num;
|
||
|
|
};
|
||
|
|
|
||
|
|
struct kni_logger
|
||
|
|
{
|
||
|
|
char local_ip_str[INET6_ADDRSTRLEN];
|
||
|
|
int entry_id;
|
||
|
|
|
||
|
|
unsigned int local_ip_nr;
|
||
|
|
rd_kafka_t *kafka_handle;
|
||
|
|
rd_kafka_topic_t* kafka_topic;
|
||
|
|
char brokerlist[KNI_CONF_MAXLEN];
|
||
|
|
const char* topic_name;
|
||
|
|
|
||
|
|
unsigned long long send_cnt;
|
||
|
|
char local_log_path[KNI_CONF_MAXLEN];
|
||
|
|
};
|
||
|
|
|
||
|
|
|
||
|
|
struct kni_logger* kni_sendlog_init(const char* profile, const char* section, void* local_logger);
|
||
|
|
//return 0 if SUCCESS, otherwise return -1
|
||
|
|
int kni_send_log(const struct kni_log* log_msg);
|
||
|
|
|
||
|
|
|
||
|
|
|