Click or drag to resize

OutputAdapterBase Class

Represents the base class for any outgoing data stream.
Inheritance Hierarchy
SystemObject
  GSF.TimeSeries.AdaptersAdapterBase
    GSF.TimeSeries.AdaptersOutputAdapterBase

Namespace: GSF.TimeSeries.Adapters
Assembly: GSF.TimeSeries (in GSF.TimeSeries.dll) Version: 2.4.207-beta
Syntax
public abstract class OutputAdapterBase : AdapterBase, 
	IOutputAdapter, IAdapter, ISupportLifecycle, IDisposable, IProvideStatus
View Source

The OutputAdapterBase type exposes the following members.

Constructors
 NameDescription
Protected methodOutputAdapterBase Constructs a new instance of the OutputAdapterBase.
Top
Properties
 NameDescription
Public propertyAutoStart Gets or sets flag indicating if adapter should automatically start or otherwise connect on demand.
(Inherited from AdapterBase)
Protected propertyConnectionAttemptInterval Gets or sets the connection attempt interval, in milliseconds, for the data output adapter.
Public propertyConnectionInfo Gets connection info for adapter, if any.
(Inherited from AdapterBase)
Public propertyConnectionString Gets or sets key/value pair connection information specific to this AdapterBase.
(Inherited from AdapterBase)
Public propertyDataSource Gets or sets DataSet based data source available to this OutputAdapterBase.
(Overrides AdapterBaseDataSource)
Public propertyEnabled Gets or sets enabled state of this AdapterBase.
(Inherited from AdapterBase)
Public propertyID Gets or sets numeric ID associated with this AdapterBase.
(Inherited from AdapterBase)
Public propertyInitializationTimeout Gets or sets maximum time system will wait during Start for initialization.
(Inherited from AdapterBase)
Public propertyInitialized Gets or sets flag indicating if the adapter has been initialized successfully.
(Inherited from AdapterBase)
Public propertyInputMeasurementKeys Gets or sets primary keys of input measurements the AdapterBase expects, if any.
(Inherited from AdapterBase)
Public propertyInputSourceIDs Gets or sets Source values used to filter input measurements.
Protected propertyInternalProcessQueue Allows derived class access to internal processing queue.
Public propertyIsDisposed Gets a flag that indicates whether the object has been disposed.
(Inherited from AdapterBase)
Protected propertyLog Log messages generated by an adapter.
(Inherited from AdapterBase)
Public propertyMeasurementReportingInterval Gets or sets the measurement reporting interval.
(Inherited from AdapterBase)
Protected propertyMetadataRefreshOperation Gets the operation that calls ExecuteMetadataRefresh.
Public propertyName Gets or sets the name of this AdapterBase.
(Inherited from AdapterBase)
Public propertyOutputIsForArchive Gets the flag that determines if measurements sent to this OutputAdapterBase are destined for archival.
Public propertyOutputMeasurements Gets or sets output measurements that the AdapterBase will produce, if any.
Public propertyProcessedMeasurements Gets the total number of measurements handled thus far by the AdapterBase.
(Inherited from AdapterBase)
Public propertyProcessingInterval Gets or sets the desired processing interval, in milliseconds, for the output adapter.
(Overrides AdapterBaseProcessingInterval)
Public propertyRequestedInputMeasurementKeys Gets or sets input measurement keys that are requested by other adapters based on what adapter says it can provide.
Public propertyRequeueOnException Gets or sets whether or not to automatically place measurements back into the processing queue if an exception occurs while processing. Defaults to false.
Public propertyRunTime Gets the total amount of time, in seconds, that the adapter has been active.
(Inherited from AdapterBase)
Public propertySettings Gets settings DictionaryTKey, TValue parsed when ConnectionString was assigned.
(Inherited from AdapterBase)
Public propertyStartTime Gets the UTC time this AdapterBase was started.
(Inherited from AdapterBase)
Public propertyStartTimeConstraint Gets the start time temporal processing constraint defined by call to SetTemporalConstraint(String, String, String).
(Inherited from AdapterBase)
Public propertyStatus Returns the detailed status of the data input source. Derived classes should extend status with implementation specific information.
(Overrides AdapterBaseStatus)
Public propertyStopTime Gets the UTC time this AdapterBase was stopped.
(Inherited from AdapterBase)
Public propertyStopTimeConstraint Gets the stop time temporal processing constraint defined by call to SetTemporalConstraint(String, String, String).
(Inherited from AdapterBase)
Public propertySupportsTemporalProcessing Gets the flag indicating if this OutputAdapterBase implementation supports temporal processing.
(Overrides AdapterBaseSupportsTemporalProcessing)
Protected propertyUseAsyncConnect Gets flag that determines if the data output stream connects asynchronously.
Top
Methods
 NameDescription
