org.apache.brooklyn.api.entity.Entity.enrichers()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(14.5k)|赞(0)|评价(0)|浏览(129)

本文整理了Java中org.apache.brooklyn.api.entity.Entity.enrichers()方法的一些代码示例，展示了Entity.enrichers()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Entity.enrichers()方法的具体详情如下：
包路径：org.apache.brooklyn.api.entity.Entity
类名称：Entity
方法名：enrichers

Entity.enrichers介绍

暂无

代码示例

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

@Override protected Enricher getInstanceFromId(Optional<Entity> entity, String id) {
    if (id == null || !entity.isPresent()) return null;
    for (Enricher enricher : entity.get().enrichers()) {
      if (id.equals(enricher.getId())) {
        return enricher;
      }
    }
    return null;
  }
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

public void addTo(Entity entity) {
  entity.enrichers().add(this);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

public static List<Enricher> getNonSystemEnrichers(Entity entity) {
  List<Enricher> result = MutableList.copyOf(entity.enrichers());
  Iterator<Enricher> ri = result.iterator();
  while (ri.hasNext()) {
    if (isSystemEnricher(ri.next())) ri.remove();
  }
  return result;
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-camp

protected static <T extends Enricher> T assertHasEnricher(Entity entity, Class<T> enricherClazz) {
  Enricher enricher = Iterables.find(entity.enrichers(), Predicates.instanceOf(enricherClazz));
  assertNotNull(enricher);
  return enricherClazz.cast(enricher);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

@Override
public synchronized void onUnmanaged(BrooklynObject instance) {
  if (LOG.isTraceEnabled()) LOG.trace("onUnmanaged: {}", instance);
  if (!isStopped()) {
    removeFromCollector(instance);
    if (instance instanceof Entity) {
      Entity entity = (Entity) instance;
      for (BrooklynObject adjunct : entity.policies()) removeFromCollector(adjunct);
      for (BrooklynObject adjunct : entity.enrichers()) removeFromCollector(adjunct);
      for (BrooklynObject adjunct : ((EntityInternal)entity).feeds().getFeeds()) removeFromCollector(adjunct);
    }
  }
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

private static void setExpectedState(Entity entity, Lifecycle state, boolean waitBrieflyForServiceUpIfRunning) {
  if (waitBrieflyForServiceUpIfRunning) {
    waitBrieflyForServiceUpIfStateIsRunning(entity, state);
  }
  ((EntityInternal)entity).sensors().set(Attributes.SERVICE_STATE_EXPECTED, new Lifecycle.Transition(state, new Date()));
  Maybe<Enricher> enricher = EntityAdjuncts.tryFindWithUniqueTag(entity.enrichers(), ComputeServiceState.DEFAULT_ENRICHER_UNIQUE_TAG);
  if (enricher.isPresent() && enricher.get() instanceof ComputeServiceState) {
    ((ComputeServiceState)enricher.get()).onEvent(null);
  }
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-base

public static void addMachineMetricsEnrichers(Entity entity) {
  entity.enrichers().add(EnricherSpec.create(YamlTimeWeightedDeltaEnricher.class)
      .configure(YamlTimeWeightedDeltaEnricher.SOURCE_SENSOR, MachineAttributes.USED_MEMORY)
      .configure(YamlTimeWeightedDeltaEnricher.TARGET_SENSOR, MachineAttributes.USED_MEMORY_DELTA_PER_SECOND_LAST));
  entity.enrichers().add(EnricherSpec.create(YamlRollingTimeWindowMeanEnricher.class)
      .configure(YamlRollingTimeWindowMeanEnricher.SOURCE_SENSOR, MachineAttributes.USED_MEMORY_DELTA_PER_SECOND_LAST)
      .configure(YamlRollingTimeWindowMeanEnricher.TARGET_SENSOR, MachineAttributes.USED_MEMORY_DELTA_PER_SECOND_IN_WINDOW));
  entity.enrichers().add(EnricherSpec.create(PercentageEnricher.class)
      .configure(PercentageEnricher.SOURCE_CURRENT_SENSOR, MachineAttributes.USED_MEMORY)
      .configure(PercentageEnricher.SOURCE_TOTAL_SENSOR, MachineAttributes.TOTAL_MEMORY)
      .configure(PercentageEnricher.TARGET_SENSOR, MachineAttributes.USED_MEMORY_PERCENT)
      .configure(PercentageEnricher.SUPPRESS_DUPLICATES, true));
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-base

public static void connectJavaAppServerPolicies(Entity entity, Duration windowPeriod) {
  entity.enrichers().add(EnricherSpec.create(TimeFractionDeltaEnricher.class)
      .configure("producer", entity)
      .configure("source", UsesJavaMXBeans.PROCESS_CPU_TIME)
      .configure("target", UsesJavaMXBeans.PROCESS_CPU_TIME_FRACTION_LAST)
      .configure("durationPerOrigUnit", Duration.millis(1)));
  entity.enrichers().add(EnricherSpec.create(RollingTimeWindowMeanEnricher.class)
      .configure("producer", entity)
      .configure("source", UsesJavaMXBeans.PROCESS_CPU_TIME_FRACTION_LAST)
      .configure("target", UsesJavaMXBeans.PROCESS_CPU_TIME_FRACTION_IN_WINDOW)
      .configure("timePeriod", windowPeriod));
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@Test
@SuppressWarnings("unchecked")
public void testZeroWindowSize() {
  averager = producer.enrichers().add(EnricherSpec.create(RollingMeanEnricher.class)
      .configure("producer", producer)
      .configure("source", deltaSensor)
      .configure("target", avgSensor)
      .configure("windowSize", 0));
  
  averager.onEvent(intSensor.newEvent(producer, 10));
  assertEquals(averager.getAverage(), null);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@Test
public void testConvertsTimeUnits() {
  @SuppressWarnings("unchecked")
  TimeFractionDeltaEnricher<Integer> enricher = producer.enrichers().add(EnricherSpec.create(TimeFractionDeltaEnricher.class)
      .configure("producer", producer)
      .configure("source", intSensor)
      .configure("target", fractionSensor)
      .configure("durationPerOrigUnit", Duration.micros(1)));
  
  enricher.onEvent(new BasicSensorEvent<Integer>(intSensor, producer, 0, 1000000L));
  enricher.onEvent(new BasicSensorEvent<Integer>(intSensor, producer, 1000000, 1001000L));
  assertEquals(producer.getAttribute(fractionSensor), 1d);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

private void addReferencedObjects(DeltaCollector deltaCollector) {
  MutableSet<BrooklynObject> referencedObjects = MutableSet.of();
  
  // collect references
  for (Entity entity : deltaCollector.entities) {
    // FIXME How to let the policy/location tell us about changes? Don't do this every time!
    for (Location location : entity.getLocations()) {
      Collection<Location> findLocationsInHierarchy = TreeUtils.findLocationsInHierarchy(location);
      referencedObjects.addAll(findLocationsInHierarchy);
    }
    if (persistPoliciesEnabled) {
      referencedObjects.addAll(entity.policies());
    }
    if (persistEnrichersEnabled) {
      referencedObjects.addAll(entity.enrichers());
    }
    if (persistFeedsEnabled) {
      referencedObjects.addAll(((EntityInternal)entity).feeds().getFeeds());
    }
  }
  
  for (BrooklynObject instance : referencedObjects) {
    deltaCollector.addIfNotRemoved(instance);
  }
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@Test
  public void testConverts100NanosTimeBlocks() {
    @SuppressWarnings("unchecked")
    TimeFractionDeltaEnricher<Integer> enricher = producer.enrichers().add(EnricherSpec.create(TimeFractionDeltaEnricher.class)
        .configure("producer", producer)
        .configure("source", intSensor)
        .configure("target", fractionSensor)
        .configure("durationPerOrigUnit", Duration.nanos(100)));
    
    enricher.onEvent(new BasicSensorEvent<Integer>(intSensor, producer, 0, 1000000L));
    enricher.onEvent(new BasicSensorEvent<Integer>(intSensor, producer, 10000000, 1001000L));
    assertEquals(producer.getAttribute(fractionSensor), 1d);
  }
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@Test
public void testDeltaEnricher() {
  AttributeSensor<Integer> deltaSensor = new BasicAttributeSensor<Integer>(Integer.class, "delta sensor");
  @SuppressWarnings("unchecked")
  DeltaEnricher<Integer> delta = producer.enrichers().add(EnricherSpec.create(DeltaEnricher.class)
      .configure("producer", producer)
      .configure("source", intSensor)
      .configure("target", deltaSensor));
  delta.onEvent(intSensor.newEvent(producer, 0));
  delta.onEvent(intSensor.newEvent(producer, 0));
  assertEquals(producer.getAttribute(deltaSensor), (Integer)0);
  delta.onEvent(intSensor.newEvent(producer, 1));
  assertEquals(producer.getAttribute(deltaSensor), (Integer)1);
  delta.onEvent(intSensor.newEvent(producer, 3));
  assertEquals(producer.getAttribute(deltaSensor), (Integer)2);
  delta.onEvent(intSensor.newEvent(producer, 8));
  assertEquals(producer.getAttribute(deltaSensor), (Integer)5);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@Test
public void testMonospaceTimeWeightedDeltaEnricher() {
  AttributeSensor<Double> deltaSensor = new BasicAttributeSensor<Double>(Double.class, "per second delta delta sensor");
  @SuppressWarnings("unchecked")
  TimeWeightedDeltaEnricher<Integer> delta = producer.enrichers().add(EnricherSpec.create(TimeWeightedDeltaEnricher.class)
      .configure("producer", producer)
      .configure("source", intSensor)
      .configure("target", deltaSensor)
      .configure("unitMillis", 1000));
  
  // Don't start with timestamp=0: that may be treated special 
  delta.onEvent(intSensor.newEvent(producer, 0), 1000);
  assertEquals(producer.getAttribute(deltaSensor), null);
  delta.onEvent(intSensor.newEvent(producer, 0), 2000);
  assertEquals(producer.getAttribute(deltaSensor), 0d);
  delta.onEvent(intSensor.newEvent(producer, 1), 3000);
  assertEquals(producer.getAttribute(deltaSensor), 1d);
  delta.onEvent(intSensor.newEvent(producer, 3), 4000);
  assertEquals(producer.getAttribute(deltaSensor), 2d);
  delta.onEvent(intSensor.newEvent(producer, 8), 5000);
  assertEquals(producer.getAttribute(deltaSensor), 5d);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@Test
public void testCalculatesFractions() {
  @SuppressWarnings("unchecked")
  TimeFractionDeltaEnricher<Integer> enricher = producer.enrichers().add(EnricherSpec.create(TimeFractionDeltaEnricher.class)
      .configure("producer", producer)
      .configure("source", intSensor)
      .configure("target", fractionSensor)
      .configure("durationPerOrigUnit", Duration.millis(1)));
  
  enricher.onEvent(new BasicSensorEvent<Integer>(intSensor, producer, 0, 1000000L));
  enricher.onEvent(new BasicSensorEvent<Integer>(intSensor, producer, 0, 1001000L));
  assertEquals(producer.getAttribute(fractionSensor), 0d);
  
  enricher.onEvent(new BasicSensorEvent<Integer>(intSensor, producer, 100, 1002000L));
  assertEquals(producer.getAttribute(fractionSensor), 0.1d, PRECISION);
  
  enricher.onEvent(new BasicSensorEvent<Integer>(intSensor, producer, 300, 1003000L));
  assertEquals(producer.getAttribute(fractionSensor), 0.2d, PRECISION);
  
  enricher.onEvent(new BasicSensorEvent<Integer>(intSensor, producer, 2300, 1004000L));
  assertEquals(producer.getAttribute(fractionSensor), 2d, PRECISION);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@Test
public void testPostProcessorCalledForDeltaEnricher() {
  AttributeSensor<Double> deltaSensor = new BasicAttributeSensor<Double>(Double.class, "per second delta delta sensor");
  @SuppressWarnings("unchecked")
  TimeWeightedDeltaEnricher<Integer> delta = producer.enrichers().add(EnricherSpec.create(TimeWeightedDeltaEnricher.class)
      .configure("producer", producer)
      .configure("source", intSensor)
      .configure("target", deltaSensor)
      .configure("unitMillis", 1000)
      .configure("postProcessor", new AddConstant(123d)));
  
  delta.onEvent(intSensor.newEvent(producer, 0), 1000);
  delta.onEvent(intSensor.newEvent(producer, 0), 2000);
  assertEquals(producer.getAttribute(deltaSensor), 123+0d);
  delta.onEvent(intSensor.newEvent(producer, 1), 3000);
  assertEquals(producer.getAttribute(deltaSensor), 123+1d);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@BeforeMethod(alwaysRun=true)
@SuppressWarnings("unchecked")
@Override
public void setUp() throws Exception {
  super.setUp();
  producer = app.addChild(EntitySpec.create(TestEntity.class));
  intSensor = new BasicAttributeSensor<Integer>(Integer.class, "int sensor");
  deltaSensor = new BasicAttributeSensor<Integer>(Integer.class, "delta sensor");
  avgSensor = new BasicAttributeSensor<Double>(Double.class, "avg sensor");
  
  producer.enrichers().add(EnricherSpec.create(DeltaEnricher.class)
      .configure("producer", producer)
      .configure("source", intSensor)
      .configure("target", deltaSensor));
  averager = producer.enrichers().add(EnricherSpec.create(RollingTimeWindowMeanEnricher.class)
      .configure("producer", producer)
      .configure("source", deltaSensor)
      .configure("target", avgSensor)
      .configure("timePeriod", timePeriod));
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-launcher

@Test
public void testDeletesOrphanedEnricher() throws Exception {
  Entity entity = origApp.addChild(EntitySpec.create(TestEntity.class).impl(MyEntity.class));
  MyEnricher enricher = entity.enrichers().add(EnricherSpec.create(MyEnricher.class));
  MementoTweaker tweaker = new MementoTweaker(new Deletions().entities(entity.getId()));
  assertTransformDeletes(new Deletions().enrichers(enricher.getId()), tweaker);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@Test
public void testVariableTimeWeightedDeltaEnricher() {
  AttributeSensor<Double> deltaSensor = new BasicAttributeSensor<Double>(Double.class, "per second delta delta sensor");
  @SuppressWarnings("unchecked")
  TimeWeightedDeltaEnricher<Integer> delta = producer.enrichers().add(EnricherSpec.create(TimeWeightedDeltaEnricher.class)
      .configure("producer", producer)
      .configure("source", intSensor)
      .configure("target", deltaSensor)
      .configure("unitMillis", 1000));
  
  delta.onEvent(intSensor.newEvent(producer, 0), 1000);
  delta.onEvent(intSensor.newEvent(producer, 0), 3000);
  assertEquals(producer.getAttribute(deltaSensor), 0d);
  delta.onEvent(intSensor.newEvent(producer, 3), 6000);
  assertEquals(producer.getAttribute(deltaSensor), 1d);
  delta.onEvent(intSensor.newEvent(producer, 7), 8000);
  assertEquals(producer.getAttribute(deltaSensor), 2d);
  delta.onEvent(intSensor.newEvent(producer, 12), 8500);
  assertEquals(producer.getAttribute(deltaSensor), 10d);
  delta.onEvent(intSensor.newEvent(producer, 15), 10500);
  assertEquals(producer.getAttribute(deltaSensor), 1.5d);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-policy

@BeforeMethod(alwaysRun=true)
@SuppressWarnings("unchecked")
@Override
public void setUp() throws Exception {
  super.setUp();
  producer = app.addChild(EntitySpec.create(TestEntity.class));
  intSensor = new BasicAttributeSensor<Integer>(Integer.class, "int sensor");
  deltaSensor = new BasicAttributeSensor<Integer>(Integer.class, "delta sensor");
  avgSensor = new BasicAttributeSensor<Double>(Double.class, "avg sensor");
  
  producer.enrichers().add(EnricherSpec.create(DeltaEnricher.class)
      .configure("producer", producer)
      .configure("source", intSensor)
      .configure("target", deltaSensor));
  averager = producer.enrichers().add(EnricherSpec.create(RollingMeanEnricher.class)
      .configure("producer", producer)
      .configure("source", intSensor)
      .configure("target", deltaSensor)
      .configure("windowSize", 4));
}

内容来源于网络，如有侵权，请联系作者删除！

Entity

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com