Searched refs:sd_schema (Results 1 – 6 of 6) sorted by relevance
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/bmp/ |
H A D | bmp.c | 417 …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 D | bmp_logdump.c | 286 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 D | kafka_plugin.c | 445 …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 D | kafka_common.h | 59 serdes_schema_t *sd_schema[MAX_AVRO_SCHEMA]; member
|
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/bgp/ |
H A D | bgp_logdump.c | 532 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 D | bgp.c | 454 …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()
|