Searched defs:last_msgid (Results 1 – 19 of 19) sorted by relevance
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_msgbatch.h | 39 uint64_t last_msgid; /**< Last message to add to batch. member
|
| H A D | rdkafka_msg.h | 113 uint64_t last_msgid; /**< On retry this is set member
|
| H A D | rdkafka_msg.c | 818 uint64_t last_msgid, in rd_kafka_msgq_move_acked()
|
| H A D | rdkafka_request.c | 2998 uint64_t first_msgid, last_msgid; in rd_kafka_handle_idempotent_Produce_success() local
|
| H A D | rdkafka_broker.c | 2599 uint64_t last_msgid) { in rd_kafka_dr_implicit_ack()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_msgbatch.h | 41 uint64_t last_msgid; /**< Last message to add to batch. member
|
| H A D | rdkafka_msg.h | 115 uint64_t last_msgid; /**< On retry this is set member
|
| H A D | rdkafka_msg.c | 1027 uint64_t last_msgid, in rd_kafka_msgq_move_acked()
|
| H A D | rdkafka_request.c | 3212 uint64_t first_msgid, last_msgid; in rd_kafka_handle_idempotent_Produce_success() local
|
| H A D | rdkafka_broker.c | 2883 uint64_t last_msgid) { in rd_kafka_dr_implicit_ack()
|
| /dports/www/nginx-full/nchan-1.2.12/src/util/ |
| H A D | nchan_output_info.c | 54 …ngx_uint_t messages, ngx_uint_t subscribers, time_t last_seen, nchan_msg_id_t *last_msgid, ngx_str… in nchan_channel_info_buf()
|
| /dports/www/nginx-full/nchan-1.2.12/src/store/redis/ |
| H A D | store-private.h | 49 nchan_msg_id_t last_msgid; member
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_msg.h | 115 uint64_t last_msgid; /**< On retry this is set member
|
| H A D | rdkafka_msg.c | 1027 uint64_t last_msgid, in rd_kafka_msgq_move_acked()
|
| H A D | rdkafka_request.c | 3207 uint64_t first_msgid, last_msgid; in rd_kafka_handle_idempotent_Produce_success() local
|
| H A D | rdkafka_broker.c | 2835 uint64_t last_msgid) { in rd_kafka_dr_implicit_ack()
|
| /dports/www/nginx-full/nchan-1.2.12/src/store/memory/ |
| H A D | ipc-handlers.c | 704 nchan_msg_id_t last_msgid; member
|
| /dports/www/nginx-full/nchan-1.2.12/src/ |
| H A D | nchan_types.h | 455 nchan_msg_id_t last_msgid; member
|
| /dports/astro/gpsd/gpsd-3.20/ |
| H A D | gpsd.h | 705 unsigned int last_msgid; /* last class/ID */ member
|