Protected methodAttemptConnection Attempts to connect to data output stream.
Protected methodAttemptDisconnection Attempts to disconnect from data output stream.
Public methodDispose Releases all the resources used by the AdapterBase object.
(Inherited from AdapterBase)
Protected methodDispose(Boolean) Releases the unmanaged resources used by the OutputAdapterBase object and optionally releases the managed resources.
(Overrides AdapterBaseDispose(Boolean))
Public methodEqualsDetermines whether the specified object is equal to the current object.
(Inherited from Object)
Protected methodExecuteMetadataRefresh Executes the metadata refresh in a synchronous fashion.
Protected methodFinalize Releases the unmanaged resources before the AdapterBase object is reclaimed by GC.
(Inherited from AdapterBase)
Public methodFlush Blocks the current thread, if the OutputAdapterBase is connected, until all items in OutputAdapterBase queue are processed, and then stops processing.
Public methodGetHashCode Serves as a hash function for the current AdapterBase.
(Inherited from AdapterBase)
Public methodGetShortStatus Gets a short one-line status of this AdapterBase.
(Inherited from AdapterBase)
Public methodGetTypeGets the Type of the current instance.
(Inherited from Object)
Protected methodIncrementProcessedMeasurements Safely increments the total processed measurements.
(Inherited from AdapterBase)
Public methodInitialize Initializes OutputAdapterBase.
(Overrides AdapterBaseInitialize)
Protected methodMemberwiseCloneCreates a shallow copy of the current Object.
(Inherited from Object)
Protected methodOnConfigurationChanged Raises ConfigurationChanged event.
(Inherited from AdapterBase)
Protected methodOnConnected Called when data output source connection is established.
Protected methodOnDisconnected Called when data input source is disconnected.
Protected methodOnInputMeasurementKeysUpdated Raises InputMeasurementKeysUpdated event.
(Inherited from AdapterBase)
Protected methodOnOutputMeasurementsUpdated Raises OutputMeasurementsUpdated event.
(Inherited from AdapterBase)
Protected methodOnProcessException(Exception)Obsolete.
Raises the ProcessException event.
(Inherited from AdapterBase)
Protected methodOnProcessException(MessageLevel, Exception, String, MessageFlags) Raises the ProcessException event.
(Inherited from AdapterBase)
Protected methodOnStatusMessage(String)Obsolete.
Raises the StatusMessage event.
(Inherited from AdapterBase)
Protected methodOnStatusMessage(String, Object)Obsolete.
Raises the StatusMessage event with a formatted status message.
(Inherited from AdapterBase)
Protected methodOnStatusMessage(MessageLevel, String, String, MessageFlags) Raises the StatusMessage event and sends this data to the Logger.
(Inherited from AdapterBase)
Protected methodOnUnprocessedMeasurements Raises the UnprocessedMeasurements event.
Protected methodProcessMeasurements Serializes measurements to data output stream.
Public methodQueueMeasurementForProcessing Queues a single measurement for processing. Measurement is automatically filtered to the defined InputMeasurementKeys.
Public methodQueueMeasurementsForProcessing Queues a collection of measurements for processing. Measurements are automatically filtered to the defined InputMeasurementKeys.
Public methodRefreshMetadata Initiates request for metadata refresh for OutputAdapterBase, if implemented.
Public methodRemoveMeasurements This removes a range of measurements from the internal measurement queue.
Public methodSetInitializedState Manually sets the initialized state of the AdapterBase.
(Inherited from AdapterBase)
Public methodSetTemporalConstraint Defines a temporal processing constraint for the adapter.
(Inherited from AdapterBase)
Public methodStart Starts this OutputAdapterBase and initiates connection cycle to data output stream.
(Overrides AdapterBaseStart)
Public methodStop Stops this OutputAdapterBase and disconnects from data output stream.
(Overrides AdapterBaseStop)
Public methodToStringReturns a string that represents the current object.
(Inherited from Object)
Top
Events
 NameDescription
