Lines Matching refs:mcluster
246 *mcluster,
354 rd_kafka_mock_topic_auto_create (rd_kafka_mock_cluster_t *mcluster,
358 rd_kafka_mock_topic_find (const rd_kafka_mock_cluster_t *mcluster,
361 rd_kafka_mock_topic_find_by_kstr (const rd_kafka_mock_cluster_t *mcluster,
364 rd_kafka_mock_cluster_get_coord (rd_kafka_mock_cluster_t *mcluster,
394 rd_kafka_mock_cluster_ApiVersion_check (const rd_kafka_mock_cluster_t *mcluster, in rd_kafka_mock_cluster_ApiVersion_check() argument
397 return (ApiVersion >= mcluster->api_handlers[ApiKey].MinVersion && in rd_kafka_mock_cluster_ApiVersion_check()
398 ApiVersion <= mcluster->api_handlers[ApiKey].MaxVersion); in rd_kafka_mock_cluster_ApiVersion_check()
441 rd_kafka_mock_cgrp_find (rd_kafka_mock_cluster_t *mcluster,
444 rd_kafka_mock_cgrp_get (rd_kafka_mock_cluster_t *mcluster,
447 void rd_kafka_mock_cgrps_connection_closed (rd_kafka_mock_cluster_t *mcluster,