Package com.atlassian.diagnostics.internal

Class DefaultMonitoringService

java.lang.Object

com.atlassian.diagnostics.internal.DefaultMonitoringService

All Implemented Interfaces:

InternalMonitoringService, IssueSupplier, MonitoringService, com.atlassian.sal.api.lifecycle.LifecycleAware

public class DefaultMonitoringService
extends Object
implements com.atlassian.sal.api.lifecycle.LifecycleAware, InternalMonitoringService, IssueSupplier

Constructor Summary

Constructors

Constructor

Description

DefaultMonitoringService(DiagnosticsConfiguration configuration, AlertEntityDao dao, com.atlassian.sal.api.message.I18nResolver i18nResolver, JsonMapper jsonMapper, com.atlassian.sal.api.permission.PermissionEnforcer permissionEnforcer, PluginHelper pluginHelper, AlertPublisher publisher, com.atlassian.scheduler.SchedulerService schedulerService, com.atlassian.sal.api.transaction.TransactionTemplate transactionTemplate)

Method Summary

Modifier and Type	Method	Description
ComponentMonitor	createMonitor(String componentId, String componentNameI18nKey)
ComponentMonitor	createMonitor(String componentId, String componentNameI18nKey, MonitorConfiguration monitorConfiguration)
boolean	destroyMonitor(String componentId)
Set<Component>	findAllComponents()
Set<Issue>	findAllIssues()
Set<String>	findAllNodesWithAlerts()
Set<PluginDetails>	findAllPluginsWithAlerts()
Issue	getIssue(String issueId, Severity severity)
Optional<ComponentMonitor>	getMonitor(String componentId)
<T> T	internalStreamAlertCounts(AlertCriteria criteria, PageCallback<? super AlertCount,T> callback, PageRequest pageRequest)	Gives unsecured access to MonitoringService.streamAlertCounts(AlertCriteria, PageCallback, PageRequest), to allow publishing of daily analytics
boolean	isEnabled()
void	onStart()
void	onStop()
<T> T	streamAlertCounts(AlertCriteria criteria, PageCallback<? super AlertCount,T> callback, PageRequest pageRequest)
<T> T	streamAlerts(AlertCriteria criteria, PageCallback<? super Alert,T> callback, PageRequest pageRequest)
<T> T	streamAlertsWithElisions(AlertCriteria criteria, PageCallback<? super AlertWithElisions,T> callback, PageRequest pageRequest)
String	subscribe(AlertListener listener)
boolean	unsubscribe(String subscriptionId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultMonitoringService

public DefaultMonitoringService(DiagnosticsConfiguration configuration,
 AlertEntityDao dao,
 com.atlassian.sal.api.message.I18nResolver i18nResolver,
 JsonMapper jsonMapper,
 com.atlassian.sal.api.permission.PermissionEnforcer permissionEnforcer,
 PluginHelper pluginHelper,
 AlertPublisher publisher,
 com.atlassian.scheduler.SchedulerService schedulerService,
 com.atlassian.sal.api.transaction.TransactionTemplate transactionTemplate)

Method Details

createMonitor

@Nonnull
public ComponentMonitor createMonitor(@Nonnull
 String componentId,
 @Nonnull
 String componentNameI18nKey)

Specified by:

createMonitor in interface MonitoringService

createMonitor

@Nonnull
public ComponentMonitor createMonitor(@Nonnull
 String componentId,
 @Nonnull
 String componentNameI18nKey,
 @Nonnull
 MonitorConfiguration monitorConfiguration)

Specified by:

createMonitor in interface MonitoringService

destroyMonitor

public boolean destroyMonitor(@Nonnull
 String componentId)

Specified by:

destroyMonitor in interface MonitoringService

findAllComponents

@Nonnull
public Set<Component> findAllComponents()

Specified by:

findAllComponents in interface MonitoringService

findAllIssues

@Nonnull
public Set<Issue> findAllIssues()

Specified by:

findAllIssues in interface MonitoringService

findAllNodesWithAlerts

@Nonnull
public Set<String> findAllNodesWithAlerts()

Specified by:

findAllNodesWithAlerts in interface MonitoringService

findAllPluginsWithAlerts

@Nonnull
public Set<PluginDetails> findAllPluginsWithAlerts()

Specified by:

findAllPluginsWithAlerts in interface MonitoringService

getIssue

@Nonnull
public Issue getIssue(@Nonnull
 String issueId,
 @Nonnull
 Severity severity)

Specified by:

getIssue in interface IssueSupplier

getMonitor

@Nonnull
public Optional<ComponentMonitor> getMonitor(@Nonnull
 String componentId)

Specified by:

getMonitor in interface MonitoringService

internalStreamAlertCounts

public <T> T internalStreamAlertCounts(@Nonnull
 AlertCriteria criteria,
 @Nonnull
 PageCallback<? super AlertCount,T> callback,
 @Nonnull
 PageRequest pageRequest)

Description copied from interface: InternalMonitoringService

Gives unsecured access to MonitoringService.streamAlertCounts(AlertCriteria, PageCallback, PageRequest), to allow publishing of daily analytics

Specified by:

internalStreamAlertCounts in interface InternalMonitoringService

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface MonitoringService

onStart

public void onStart()

Specified by:

onStart in interface com.atlassian.sal.api.lifecycle.LifecycleAware

onStop

public void onStop()

Specified by:

onStop in interface com.atlassian.sal.api.lifecycle.LifecycleAware

streamAlerts

public <T> T streamAlerts(@Nonnull
 AlertCriteria criteria,
 @Nonnull
 PageCallback<? super Alert,T> callback,
 @Nonnull
 PageRequest pageRequest)

Specified by:

streamAlerts in interface MonitoringService

streamAlertCounts

public <T> T streamAlertCounts(@Nonnull
 AlertCriteria criteria,
 @Nonnull
 PageCallback<? super AlertCount,T> callback,
 @Nonnull
 PageRequest pageRequest)

Specified by:

streamAlertCounts in interface MonitoringService

streamAlertsWithElisions

public <T> T streamAlertsWithElisions(@Nonnull
 AlertCriteria criteria,
 @Nonnull
 PageCallback<? super AlertWithElisions,T> callback,
 @Nonnull
 PageRequest pageRequest)

Specified by:

streamAlertsWithElisions in interface MonitoringService

subscribe

@Nonnull
public String subscribe(@Nonnull
 AlertListener listener)

Specified by:

subscribe in interface MonitoringService

unsubscribe

public boolean unsubscribe(@Nonnull
 String subscriptionId)

Specified by:

unsubscribe in interface MonitoringService