Searched defs:rd_kafka_queue_t (Results 1 – 4 of 4) sorted by relevance
1081 ) -> *mut rd_kafka_queue_t; in rd_kafka_queue_get_partition()1087 pub fn rd_kafka_queue_forward(src: *mut rd_kafka_queue_t, dst: *mut rd_kafka_queue_t); in rd_kafka_queue_forward()1092 rkqu: *mut rd_kafka_queue_t, in rd_kafka_set_log_queue()1100 rkqu: *mut rd_kafka_queue_t, in rd_kafka_queue_io_event_enable()1108 rkqu: *mut rd_kafka_queue_t, in rd_kafka_queue_cb_event_enable()1122 rkqu: *mut rd_kafka_queue_t, in rd_kafka_consume_start_queue()1165 rkqu: *mut rd_kafka_queue_t, in rd_kafka_consume_queue()1171 rkqu: *mut rd_kafka_queue_t, in rd_kafka_consume_batch_queue()1179 rkqu: *mut rd_kafka_queue_t, in rd_kafka_consume_callback_queue()1254 rkqu: *mut rd_kafka_queue_t, in rd_kafka_commit_queue()[all …]
235 typedef struct rd_kafka_queue_s rd_kafka_queue_t; typedef
245 typedef struct rd_kafka_queue_s rd_kafka_queue_t; typedef