Searched defs:kafka_host (Results 1 – 10 of 10) sorted by relevance
77 void p_kafka_unset_topic(struct p_kafka_host *kafka_host) in p_kafka_unset_topic()117 rd_kafka_t *p_kafka_get_handler(struct p_kafka_host *kafka_host) in p_kafka_get_handler()124 char *p_kafka_get_broker(struct p_kafka_host *kafka_host) in p_kafka_get_broker()131 char *p_kafka_get_topic(struct p_kafka_host *kafka_host) in p_kafka_get_topic()139 void p_kafka_init_topic_rr(struct p_kafka_host *kafka_host) in p_kafka_init_topic_rr()149 int p_kafka_get_topic_rr(struct p_kafka_host *kafka_host) in p_kafka_get_topic_rr()183 int p_kafka_get_content_type(struct p_kafka_host *kafka_host) in p_kafka_get_content_type()199 int p_kafka_get_partition(struct p_kafka_host *kafka_host) in p_kafka_get_partition()219 char *p_kafka_get_key(struct p_kafka_host *kafka_host) in p_kafka_get_key()401 int p_kafka_connect_to_produce(struct p_kafka_host *kafka_host) in p_kafka_connect_to_produce()[all …]
2989 struct p_kafka_host *kafka_host = kh; in NF_init_kafka_host() local
2651 struct p_kafka_host *kafka_host = kh; in SF_init_kafka_host() local
50 void *kafka_host; member
529 struct p_kafka_host *kafka_host = (struct p_kafka_host *) peer->log->kafka_host; in bgp_peer_log_msg() local784 struct p_kafka_host *kafka_host = (struct p_kafka_host *) peer->log->kafka_host; in bgp_peer_log_init() local999 struct p_kafka_host *kafka_host = (struct p_kafka_host *) peer->log->kafka_host; in bgp_peer_log_close() local1349 struct p_kafka_host *kafka_host = (struct p_kafka_host *) peer->log->kafka_host; in bgp_peer_dump_init() local1564 struct p_kafka_host *kafka_host = (struct p_kafka_host *) peer->log->kafka_host; in bgp_peer_dump_close() local
230 struct p_kafka_host *kafka_host = kh; in telemetry_init_kafka_host() local
309 struct p_kafka_host *kafka_host = h; in telemetry_decode_producer_peer() local
65 struct p_kafka_host kafka_host; /* Emitting to Kafka: librdkafka structs */ member
470 struct p_kafka_host *kafka_host = &pool->kafka_host; in Tee_kafka_send() local654 void Tee_init_kafka_host(struct p_kafka_host *kafka_host, char *kafka_broker, char *kafka_topic, u_… in Tee_init_kafka_host()
284 struct p_kafka_host *kafka_host = (struct p_kafka_host *) peer->log->kafka_host; in bmp_log_msg() local