Skip to content

Commit

Permalink
feat: alert pid (#709)
Browse files Browse the repository at this point in the history
  • Loading branch information
masaimu authored Oct 25, 2023
1 parent 3203bc7 commit 48f9823
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public class AbstractUniformInspectRunningRule {
LoggerFactory.getLogger(AbstractUniformInspectRunningRule.class);

ThreadPoolExecutor ruleRunner = new ThreadPoolExecutor(20, 100, 10, TimeUnit.SECONDS,
new ArrayBlockingQueue<>(1000), r -> new Thread(r, "RuleRunner"));
new ArrayBlockingQueue<>(2000), r -> new Thread(r, "RuleRunner"));

@Autowired
private NullValueTracker nullValueTracker;
Expand Down Expand Up @@ -155,6 +155,8 @@ public EventInfo runRule(InspectConfig inspectConfig, long period,
ComputeInfo computeInfo = ComputeInfo.getComputeInfo(inspectConfig, period);
List<TriggerResult> triggerResults = new CopyOnWriteArrayList<>();
CountDownLatch latch = new CountDownLatch(parallelSize);
logger.info("ALERT_CONCURRENT_MONITOR,size={},rule={}", parallelSize,
inspectConfig.getUniqueId());
for (DataResult dataResult : dataResultList) {
ruleRunner.execute(() -> {
try {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,9 @@ public enum AlertTemplateField {
ALERT_TRIGGER_CONDITION("ALERT_TRIGGER_CONDITION", "告警触发条件", "string"), //
SOURCE_TYPE("SOURCE_TYPE", "告警来源类型", "string"), //
LOG_CONTENT("LOG_CONTENT", "告警来源日志采样内容", "string"), //
TENANT_NAME("TENANT_NAME", "租户名", "string"), //
WORKSPACE_NAME("WORKSPACE_NAME", "工作空间名", "string"), //
PID("PID", "pid", "string"), //

;

Expand Down

0 comments on commit 48f9823

Please sign in to comment.