import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Test(dependsOnMethods = { "alertingUp" }, groups = { GROUP })
@RunAsClient
public void postGetDelete() throws Throwable {
    final String triggersPath = alertingPath + "/triggers";
    final String testTriggerId = "demo-itest-trigger";
    final String triggerPath = triggersPath + "/" + testTriggerId;

    /* ensure our test trigger is not created */
    testClient.newRequest().path(triggerPath).get().assertCode(404);

    /* create our test trigger */
    Trigger testTrigger = new Trigger(testTriggerId, "No-Metric");
    testClient.newRequest().path(triggersPath).postObject(testTrigger).assertCode(200);

    /* check that the trigger is created */
    testClient.newRequest()
            .path(triggerPath).get()
            .assertCode(200)
            .assertJson(json -> Assert.assertEquals(json.get("id").asText(), testTriggerId,
                    String.format("GET [%s] returned an unexpected object", triggerPath)));

    /* cleanup */
    testClient.newRequest().path(triggerPath).delete().assertCode(200);
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
private void addFullTrigger(String tenantId, FullTrigger fullTrigger) throws Exception {
    if (null == fullTrigger) {
        throw new IllegalArgumentException("FullTrigger must be not null");
    }
    if (fullTrigger.getTrigger() != null) {
        Trigger trigger = fullTrigger.getTrigger();
        trigger.setTenantId(tenantId);
        addTrigger(trigger);
        if (!isEmpty(fullTrigger.getDampenings())) {
            for (Dampening d : fullTrigger.getDampenings()) {
                d.setTenantId(tenantId);
                d.setTriggerId(trigger.getId());
                addDampening(d);
            }
        }
        if (!isEmpty(fullTrigger.getConditions())) {
            setAllConditions(tenantId, trigger.getId(), fullTrigger.getConditions());
        }
    }
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Test(dependsOnMethods = "updateTriggerToEnabled")
public void createTriggerNoId() {
    noIdTrigger.setId(null);

    ClientResponse<Trigger> response = client()
        .alerts()
        .triggers()
        .createTrigger(noIdTrigger);

    Assert.assertTrue(response.isSuccess());
    Assert.assertNotNull(response.getEntity());

    //Update ID to allow for simple comparison
    noIdTrigger.setId(response.getEntity().getId());

    Assert.assertEquals(response.getEntity(), noIdTrigger);
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Test
public void createFullTrigger() {
    LOG.info("Testing with FullTriggers == {}", fullTriggerId);

    AvailabilityCondition condition = new AvailabilityCondition(fullTriggerId, Mode.FIRING, "no-data-id", AvailabilityCondition.Operator.UP);
    Dampening dampening = Dampening.forRelaxedCount(BaseTest.HEADER_TENANT, fullTriggerId, Mode.FIRING, 1, 2);
    Trigger trigger = new Trigger(BaseTest.HEADER_TENANT, fullTriggerId, "trigger is up");
    FullTrigger fullTrigger = new FullTrigger(trigger, Arrays.asList(dampening), Arrays.asList(condition));

    ClientResponse<FullTrigger> response = client()
        .alerts()
        .triggers()
        .createFullTrigger(fullTrigger);

    Assert.assertTrue(response.isSuccess());
    Assert.assertNotNull(response.getEntity());
    Assert.assertEquals(response.getEntity(), fullTrigger);
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@DocPath(method = POST,
        path = "/",
        name = "Create a new trigger.",
        notes = "Returns created trigger.")
@DocParameters(value = {
        @DocParameter(required = true, body = true, type = Trigger.class,
                description = "Trigger definition to be created.")
})
@DocResponses(value = {
        @DocResponse(code = 200, message = "Success, Trigger Created.", response = Trigger.class),
        @DocResponse(code = 400, message = "Bad Request/Invalid Parameters.", response = ApiError.class),
        @DocResponse(code = 500, message = "Internal server error.", response = ApiError.class)
})
public void createTrigger(RoutingContext routing) {
    createTrigger(routing, false);
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@DocPath(method = PUT,
        path = "/groups/{groupId}",
        name = "Update an existing group trigger definition and its member definitions.")
@DocParameters(value = {
        @DocParameter(name = "groupId", required = true, path = true,
                description = "Group Trigger definition id to be updated."),
        @DocParameter(required = true, body = true, type = Trigger.class,
                description = "Updated group trigger definition.")
})
@DocResponses(value = {
        @DocResponse(code = 200, message = "Success, Group Trigger updated.", response = Trigger.class),
        @DocResponse(code = 400, message = "Bad Request/Invalid Parameters.", response = ApiError.class),
        @DocResponse(code = 404, message = "Trigger not found.", response = ApiError.class),
        @DocResponse(code = 500, message = "Internal server error.", response = ApiError.class)
})
public void updateGroupTrigger(RoutingContext routing) {
    updateTrigger(routing, true);
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
public Event(String tenantId, Trigger trigger, Dampening dampening, List<Set<ConditionEval>> evalSets) {
    this.tenantId = tenantId;
    this.trigger = trigger;
    this.dampening = dampening;
    this.evalSets = evalSets;
    this.eventType = EventType.EVENT.name();
    this.ctime = System.currentTimeMillis();

    this.id = trigger.getId() + "-" + this.ctime + "-" + UUID.randomUUID();
    this.dataSource = trigger.getSource();
    this.dataId = trigger.getId();
    this.context = trigger.getContext();
    if (!isEmpty(trigger.getEventCategory())) {
        this.category = trigger.getEventCategory();
    } else {
        this.category = (EventType.ALERT == trigger.getEventType()) ?
                EventCategory.ALERT.name() : EventCategory.TRIGGER.name();
    }
    if (!isEmpty(trigger.getEventText())) {
        this.text = trigger.getEventText();
    } else {
        this.text = isEmpty(trigger.getDescription()) ? trigger.getName() : trigger.getDescription();
    }
    this.tags = trigger.getTags();
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Ignore
@Test
public void listenDataFromKafkaTopic() throws Exception {
    Trigger kafkaTrigger = new Trigger("test-tenant","kafka-trigger-id", "kafka-trigger-name");
    kafkaTrigger.addContext("kafka.bootstrap.servers", "localhost:9092");
    kafkaTrigger.addContext("kafka.group.id", "kafka-trigger-group");
    kafkaTrigger.addContext("kafka.key.deserializer", StringDeserializer.class.getName());
    kafkaTrigger.addContext("kafka.value.deserializer", StringDeserializer.class.getName());
    kafkaTrigger.addContext("topic", "my-topic");

    KafkaQuery kafkaQuery = new KafkaQuery(null, kafkaTrigger);

    ExecutorService executor = Executors.newFixedThreadPool(1);
    executor.submit(kafkaQuery);

    int seconds = 100;
    for (int i = 0; i < seconds; i++) {
        System.out.println("Second: " + i);
        Thread.sleep(1000);
    }

    kafkaQuery.shutdown();
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
public static void checkTenantId(String tenantId, Object obj) {
    if (isEmpty(tenantId)) {
        return;
    }
    if (obj == null) {
        return;
    }
    if (obj instanceof Trigger) {
        Trigger trigger = (Trigger) obj;
        if (trigger.getTenantId() == null || !trigger.getTenantId().equals(tenantId)) {
            trigger.setTenantId(tenantId);
            if (trigger.getActions() != null) {
                for (TriggerAction triggerAction : trigger.getActions()) {
                    triggerAction.setTenantId(tenantId);
                }
            }
        }
    } else if (obj instanceof Dampening) {
        Dampening dampening = (Dampening) obj;
        if (dampening.getTenantId() == null || !dampening.getTenantId().equals(tenantId)) {
            dampening.setTenantId(tenantId);
        }
    }
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Ignore
@Test
public void listenEventFromKafkaTopic() throws Exception {
    Trigger kafkaTrigger = new Trigger("test-tenant","kafka-trigger-id", "kafka-trigger-name");
    kafkaTrigger.addContext("kafka.bootstrap.servers", "localhost:9092");
    kafkaTrigger.addContext("kafka.group.id", "kafka-trigger-group");
    kafkaTrigger.addContext("kafka.key.deserializer", StringDeserializer.class.getName());
    kafkaTrigger.addContext("kafka.value.deserializer", StringDeserializer.class.getName());
    kafkaTrigger.addContext("topic", "my-topic");
    kafkaTrigger.addContext("mapping", "origin:dataId,payload:text");

    KafkaQuery kafkaQuery = new KafkaQuery(null, kafkaTrigger);

    ExecutorService executor = Executors.newFixedThreadPool(1);
    executor.submit(kafkaQuery);

    int seconds = 100;
    for (int i = 0; i < seconds; i++) {
        System.out.println("Second: " + i);
        Thread.sleep(1000);
    }

    kafkaQuery.shutdown();
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Override
public void removeTrigger(String tenantId, String triggerId) throws Exception {
    if (isEmpty(tenantId)) {
        throw new IllegalArgumentException("TenantId must be not null");
    }
    if (isEmpty(triggerId)) {
        throw new IllegalArgumentException("TriggerId must be not null");
    }

    // fetch the trigger (or throw NotFoundException)
    Trigger doomedTrigger = getTrigger(tenantId, triggerId);
    if (doomedTrigger.isGroup()) {
        throw new IllegalArgumentException("Trigger [" + tenantId + "/" + triggerId + "] is a group trigger.");
    }

    removeTrigger(doomedTrigger);
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Override
public Collection<Trigger> getAllTriggersByTag(String name, String value) throws Exception {
    if (isEmpty(name)) {
        throw new IllegalArgumentException("name must be not null");
    }
    if (isEmpty(value)) {
        throw new IllegalArgumentException("value must be not null (use '*' for all");
    }
    StringBuilder query = new StringBuilder(
            "from org.hawkular.alerts.engine.impl.ispn.model.IspnTrigger where tags like '")
                    .append(name)
                    .append(TagsBridge.VALUE)
                    .append(value.equals("*") ? "%" : value)
                    .append("'");
    List<IspnTrigger> triggers = queryFactory.create(query.toString()).list();
    return triggers.stream().map(t -> t.getTrigger()).collect(Collectors.toList());
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Override
public Trigger orphanMemberTrigger(String tenantId, String memberId) throws Exception {
    if (isEmpty(tenantId)) {
        throw new IllegalArgumentException("TenantId must be not null");
    }
    if (isEmpty(memberId)) {
        throw new IllegalArgumentException("TriggerId must be not null");
    }

    // fetch the trigger (or throw NotFoundException)
    Trigger member = getTrigger(tenantId, memberId);
    if (!member.isMember()) {
        throw new IllegalArgumentException("Trigger is not a member trigger: [" + tenantId + "/" + memberId + "]");
    }
    if (member.isOrphan()) {
        throw new IllegalArgumentException("Trigger is already an orphan: [" + tenantId + "/" + memberId + "]");
    }

    member.setType(TriggerType.ORPHAN);

    return updateTrigger(member);
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Ignore
@Test
public void searchMetricsByResources() {
    // Case 4.2
    Trigger trigger = new Trigger("tenant", "gnochi-test-id", "Gnocchi Trigger");
    String resourceQuery = "{" +
            "\"like\":{" +
            "\"type\":\"c%\"" +
            "}" +
            "}";
    trigger.getContext().put("metric.resource.query", resourceQuery);
    new GnocchiQuery(trigger, null, null).run();
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Override
public ClientResponse<List<Trigger>> findTriggers(String triggerIds, String tags, Boolean thin) {
    Response serverResponse = null;

    try {
        serverResponse = restApi().findTriggers(triggerIds, tags, thin);
        JavaType javaType = collectionResolver().get(List.class, Trigger.class);

        return new DefaultClientResponse<>(javaType, serverResponse, ResponseCodes.GET_SUCCESS_200);
    } finally {
        if (serverResponse != null) {
            serverResponse.close();
        }
    }
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Test
public void groupTest() throws Exception {
    Trigger groupTrigger = new Trigger("groupTrigger0", "groupTrigger0");
    groupTrigger.setType(TriggerType.GROUP);
    definitions.addGroupTrigger("tenant0", groupTrigger);
    Condition fc = new AvailabilityCondition("group-trigger", Mode.FIRING, "avail", Operator.NOT_UP);
    definitions.setGroupConditions("tenant0", "groupTrigger0", Mode.FIRING, Collections.singleton(fc), null);
    definitions.addMemberTrigger("tenant0", "groupTrigger0", "member0", "member0", "member0", null, null,
            Collections.singletonMap("avail", "avail0"));
    assertEquals(1, definitions.getMemberTriggers("tenant0", "groupTrigger0", true).size());
    definitions.removeGroupTrigger("tenant0", "groupTrigger0", false, false);
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Override
public ClientResponse<Trigger> createGroupTrigger(Trigger groupTrigger) {
    Response serverResponse = null;

    try {
        serverResponse = restApi().createGroupTrigger(groupTrigger);
        JavaType javaType = simpleResolver().get(Trigger.class);

        return new DefaultClientResponse<>(javaType, serverResponse, ResponseCodes.GET_SUCCESS_200);
    } finally {
        if (serverResponse != null) {
            serverResponse.close();
        }
    }
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Test
public void multipleConditionsOnSameDataIdWithAnyMatching() {
    Trigger t1 = new Trigger("tenant", "trigger-1", "Multiple Conditions in ANY");
    t1.setFiringMatch(Match.ANY);
    t1.setEventType(EventType.EVENT);
    t1.setEnabled(true);
    ThresholdCondition t1c1 = new ThresholdCondition("tenant", "trigger-1", 2, 1,
            "HeapUsed",
            ThresholdCondition.Operator.LT, 10.0);
    ThresholdCondition t1c2 = new ThresholdCondition("tenant", "trigger-1", 2, 2,
            "HeapUsed",
            ThresholdCondition.Operator.GT, 20.0);

    // Default dampening

    rulesEngine.addFacts(Arrays.asList(t1, t1c1, t1c2));

    datums.add(Data.forNumeric("tenant", "HeapUsed", 1000, 9.0));
    datums.add(Data.forNumeric("tenant", "HeapUsed", 2000, 11.0));
    datums.add(Data.forNumeric("tenant", "HeapUsed", 3000, 21.0));
    datums.add(Data.forNumeric("tenant", "HeapUsed", 4000, 19.0));

    rulesEngine.addData(datums);

    rulesEngine.fire();

    assertEquals(2, outputEvents.size());
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Test
public void externalDataTest() {
    Trigger t1 = new Trigger("tenant", "trigger-1", "External-Metrics");
    ExternalCondition t1c1 = new ExternalCondition("tenant", "trigger-1", Mode.FIRING, 1, 1,
            "ExternalData-01", "HawkularMetrics", "metric:5:avg(foo > 100.5)");

    datums.add(Data.forString("tenant", "ExternalData-01", 1000, "Ignored"));

    // default dampening

    t1.setEnabled(true);

    rulesEngine.addFact(t1);
    rulesEngine.addFact(t1c1);

    rulesEngine.addData(datums);

    rulesEngine.fire();

    assertEquals(alerts.toString(), 1, alerts.size());

    Alert a = alerts.get(0);
    assertEquals("trigger-1", a.getTriggerId());
    assertEquals(1, a.getEvalSets().size());
    Set<ConditionEval> evals = a.getEvalSets().get(0);
    assertEquals(1, evals.size());
    ExternalConditionEval e = (ExternalConditionEval) evals.iterator().next();
    assertEquals(1, e.getConditionSetIndex());
    assertEquals(1, e.getConditionSetSize());
    assertEquals("trigger-1", e.getTriggerId());
    assertTrue(e.isMatch());
    String v = e.getValue();
    assertEquals("Ignored", v);
    assertEquals("ExternalData-01", e.getCondition().getDataId());
}
 

import org.hawkular.alerts.api.model.trigger.Trigger; //导入依赖的package包/类
@Override
public ClientResponse<Trigger> getTrigger(String triggerId) {
    Response serverResponse = null;

    try {
        serverResponse = restApi().getTrigger(triggerId);
        JavaType javaType = simpleResolver().get(Trigger.class);

        return new DefaultClientResponse<>(javaType, serverResponse, ResponseCodes.GET_SUCCESS_200);
    } finally {
        if (serverResponse != null) {
            serverResponse.close();
        }
    }
}