milvus/internal/util
yihao.dai a5a83a0904
fix: Fix consume blocked due to too many consumers (#38455)
This PR limits the maximum number of consumers per pchannel to 10 for
each QueryNode and DataNode.

issue: https://github.com/milvus-io/milvus/issues/37630

---------

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2025-01-15 21:37:01 +08:00
..
analyzecgowrapper enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
bloomfilter enhance: Use internal json(sonic) to replace std json lib (#37708) 2024-11-18 10:46:31 +08:00
cgo fix: add future stateful lock (#36332) 2024-09-18 20:15:11 +08:00
cgoconverter enhance: move the cgo code in the pkg dir to interal dir (#30261) 2024-01-25 15:15:01 +08:00
clustering feat: Support Int8Vector in go (#38990) 2025-01-14 20:43:06 +08:00
componentutil enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
ctokenizer enhance: rename tokenizer to analyzer and check analyzer params (#37478) 2024-11-10 16:12:26 +08:00
dependency feat: management WebUI homepage (#36822) 2024-10-23 11:29:28 +08:00
exprutil enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
flowgraph enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
function fix: sparse inc mast less than uint32 max (#38250) 2024-12-06 15:14:41 +08:00
funcutil enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
grpcclient enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
hookutil fix: Add version to the proxy cache to resolve concurrency issues (#38067) 2024-12-04 18:06:39 +08:00
idalloc enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
importutilv2 enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
indexcgowrapper feat: Support Int8Vector in go (#38990) 2025-01-14 20:43:06 +08:00
indexparamcheck feat: Support Int8Vector in go (#38990) 2025-01-14 20:43:06 +08:00
initcore enhance: GCS native support (GCS implemented using Google Cloud Storage libraries) (#36214) 2024-09-30 13:23:32 +08:00
metrics enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
mock enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
nullutil enhance: support default value in import (#36700) 2024-10-17 12:05:24 +08:00
pipeline fix: Fix consume blocked due to too many consumers (#38455) 2025-01-15 21:37:01 +08:00
proxyutil enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
quota enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
ratelimitutil enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
reduce fix: iterator cursor progress too fast(#36179) (#36180) 2024-09-24 11:45:13 +08:00
searchutil enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
segcore enhance: Add try-catch and return CStatus for NewCollection (#39279) 2025-01-15 19:17:01 +08:00
segmentutil enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
sessionutil fix: Add scalar index engine version for compatibility (#39204) 2025-01-15 12:25:00 +08:00
streamingutil enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
streamrpc enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00
testutil feat: Support Int8Vector in go (#38990) 2025-01-14 20:43:06 +08:00
tokenizerapi feat: Tokenizer support build with params and clone for concurrency (#37048) 2024-11-06 17:48:24 +08:00
tsoutil enhance: move rocksmq from internal to pkg module (#33881) 2024-06-25 21:18:15 +08:00
typeutil feat: Support Int8Vector in go (#38990) 2025-01-14 20:43:06 +08:00
vecindexmgr feat: Support Int8Vector in go (#38990) 2025-01-14 20:43:06 +08:00
wrappers enhance: make new go package to manage proto (#39114) 2025-01-10 10:49:01 +08:00