Searched refs:rd_kafka_admin_result_new (Results 1 – 3 of 3) sorted by relevance
328 static rd_kafka_op_t *rd_kafka_admin_result_new (rd_kafka_op_t *rko_req) { in rd_kafka_admin_result_new() function442 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_admin_result_fail()1284 rko_result = rd_kafka_admin_result_new(rko_fanout); in rd_kafka_admin_fanout_worker()1673 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_CreateTopicsResponse_parse()1904 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_DeleteTopicsResponse_parse()2187 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_CreatePartitionsResponse_parse()2758 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_AlterConfigsResponse_parse()2954 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_DescribeConfigsResponse_parse()3352 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_DeleteRecordsResponse_parse()3658 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_DeleteGroupsResponse_parse()[all …]
325 static rd_kafka_op_t *rd_kafka_admin_result_new (rd_kafka_op_t *rko_req) {433 rko_result = rd_kafka_admin_result_new(rko_req);1275 rko_result = rd_kafka_admin_result_new(rko_fanout);1664 rko_result = rd_kafka_admin_result_new(rko_req);1895 rko_result = rd_kafka_admin_result_new(rko_req);2178 rko_result = rd_kafka_admin_result_new(rko_req);2749 rko_result = rd_kafka_admin_result_new(rko_req);2945 rko_result = rd_kafka_admin_result_new(rko_req);3316 rko_result = rd_kafka_admin_result_new(rko_req);3622 rko_result = rd_kafka_admin_result_new(rko_req);[all …]
257 static rd_kafka_op_t *rd_kafka_admin_result_new (const rd_kafka_op_t *rko_req) { in rd_kafka_admin_result_new() function327 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_admin_result_fail()1204 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_CreateTopicsResponse_parse()1435 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_DeleteTopicsResponse_parse()1717 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_CreatePartitionsResponse_parse()2282 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_AlterConfigsResponse_parse()2475 rko_result = rd_kafka_admin_result_new(rko_req); in rd_kafka_DescribeConfigsResponse_parse()