Searched refs:rd_kafka_DeleteTopic_new (Results 1 – 18 of 18) sorted by relevance
306 del_topics[i] = rd_kafka_DeleteTopic_new(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteTopics()557 topic = rd_kafka_DeleteTopic_new("test"); in do_test_unclean_destroy()
328 del_topics[i] = rd_kafka_DeleteTopic_new(topic); in do_test_DeleteTopics()
4054 delt[0] = rd_kafka_DeleteTopic_new(topicname); in test_admin_delete_topic()5194 del_topics[i] = rd_kafka_DeleteTopic_new(topics[i]); in test_DeleteTopics_simple()
312 del_topics[i] = rd_kafka_DeleteTopic_new(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteTopics()923 topic = rd_kafka_DeleteTopic_new("test"); in do_test_unclean_destroy()
338 del_topics[i] = rd_kafka_DeleteTopic_new(topic); in do_test_DeleteTopics()
4548 delt[0] = rd_kafka_DeleteTopic_new(topicname); in test_admin_delete_topic()5788 del_topics[i] = rd_kafka_DeleteTopic_new(topics[i]); in test_DeleteTopics_simple()
4506 delt[0] = rd_kafka_DeleteTopic_new(topicname); in test_admin_delete_topic()5746 del_topics[i] = rd_kafka_DeleteTopic_new(topics[i]); in test_DeleteTopics_simple()
1352 rd_kafka_DeleteTopic_t *rd_kafka_DeleteTopic_new (const char *topic) { in rd_kafka_DeleteTopic_new() function1394 return rd_kafka_DeleteTopic_new(src->topic); in rd_kafka_DeleteTopic_copy()
5878 rd_kafka_DeleteTopic_new (const char *topic);
117 NativeDeleteTopic::from_ptr(rdsys::rd_kafka_DeleteTopic_new(tn_c.as_ptr())).unwrap() in delete_topics_inner()
527 c_objs[i] = rd_kafka_DeleteTopic_new( in Admin_delete_topics()
1822 rd_kafka_DeleteTopic_t *rd_kafka_DeleteTopic_new (const char *topic) { in rd_kafka_DeleteTopic_new() function1864 return rd_kafka_DeleteTopic_new(src->topic); in rd_kafka_DeleteTopic_copy()
6466 rd_kafka_DeleteTopic_new (const char *topic);
1813 rd_kafka_DeleteTopic_t *rd_kafka_DeleteTopic_new (const char *topic) {1855 return rd_kafka_DeleteTopic_new(src->topic);
6460 rd_kafka_DeleteTopic_new (const char *topic);
1917 pub fn rd_kafka_DeleteTopic_new(topic: *const c_char) -> *mut rd_kafka_DeleteTopic_t; in rd_kafka_DeleteTopic_new() function