本文整理汇总了Java中com.appdynamics.extensions.yml.YmlReader类的典型用法代码示例。如果您正苦于以下问题:Java YmlReader类的具体用法?Java YmlReader怎么用?Java YmlReader使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
YmlReader类属于com.appdynamics.extensions.yml包,在下文中一共展示了YmlReader类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: main
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
public static void main(String[] args) {
logger.info("*****************START******************");
String msg = "Using AlertingExtension Version [" + getImplementationTitle() + "]";
logger.info(msg);
if (args == null || args.length == 0) {
logger.error("No arguments passed to the extension, exiting the program.");
return;
}
logger.debug("Arguments passed :: " + Arrays.asList(args));
Configuration config;
try {
config = YmlReader.readFromFile(CONFIG_FILENAME, Configuration.class);
SlackAlertExtension alertExtension = new SlackAlertExtension(config);
boolean status = alertExtension.processAnEvent(args);
if (status) {
logger.info("Slack Extension completed successfully.");
logger.info("******************END******************");
return;
}
} catch (Exception e) {
logger.error("Error processing an event", e);
}
logger.error("Slack Extension completed with errors");
}
开发者ID:Appdynamics,项目名称:slack-alerting-extension,代码行数:26,代码来源:SlackAlertExtension.java
示例2: testMasterAndRegionServers
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testMasterAndRegionServers() throws Exception {
config = YmlReader.readFromFileAsMap(new File("src/test/resources/conf/config.yaml"));
List<Map<String, String>> instances = (List<Map<String, String>>) config.get("instances");
server = instances.get(0);
configMBeans = (Map<String, List<Map>>) config.get(ConfigConstants.MBEANS);
PowerMockito.whenNew(Phaser.class)
.withNoArguments().thenReturn(phaser);
Mockito.when(serviceProvider.getMonitorConfiguration()).thenReturn(monitorConfiguration);
Mockito.when(serviceProvider.getMetricWriteHelper()).thenReturn(metricWriter);
Mockito.when(monitorConfiguration.getConfigYml()).thenReturn(config);
Mockito.when(monitorConfiguration.getExecutorService()).thenReturn(executorService);
HBaseMonitorTask hBaseMonitorTask = new HBaseMonitorTask(serviceProvider, server);
hBaseMonitorTask.run();
verify(executorService, times(3)).submit(anyString(), any(JMXMetricCollector.class));
}
开发者ID:Appdynamics,项目名称:hbase-monitoring-extension,代码行数:24,代码来源:HBaseMonitorTaskTest.java
示例3: testMasterOnly
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testMasterOnly() throws Exception {
config = YmlReader.readFromFileAsMap(new File("src/test/resources/conf/configMasterOnly.yaml"));
List<Map<String, String>> instances = (List<Map<String, String>>) config.get("instances");
server = instances.get(0);
configMBeans = (Map<String, List<Map>>) config.get(ConfigConstants.MBEANS);
PowerMockito.whenNew(Phaser.class)
.withNoArguments().thenReturn(phaser);
Mockito.when(serviceProvider.getMonitorConfiguration()).thenReturn(monitorConfiguration);
Mockito.when(serviceProvider.getMetricWriteHelper()).thenReturn(metricWriter);
Mockito.when(monitorConfiguration.getConfigYml()).thenReturn(config);
Mockito.when(monitorConfiguration.getExecutorService()).thenReturn(executorService);
HBaseMonitorTask hBaseMonitorTask = new HBaseMonitorTask(serviceProvider, server);
hBaseMonitorTask.run();
verify(executorService, times(3)).submit(anyString(), any(JMXMetricCollector.class));
}
开发者ID:Appdynamics,项目名称:hbase-monitoring-extension,代码行数:24,代码来源:HBaseMonitorTaskTest.java
示例4: testRegionServerOnly
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testRegionServerOnly() throws Exception {
config = YmlReader.readFromFileAsMap(new File("src/test/resources/conf/configRSOnly.yaml"));
List<Map<String, String>> instances = (List<Map<String, String>>) config.get("instances");
server = instances.get(0);
configMBeans = (Map<String, List<Map>>) config.get(ConfigConstants.MBEANS);
PowerMockito.whenNew(Phaser.class)
.withNoArguments().thenReturn(phaser);
Mockito.when(serviceProvider.getMonitorConfiguration()).thenReturn(monitorConfiguration);
Mockito.when(serviceProvider.getMetricWriteHelper()).thenReturn(metricWriter);
Mockito.when(monitorConfiguration.getConfigYml()).thenReturn(config);
Mockito.when(monitorConfiguration.getExecutorService()).thenReturn(executorService);
HBaseMonitorTask hBaseMonitorTask = new HBaseMonitorTask(serviceProvider, server);
hBaseMonitorTask.run();
verify(executorService, times(3)).submit(anyString(), any(JMXMetricCollector.class));
}
开发者ID:Appdynamics,项目名称:hbase-monitoring-extension,代码行数:24,代码来源:HBaseMonitorTaskTest.java
示例5: main
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
public static void main(String[] args) {
logger.info("*****************START******************");
String msg = "Using Jira Alerting Extension Version [" + getImplementationTitle() + "]";
logger.info(msg);
if (args == null || args.length == 0) {
logger.error("No arguments passed to the extension, exiting the program.");
return;
}
logger.debug("Arguments passed :: " + Arrays.asList(args));
Configuration config;
try {
config = YmlReader.readFromFile(CONFIG_FILENAME, Configuration.class);
JiraAlertExtension alertExtension = new JiraAlertExtension(config);
boolean status = alertExtension.processAnEvent(args);
if (status) {
logger.info("Jira Extension execution completed.");
logger.info("******************END******************");
return;
}
} catch (Exception e) {
logger.error("Error processing an event ", e);
}
logger.error("Jira Extension completed with errors");
}
开发者ID:Appdynamics,项目名称:jira-alerting-extension,代码行数:26,代码来源:JiraAlertExtension.java
示例6: testBuildMetricsWithImproperMetricsConfig
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testBuildMetricsWithImproperMetricsConfig() {
Map<String, ?> config = YmlReader.readFromFile(new File("src/test/resources/conf/config.yml"));
Map<String, ProcessData> processDataMap = Maps.newHashMap();
ProcessData processData = new ProcessData();
Map<String, String> processMetrics = Maps.newHashMap();
processMetrics.put("CPU%", "10");
processMetrics.put("MEM%", "30");
processData.setProcessMetrics(processMetrics);
processDataMap.put("Java", processData);
List<Metric> metrics = classUnderTest.buildMetrics("Linux Processes", processDataMap, config);
Assert.assertEquals(1, metrics.size());
Assert.assertEquals("Linux Processes|Java|CPU%", metrics.get(0).getMetricPath());
Assert.assertEquals(String.valueOf(10), metrics.get(0).getMetricValue());
Assert.assertEquals("INDIVIDUAL", metrics.get(0).getMetricProperties().getClusterRollUpType());
Assert.assertEquals("SUM", metrics.get(0).getMetricProperties().getAggregationType());
Assert.assertEquals(new BigDecimal(1), metrics.get(0).getMetricProperties().getMultiplier());
}
开发者ID:Appdynamics,项目名称:process-monitoring-extension,代码行数:20,代码来源:ProcessMonitorTaskTest.java
示例7: testBuildMetricsWithProperMetricsConfig
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testBuildMetricsWithProperMetricsConfig() {
Map<String, ?> config = YmlReader.readFromFile(new File("src/test/resources/conf/config.yml"));
Map<String, ProcessData> processDataMap = Maps.newHashMap();
ProcessData processData = new ProcessData();
Map<String, String> processMetrics = Maps.newHashMap();
processMetrics.put("CPU%", "10");
processMetrics.put("Memory%", "30");
processMetrics.put("RSS", "30");
processMetrics.put("Running Instances", "2");
processData.setProcessMetrics(processMetrics);
processDataMap.put("Java", processData);
processDataMap.put("SQL", processData);
List<Metric> metrics = classUnderTest.buildMetrics("Linux Processes", processDataMap, config);
Assert.assertEquals(8, metrics.size());
}
开发者ID:Appdynamics,项目名称:process-monitoring-extension,代码行数:18,代码来源:ProcessMonitorTaskTest.java
示例8: testBuildMetricsWithExcessMetricsThanMetricsConfig
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testBuildMetricsWithExcessMetricsThanMetricsConfig() {
Map<String, ?> config = YmlReader.readFromFile(new File("src/test/resources/conf/config.yml"));
Map<String, ProcessData> processDataMap = Maps.newHashMap();
ProcessData processData = new ProcessData();
Map<String, String> processMetrics = Maps.newHashMap();
processMetrics.put("CPU%", "10");
processMetrics.put("Memory%", "30");
processMetrics.put("RSS", "30");
processMetrics.put("Running Instances", "2");
processMetrics.put("VSZ", "10");
processData.setProcessMetrics(processMetrics);
processDataMap.put("Java", processData);
List<Metric> metrics = classUnderTest.buildMetrics("Linux Processes", processDataMap, config);
Assert.assertEquals(4, metrics.size());
}
开发者ID:Appdynamics,项目名称:process-monitoring-extension,代码行数:18,代码来源:ProcessMonitorTaskTest.java
示例9: testFetchMetrics
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testFetchMetrics() {
Map<String, ?> configArgs = YmlReader.readFromFile(new File("src/test/resources/conf/config-aix.yml"));
PowerMockito.when(CommandExecutor.execute(MonitorConstants.AIX_PROCESS_LIST_COMMAND)).thenReturn(processList);
Map<String, ProcessData> processDataMap = parser.fetchMetrics(configArgs);
Map<String, String> javaProcessData = processDataMap.get("java").getProcessMetrics();
Assert.assertEquals(String.valueOf(3), javaProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Assert.assertNull(javaProcessData.get("CPU%"));
Map<String, String> sshProcessData = processDataMap.get("ssh").getProcessMetrics();
Assert.assertEquals(String.valueOf(1), sshProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Assert.assertEquals(String.valueOf(1548), sshProcessData.get("RSS"));
Map<String, String> testProcessData = processDataMap.get("test").getProcessMetrics();
Assert.assertEquals(String.valueOf(0), testProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
}
开发者ID:Appdynamics,项目名称:process-monitoring-extension,代码行数:18,代码来源:AIXParserTest.java
示例10: testFetchMetrics
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testFetchMetrics() {
Map<String, ?> configArgs = YmlReader.readFromFile(new File("src/test/resources/conf/config-solaris.yml"));
PowerMockito.when(CommandExecutor.execute(MonitorConstants.SOLARIS_PROCESS_LIST_COMMAND)).thenReturn(processList);
Map<String, ProcessData> processDataMap = parser.fetchMetrics(configArgs);
Map<String, String> dockerProcessData = processDataMap.get("docker").getProcessMetrics();
Assert.assertEquals(String.valueOf(0), dockerProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Map<String, String> gnomeProcessData = processDataMap.get("gnome").getProcessMetrics();
Assert.assertEquals(String.valueOf(6), gnomeProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Assert.assertNull(gnomeProcessData.get("CPU%"));
Map<String, String> javaProcessData = processDataMap.get("java").getProcessMetrics();
Assert.assertEquals(String.valueOf(1), javaProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Assert.assertEquals(String.valueOf(120012), javaProcessData.get("RSS"));
Map<String, String> java1ProcessData = processDataMap.get("java1").getProcessMetrics();
Assert.assertEquals(String.valueOf(1), java1ProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Map<String, String> hadoopProcessData = processDataMap.get("hadoop").getProcessMetrics();
Assert.assertEquals(String.valueOf(0), hadoopProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
}
开发者ID:Appdynamics,项目名称:process-monitoring-extension,代码行数:24,代码来源:SolarisParserTest.java
示例11: testFetchMetrics
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testFetchMetrics() {
Map<String, ?> configArgs = YmlReader.readFromFile(new File("src/test/resources/conf/config-linux.yml"));
PowerMockito.when(CommandExecutor.execute(MonitorConstants.LINUX_PROCESS_LIST_COMMAND)).thenReturn(processList);
Map<String, ProcessData> processDataMap = parser.fetchMetrics(configArgs);
Map<String, String> dockerProcessData = processDataMap.get("docker").getProcessMetrics();
Assert.assertEquals(String.valueOf(2), dockerProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Map<String, String> biosetProcessData = processDataMap.get("bioset").getProcessMetrics();
Assert.assertEquals(String.valueOf(10), biosetProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
// If instance count is > 1, no metrics will be reported
Assert.assertNull(biosetProcessData.get("CPU%"));
Map<String, String> javaProcessData = processDataMap.get("java").getProcessMetrics();
Assert.assertEquals(String.valueOf(1), javaProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Assert.assertEquals(String.valueOf(264708), javaProcessData.get("RSS"));
Map<String, String> hadoopProcessData = processDataMap.get("hadoop").getProcessMetrics();
Assert.assertEquals(String.valueOf(0), hadoopProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
}
开发者ID:Appdynamics,项目名称:process-monitoring-extension,代码行数:22,代码来源:LinuxParserTest.java
示例12: testParseProcesses
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void testParseProcesses() {
Map<String, ?> configArgs = YmlReader.readFromFile(new File("src/test/resources/conf/config-windows.yml"));
Mockito.doReturn(processList).when(parser).fetchProcessListFromSigar();
Mockito.doReturn(20.0).when(parser).getProcCPU((Sigar) Mockito.anyObject(), Mockito.anyString());
Mockito.doReturn(Long.valueOf(20)).when(parser).getProcMem((Sigar) Mockito.anyObject(), Mockito.anyString());
Map<String, ProcessData> processDataMap = parser.fetchMetrics(configArgs);
Map<String, String> dockerProcessData = processDataMap.get("docker").getProcessMetrics();
Assert.assertEquals(String.valueOf(0), dockerProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Map<String, String> svchostProcessData = processDataMap.get("svchost").getProcessMetrics();
Assert.assertEquals(String.valueOf(11), svchostProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Map<String, String> svchostFilteredData = processDataMap.get("svchostFiltered").getProcessMetrics();
Assert.assertEquals(String.valueOf(1), svchostFilteredData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Map<String, String> javaProcessData = processDataMap.get("java").getProcessMetrics();
Assert.assertEquals(String.valueOf(2), javaProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Map<String, String> machineAgentProcessData = processDataMap.get("MachineAgent").getProcessMetrics();
Assert.assertEquals(String.valueOf(1), machineAgentProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
Map<String, String> notepadProcessData = processDataMap.get("Notepad").getProcessMetrics();
Assert.assertEquals(String.valueOf(1), notepadProcessData.get(MonitorConstants.RUNNING_INSTANCES_COUNT));
}
开发者ID:Appdynamics,项目名称:process-monitoring-extension,代码行数:27,代码来源:WindowsParserTest.java
示例13: execute
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
public TaskOutput execute(Map<String, String> taskArguments, TaskExecutionContext taskContext)
throws TaskExecutionException {
if(taskArguments != null) {
logger.info("Starting " + getImplementationVersion() + " Monitoring Task");
try {
String configFilename = getConfigFilename(taskArguments.get(CONFIG_ARG));
Configuration config = YmlReader.readFromFile(configFilename, Configuration.class);
fetchMetrics(config, OracleQueries.queries);
printDBMetrics(config);
logger.info("Oracle DB Monitoring Task completed successfully");
return new TaskOutput("Oracle DB Monitoring Task completed successfully");
} catch (Exception e) {
logger.error("Metrics Collection Failed: ", e);
}
}
throw new TaskExecutionException("Oracle DB Monitoring Task completed with failures.");
}
开发者ID:Appdynamics,项目名称:oracle-monitoring-extension,代码行数:21,代码来源:OracleDbMonitor.java
示例14: getCores_whenNoCoresPresent
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void getCores_whenNoCoresPresent () throws IOException {
Map<String, ?> config = YmlReader.readFromFile(new File("src/test/resources/conf/config_with_no_cores.yml"));
List<Core> cores = coreContextStats.getCores(config);
Assert.assertTrue(cores.get(0).getName().equals("DefaultCore"));
Assert.assertTrue(cores.get(0).getQueryHandlers().size() == 0);
Assert.assertTrue(cores.get(0).getPingHandler() == null);
}
开发者ID:Appdynamics,项目名称:solr-monitoring-extension,代码行数:9,代码来源:CoreContextTest.java
示例15: getCores_whenCoreIsPresent
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void getCores_whenCoreIsPresent () throws IOException {
Map<String, ?> config = YmlReader.readFromFile(new File("src/test/resources/conf/config_with_core.yml"));
List<Core> cores = coreContextStats.getCores(config);
Assert.assertTrue(cores.get(0).getName().equals("gettingstarted"));
Assert.assertTrue(cores.get(0).getPingHandler().equals("/admin/ping"));
Assert.assertTrue(cores.get(0).getQueryHandlers().get(0).equals("/select"));
Assert.assertTrue(cores.get(0).getQueryHandlers().get(1).equals("/update"));
}
开发者ID:Appdynamics,项目名称:solr-monitoring-extension,代码行数:10,代码来源:CoreContextTest.java
示例16: getCores_whenEmptyCoresElementIsPresent
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void getCores_whenEmptyCoresElementIsPresent () throws IOException {
Map<String, ?> config = YmlReader.readFromFile(new File
("src/test/resources/conf/config_with_empty_cores_element.yml"));
List<Core> cores = coreContextStats.getCores(config);
Assert.assertTrue(cores.get(0).getName().equals("DefaultCore"));
Assert.assertTrue(cores.get(0).getQueryHandlers().size() == 0);
Assert.assertTrue(cores.get(0).getPingHandler() == null);
}
开发者ID:Appdynamics,项目名称:solr-monitoring-extension,代码行数:10,代码来源:CoreContextTest.java
示例17: getNodeMetrics_NonCompositeObject
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void getNodeMetrics_NonCompositeObject () throws MalformedObjectNameException, IntrospectionException, ReflectionException,
InstanceNotFoundException, IOException {
Map config = YmlReader.readFromFileAsMap(new File(this.getClass().getResource("/conf/config_without_composite_object.yml").getFile()));
List<Map> mBeans = (List) config.get("mbeans");
Set<ObjectInstance> objectInstances = Sets.newHashSet();
objectInstances.add(new ObjectInstance("org.apache.cassandra.metrics:type=ClientRequest,scope=Read,name=Latency", "test"));
Set<Attribute> attributes = Sets.newHashSet();
attributes.add(new Attribute("Min", new BigDecimal(100)));
attributes.add(new Attribute("Max", new BigDecimal(200)));
List<String> metricNames = Lists.newArrayList();
metricNames.add("metric1");
metricNames.add("metric2");
when(jmxConnectionAdapter.queryMBeans(eq(jmxConnector), Mockito.any(ObjectName.class))).thenReturn
(objectInstances);
when(jmxConnectionAdapter.getReadableAttributeNames(eq(jmxConnector), Mockito.any(ObjectInstance.class)))
.thenReturn(metricNames);
when(jmxConnectionAdapter.getAttributes(eq(jmxConnector), Mockito.any(ObjectName.class), Mockito.any(String[]
.class))).thenReturn(attributes);
MetricPropertiesBuilder metricPropertiesBuilder = new MetricPropertiesBuilder();
NodeMetricsProcessor nodeMetricsProcessor = new NodeMetricsProcessor(jmxConnectionAdapter, jmxConnector);
Map<String, MetricProperties> metricPropertiesMap = metricPropertiesBuilder.build(mBeans.get(0));
List<Metric> metrics = nodeMetricsProcessor.getNodeMetrics(mBeans.get(0), metricPropertiesMap, "");
Assert.assertTrue(metrics.get(0).getMetricKey().equals("ClientRequest|Read|Latency|Max Latency"));
Assert.assertTrue(metrics.get(0).getInstanceKey().equals("ClientRequest|Read|Latency|"));
Assert.assertTrue(metrics.get(0).getMetricValue().equals(new BigDecimal(200)));
Assert.assertTrue(metrics.get(0).getProperties().equals(metricPropertiesMap.get("Max")));
Assert.assertTrue(metrics.get(1).getMetricKey().equals("ClientRequest|Read|Latency|Min Latency"));
Assert.assertTrue(metrics.get(1).getInstanceKey().equals("ClientRequest|Read|Latency|"));
Assert.assertTrue(metrics.get(1).getMetricValue().equals(new BigDecimal(100)));
Assert.assertTrue(metrics.get(1).getProperties().equals(metricPropertiesMap.get("Min")));
}
开发者ID:Appdynamics,项目名称:cassandra-monitoring-extension,代码行数:41,代码来源:NodeMetricsProcessorTest.java
示例18: getNodeMetrics_CompositeObject
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void getNodeMetrics_CompositeObject () throws MalformedObjectNameException, IntrospectionException,
ReflectionException, InstanceNotFoundException, IOException, OpenDataException {
Map config = YmlReader.readFromFileAsMap(new File(this.getClass().getResource
("/conf/config_with_composite_object.yml").getFile()));
List<Map> mBeans = (List) config.get("mbeans");
Set<ObjectInstance> objectInstances = Sets.newHashSet();
objectInstances.add(new ObjectInstance("java.lang:type=Memory", "test"));
Set<Attribute> attributes = Sets.newHashSet();
attributes.add(new Attribute("HeapMemoryUsage", createCompositeDataSupportObject()));
List<String> metricNames = Lists.newArrayList();
metricNames.add("metric1");
metricNames.add("metric2");
when(jmxConnectionAdapter.queryMBeans(eq(jmxConnector), Mockito.any(ObjectName.class))).thenReturn
(objectInstances);
when(jmxConnectionAdapter.getReadableAttributeNames(eq(jmxConnector), Mockito.any(ObjectInstance.class)))
.thenReturn(metricNames);
when(jmxConnectionAdapter.getAttributes(eq(jmxConnector), Mockito.any(ObjectName.class), Mockito.any(String[]
.class))).thenReturn(attributes);
MetricPropertiesBuilder metricPropertiesBuilder = new MetricPropertiesBuilder();
NodeMetricsProcessor nodeMetricsProcessor = new NodeMetricsProcessor(jmxConnectionAdapter, jmxConnector);
Map<String, MetricProperties> metricPropertiesMap = metricPropertiesBuilder.build(mBeans.get(0));
List<Metric> metrics = nodeMetricsProcessor.getNodeMetrics(mBeans.get(0), metricPropertiesMap, "");
Assert.assertTrue(metrics.get(0).getMetricKey().equals("Memory|Heap Memory Usage|Max Heap Memory"));
Assert.assertTrue(metrics.get(0).getInstanceKey().equals("Memory|"));
Assert.assertTrue(metrics.get(0).getMetricValue().equals(new BigDecimal(100)));
Assert.assertTrue(metrics.get(0).getProperties().equals(metricPropertiesMap.get("HeapMemoryUsage.max")));
Assert.assertTrue(metrics.get(1).getMetricKey().equals("Memory|Heap Memory Usage|Used Heap Memory"));
Assert.assertTrue(metrics.get(1).getInstanceKey().equals("Memory|"));
Assert.assertTrue(metrics.get(1).getMetricValue().equals(new BigDecimal(50)));
Assert.assertTrue(metrics.get(1).getProperties().equals(metricPropertiesMap.get("HeapMemoryUsage.used")));
}
开发者ID:Appdynamics,项目名称:cassandra-monitoring-extension,代码行数:38,代码来源:NodeMetricsProcessorTest.java
示例19: getNodeMetrics_compositeAndNonCompositeObjects
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void getNodeMetrics_compositeAndNonCompositeObjects() throws MalformedObjectNameException, IntrospectionException,
ReflectionException, InstanceNotFoundException, IOException, OpenDataException {
Map config = YmlReader.readFromFileAsMap(new File(this.getClass().getResource("/conf/config_with_composite_and_noncomposite_objects.yml").getFile()));
List<Map> mBeans = (List) config.get("mbeans");
Set<ObjectInstance> objectInstances = Sets.newHashSet();
objectInstances.add(new ObjectInstance("java.lang:type=Memory", "test"));
Set<Attribute> attributes = Sets.newHashSet();
attributes.add(new Attribute("ObjectPendingFinalizationCount", 0));
attributes.add(new Attribute("HeapMemoryUsage", createCompositeDataSupportObject()));
List<String> metricNames = Lists.newArrayList();
metricNames.add("metric1");
metricNames.add("metric2");
when(jmxConnectionAdapter.queryMBeans(eq(jmxConnector), Mockito.any(ObjectName.class))).thenReturn
(objectInstances);
when(jmxConnectionAdapter.getReadableAttributeNames(eq(jmxConnector), Mockito.any(ObjectInstance.class)))
.thenReturn(metricNames);
when(jmxConnectionAdapter.getAttributes(eq(jmxConnector), Mockito.any(ObjectName.class), Mockito.any(String[]
.class))).thenReturn(attributes);
MetricPropertiesBuilder metricPropertiesBuilder = new MetricPropertiesBuilder();
NodeMetricsProcessor nodeMetricsProcessor = new NodeMetricsProcessor(jmxConnectionAdapter, jmxConnector);
Map<String, MetricProperties> metricPropertiesMap = metricPropertiesBuilder.build(mBeans.get(0));
List<Metric> metrics = nodeMetricsProcessor.getNodeMetrics(mBeans.get(0), metricPropertiesMap, "");
Assert.assertTrue(metrics.get(0).getMetricKey().equals("Memory|ObjectPendingFinalizationCount"));
Assert.assertTrue(metrics.get(0).getInstanceKey().equals("Memory|"));
Assert.assertTrue(metrics.get(0).getMetricValue().equals(new BigDecimal(0)));
Assert.assertTrue(metrics.get(0).getProperties().equals(metricPropertiesMap.get("ObjectPendingFinalizationCount")));
Assert.assertTrue(metrics.get(1).getMetricKey().equals("Memory|Heap Memory Usage|Heap Memory Used"));
Assert.assertTrue(metrics.get(1).getInstanceKey().equals("Memory|"));
Assert.assertTrue(metrics.get(1).getMetricValue().equals(new BigDecimal(50)));
Assert.assertTrue(metrics.get(1).getProperties().equals(metricPropertiesMap.get("HeapMemoryUsage.used")));
}
开发者ID:Appdynamics,项目名称:cassandra-monitoring-extension,代码行数:41,代码来源:NodeMetricsProcessorTest.java
示例20: getNodeMetrics_NonCompositeObject
import com.appdynamics.extensions.yml.YmlReader; //导入依赖的package包/类
@Test
public void getNodeMetrics_NonCompositeObject () throws MalformedObjectNameException, IntrospectionException, ReflectionException,
InstanceNotFoundException, IOException {
Map config = YmlReader.readFromFileAsMap(new File(this.getClass().getResource("/conf/config_without_composite_object.yml").getFile()));
List<Map> mBeans = (List) config.get("mbeans");
Set<ObjectInstance> objectInstances = Sets.newHashSet();
objectInstances.add(new ObjectInstance("org.apache.activemq.metrics:type=ClientRequest,scope=Read,name=Latency", "test"));
Set<Attribute> attributes = Sets.newHashSet();
attributes.add(new Attribute("Min", new BigDecimal(100)));
attributes.add(new Attribute("Max", new BigDecimal(200)));
List<String> metricNames = Lists.newArrayList();
metricNames.add("metric1");
metricNames.add("metric2");
when(jmxConnectionAdapter.queryMBeans(eq(jmxConnector), Mockito.any(ObjectName.class))).thenReturn
(objectInstances);
when(jmxConnectionAdapter.getReadableAttributeNames(eq(jmxConnector), Mockito.any(ObjectInstance.class)))
.thenReturn(metricNames);
when(jmxConnectionAdapter.getAttributes(eq(jmxConnector), Mockito.any(ObjectName.class), Mockito.any(String[]
.class))).thenReturn(attributes);
MetricPropertiesBuilder metricPropertiesBuilder = new MetricPropertiesBuilder();
NodeMetricsProcessor nodeMetricsProcessor = new NodeMetricsProcessor(jmxConnectionAdapter, jmxConnector);
Map<String, MetricProperties> metricPropertiesMap = metricPropertiesBuilder.build(mBeans.get(0));
List<Metric> metrics = nodeMetricsProcessor.getNodeMetrics(mBeans.get(0), metricPropertiesMap, "");
Assert.assertTrue(metrics.get(0).getMetricKey().equals("ClientRequest|Read|Latency|Max Latency"));
Assert.assertTrue(metrics.get(0).getInstanceKey().equals("ClientRequest|Read|Latency|"));
Assert.assertTrue(metrics.get(0).getMetricValue().equals(new BigDecimal(200)));
Assert.assertTrue(metrics.get(0).getProperties().equals(metricPropertiesMap.get("Max")));
Assert.assertTrue(metrics.get(1).getMetricKey().equals("ClientRequest|Read|Latency|Min Latency"));
Assert.assertTrue(metrics.get(1).getInstanceKey().equals("ClientRequest|Read|Latency|"));
Assert.assertTrue(metrics.get(1).getMetricValue().equals(new BigDecimal(100)));
Assert.assertTrue(metrics.get(1).getProperties().equals(metricPropertiesMap.get("Min")));
}
开发者ID:Appdynamics,项目名称:activemq-monitoring-extension,代码行数:41,代码来源:NodeMetricsProcessorTest.java
注:本文中的com.appdynamics.extensions.yml.YmlReader类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论