Public eventConfigurationChanged Event is raised when adapter is aware of a configuration change.
(Inherited from AdapterBase)
Public eventDisposed Event is raised when AdapterBase is disposed.
(Inherited from AdapterBase)
Public eventInputMeasurementKeysUpdated Event is raised when InputMeasurementKeys are updated.
(Inherited from AdapterBase)
Public eventOutputMeasurementsUpdated Event is raised when OutputMeasurements are updated.
(Inherited from AdapterBase)
Public eventProcessException Event is raised when there is an exception encountered while processing.
(Inherited from AdapterBase)
Public eventStatusMessage Provides status messages to consumer.
(Inherited from AdapterBase)
Public eventUnprocessedMeasurements Event is raised every five seconds allowing host to track total number of unprocessed measurements.
Top
Extension Methods
 NameDescription
Public Extension MethodGetEnumValueOrDefault Gets the enumeration constant for value, if defined in the enumeration, or a default value.
(Defined by EnumExtensions)
Public Extension MethodGetEnumValueOrDefaultT Gets the enumeration constant for this value, if defined in the enumeration, or a default value.
(Defined by EnumExtensions)
Public Extension MethodGetMeasurementRecord Gets measurement record, creating it if needed.
(Defined by MetadataHelpers)
Public Extension MethodGetParentDevice Gets ID of parent device, creating or updating record if needed, for the current IAdapter instance.
(Defined by MetadataHelpers)
Public Extension MethodInputMeasurementKeys Returns the MeasurementKey values of the IAdapter input measurements.
(Defined by IAdapterExtensions)
Public Extension MethodLookupDevice Looks up associated device acronym and ID from provided signalID.
(Defined by MetadataHelpers)
Public Extension MethodLookupMeasurementKey Looks up or creates measurement key based on provided signalID.
(Defined by MetadataHelpers)
Public Extension MethodLookupPointTag Looks up point tag name from provided signalID.
(Defined by MetadataHelpers)
Public Extension MethodLookupSignalReference Looks up signal reference from provided signalID.
(Defined by MetadataHelpers)
Public Extension MethodOnConfigurationChanged Notifies host system of configuration changes.
(Defined by MetadataHelpers)
Public Extension MethodOutputMeasurementKeys Returns the MeasurementKey values of the IAdapter output measurements.
(Defined by IAdapterExtensions)
Public Extension MethodPointTagExists Determines if pointTag exists in local configuration.
(Defined by MetadataHelpers)
Public Extension MethodSignalIDExists Determines if signalID exists in local configuration.
(Defined by MetadataHelpers)
Public Extension MethodSignalReferenceExists Determines if signalReference exists in local configuration.
(Defined by MetadataHelpers)
Public Extension MethodTemporalConstraintIsDefined Returns true if IAdapter has a temporal constraint defined, i.e., either StartTimeConstraint or StopTimeConstraint is not set to its default value.
(Defined by IAdapterExtensions)
Public Extension MethodWaitForSignalsToLoad Waits for signalIDs to be loaded in system configuration.
(Defined by MetadataHelpers)
Top
Remarks
This base class acts as a measurement queue so that output adapters can temporarily go offline without losing any measurements to be processed. Derived classes are expected to override ProcessMeasurements(IMeasurement) to handle queued measurements.
See Also