Home
last modified time | relevance | path

Searched refs:sd_schema (Results 1 – 6 of 6) sorted by relevance

/dports/net-mgmt/pmacct/pmacct-1.7.5/src/bmp/
H A Dbmp.c417 …bmp_daemon_msglog_kafka_host.sd_schema[BMP_MSG_ROUTE_MONITOR] = compose_avro_schema_registry_name_… in skinny_bmp_daemon()
422 …bmp_daemon_msglog_kafka_host.sd_schema[BMP_MSG_STATS] = compose_avro_schema_registry_name_2(config… in skinny_bmp_daemon()
427 …bmp_daemon_msglog_kafka_host.sd_schema[BMP_MSG_PEER_UP] = compose_avro_schema_registry_name_2(conf… in skinny_bmp_daemon()
432 …bmp_daemon_msglog_kafka_host.sd_schema[BMP_MSG_PEER_DOWN] = compose_avro_schema_registry_name_2(co… in skinny_bmp_daemon()
437 …bmp_daemon_msglog_kafka_host.sd_schema[BMP_MSG_INIT] = compose_avro_schema_registry_name_2(config.… in skinny_bmp_daemon()
442 …bmp_daemon_msglog_kafka_host.sd_schema[BMP_MSG_TERM] = compose_avro_schema_registry_name_2(config.… in skinny_bmp_daemon()
447 …bmp_daemon_msglog_kafka_host.sd_schema[BMP_MSG_TMP_RPAT] = compose_avro_schema_registry_name_2(con… in skinny_bmp_daemon()
452 …bmp_daemon_msglog_kafka_host.sd_schema[BMP_LOG_TYPE_LOGINIT] = compose_avro_schema_registry_name_2… in skinny_bmp_daemon()
457 …bmp_daemon_msglog_kafka_host.sd_schema[BMP_LOG_TYPE_LOGCLOSE] = compose_avro_schema_registry_name_… in skinny_bmp_daemon()
H A Dbmp_logdump.c286 if (kafka_host->sd_schema[log_type] == NULL) { in bmp_log_msg()
289 …else if (serdes_schema_serialize_avro(kafka_host->sd_schema[log_type], &p_avro_obj, &p_avro_local_… in bmp_log_msg()
1274 …bmp_dump_kafka_host.sd_schema[BMP_MSG_ROUTE_MONITOR] = compose_avro_schema_registry_name_2(config.… in bmp_handle_dump_event()
1279 …bmp_dump_kafka_host.sd_schema[BMP_MSG_STATS] = compose_avro_schema_registry_name_2(config.bmp_dump… in bmp_handle_dump_event()
1284 …bmp_dump_kafka_host.sd_schema[BMP_MSG_PEER_UP] = compose_avro_schema_registry_name_2(config.bmp_du… in bmp_handle_dump_event()
1289 …bmp_dump_kafka_host.sd_schema[BMP_MSG_PEER_DOWN] = compose_avro_schema_registry_name_2(config.bmp_… in bmp_handle_dump_event()
1294 …bmp_dump_kafka_host.sd_schema[BMP_MSG_INIT] = compose_avro_schema_registry_name_2(config.bmp_dump_… in bmp_handle_dump_event()
1299 …bmp_dump_kafka_host.sd_schema[BMP_MSG_TERM] = compose_avro_schema_registry_name_2(config.bmp_dump_… in bmp_handle_dump_event()
1304 …bmp_dump_kafka_host.sd_schema[BMP_LOG_TYPE_DUMPINIT] = compose_avro_schema_registry_name_2(config.… in bmp_handle_dump_event()
1309 …bmp_dump_kafka_host.sd_schema[BMP_LOG_TYPE_DUMPCLOSE] = compose_avro_schema_registry_name_2(config… in bmp_handle_dump_event()
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/
H A Dkafka_plugin.c445 …kafkap_kafka_host.sd_schema[AVRO_ACCT_DATA_SID] = compose_avro_schema_registry_name_2(p_kafka_get_… in kafka_cache_purge()
449 …kafkap_kafka_host.sd_schema[AVRO_ACCT_INIT_SID] = compose_avro_schema_registry_name_2(p_kafka_get_… in kafka_cache_purge()
453 …kafkap_kafka_host.sd_schema[AVRO_ACCT_CLOSE_SID] = compose_avro_schema_registry_name_2(p_kafka_get… in kafka_cache_purge()
522 …if (serdes_schema_serialize_avro(kafkap_kafka_host.sd_schema[AVRO_ACCT_INIT_SID], &p_avro_value, &… in kafka_cache_purge()
640 …if (serdes_schema_serialize_avro(kafkap_kafka_host.sd_schema[AVRO_ACCT_DATA_SID], &p_avro_value, &… in kafka_cache_purge()
848 …if (serdes_schema_serialize_avro(kafkap_kafka_host.sd_schema[AVRO_ACCT_CLOSE_SID], &p_avro_value, … in kafka_cache_purge()
H A Dkafka_common.h59 serdes_schema_t *sd_schema[MAX_AVRO_SCHEMA]; member
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/bgp/
H A Dbgp_logdump.c532 if (kafka_host->sd_schema[0] == NULL) { in bgp_peer_log_msg()
535 …else if (serdes_schema_serialize_avro(kafka_host->sd_schema[0], &p_avro_obj, &p_avro_local_buf, &p… in bgp_peer_log_msg()
786 …if (serdes_schema_serialize_avro(kafka_host->sd_schema[BGP_LOG_TYPE_LOGINIT], &p_avro_obj, &p_avro… in bgp_peer_log_init()
1001 …if (serdes_schema_serialize_avro(kafka_host->sd_schema[BGP_LOG_TYPE_LOGCLOSE], &p_avro_obj, &p_avr… in bgp_peer_log_close()
1351 …if (serdes_schema_serialize_avro(kafka_host->sd_schema[BGP_LOG_TYPE_DUMPINIT], &p_avro_obj, &p_avr… in bgp_peer_dump_init()
1566 …if (serdes_schema_serialize_avro(kafka_host->sd_schema[BGP_LOG_TYPE_DUMPCLOSE], &p_avro_obj, &p_av… in bgp_peer_dump_close()
1667 …bgp_table_dump_kafka_host.sd_schema[0] = compose_avro_schema_registry_name_2(config.bgp_table_dump… in bgp_handle_dump_event()
1672 …bgp_table_dump_kafka_host.sd_schema[BGP_LOG_TYPE_DUMPINIT] = compose_avro_schema_registry_name_2(c… in bgp_handle_dump_event()
1677 …bgp_table_dump_kafka_host.sd_schema[BGP_LOG_TYPE_DUMPCLOSE] = compose_avro_schema_registry_name_2(… in bgp_handle_dump_event()
H A Dbgp.c454 …bgp_daemon_msglog_kafka_host.sd_schema[0] = compose_avro_schema_registry_name_2(config.bgp_daemon_… in skinny_bgp_daemon_online()
458 …bgp_daemon_msglog_kafka_host.sd_schema[BGP_LOG_TYPE_LOGINIT] = compose_avro_schema_registry_name_2… in skinny_bgp_daemon_online()
462 …bgp_daemon_msglog_kafka_host.sd_schema[BGP_LOG_TYPE_LOGCLOSE] = compose_avro_schema_registry_name_… in skinny_bgp_daemon_online()