Package com.inductiveautomation.eventstream.designer.ui.viewmodel.diagnostics

Class EventStreamDiagnosticsProvider

java.lang.Object

com.inductiveautomation.eventstream.designer.ui.viewmodel.diagnostics.EventStreamDiagnosticsProvider

All Implemented Interfaces:

Disposable

public class EventStreamDiagnosticsProvider
extends Object
implements Disposable

Curates and publish diagnostics information about an event stream at 1 sec intervals. This is typically used to update the FlowPanel in the EventStreamResourceEditorPanel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	EventStreamDiagnosticsProvider.DiagnosticsData

Constructor Summary

Constructors

Constructor	Description
EventStreamDiagnosticsProvider(String projectName, String resourceFolderPath, EventStreamRpc rpc)

Method Summary

Modifier and Type	Method	Description
void	addDataListener(DataEventListener<EventStreamDiagnosticsProvider,EventStreamDiagnosticsProvider.DiagnosticsData> listener)
void	dispose()
EventStreamDiagnostics	getDiagnostics()
void	initialize(PropertyPublisherReadOnly<SubtextStateInfo> stateInfo)
void	removeDataListener(DataEventListener<EventStreamDiagnosticsProvider,EventStreamDiagnosticsProvider.DiagnosticsData> listener)

Methods inherited from class java.lang.Object

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

Constructor Details

EventStreamDiagnosticsProvider

public EventStreamDiagnosticsProvider(String projectName,
 String resourceFolderPath,
 EventStreamRpc rpc)

Parameters:

projectName - The projectName to retrieve diagnostics for

resourceFolderPath - The resourceFolderPath to retrieve diagnostics for

rpc - The EventStreamRpc to use to retrieve diagnostics

Method Details

initialize

public void initialize(PropertyPublisherReadOnly<SubtextStateInfo> stateInfo)

Parameters:

stateInfo - This is used to regulate if the polling timer is running or not

getDiagnostics

public EventStreamDiagnostics getDiagnostics()

Returns:

The most recent EventStreamDiagnostics retrieved from the Gateway

addDataListener

public void addDataListener(DataEventListener<EventStreamDiagnosticsProvider,EventStreamDiagnosticsProvider.DiagnosticsData> listener)

removeDataListener

public void removeDataListener(DataEventListener<EventStreamDiagnosticsProvider,EventStreamDiagnosticsProvider.DiagnosticsData> listener)

dispose

public void dispose()

Specified by:

dispose in interface Disposable