Implements a (hopefully) data provider agnostic store for keeping ECOP data in an RDBMS. The goal here is to provide a data store implementation that can be used to scale ECOP from its current scope to an enterprise scope by altering the RDBMS underneath. More...

Inheritance diagram for Apac.Data.FirebirdStore:

Protected Member Functions
override DbCommand	OnFormulateMergeSetting (DbConnection connection, string name, string value, short configid)
	Builds a command that updates the settings. More...

override DbCommand	OnFormulateGetConfigId (DbConnection connection, string name)
	Builds a command that returns the identifier for the configuration with name . More...

override DbCommand	OnFormulateCreateConfig (DbConnection connection, string name)
	Builds a command that creates a new configuration instance with name . More...

override DbCommand	OnFormulateDeleteConfig (DbConnection connection, short id)
	Builds a command that deletes the configuration instance with id . More...

override DbCommand	OnFormulateGetEcopConfig (DbConnection connection, short id)
	Builds a command that returns the requested configuration instance (shallow). More...

override DbCommand	OnFormulateGetEcopConfig (DbConnection connection, string name)
	Builds a command that returns the requested configuration instance (shallow). More...

override DbCommand	OnFormulateGetActiveEcopConfig (DbConnection connection)
	Builds a command that returns the active configuration instance (shallow). More...

override DbCommand	OnFormulateFetchDailyAvgs (DbConnection connection, MeasurementQueryCriteria criteria)
	Builds a command that returns all daily averages matching the conditions in criteria . More...

override DbCommand	OnFormulateFetchFiveMinAvgs (DbConnection connection, MeasurementQueryCriteria criteria)
	Builds a command that returns all five-minute averages matching the conditions in criteria . More...

override DbCommand	OnFormulateFetchHourlyAvgs (DbConnection connection, MeasurementQueryCriteria criteria)
	Builds a command that returns all hourly averages matching the conditions in criteria . More...

override DbCommand	OnFormulateFetchMeasurements (DbConnection connection, MeasurementQueryCriteria criteria)
	Builds a command that returns all measurements matching the conditions in criteria . More...

override DbCommand	OnFormulateFetchMonthlyAvgs (DbConnection connection, MeasurementQueryCriteria criteria)
	Builds a command that returns all monthly averages matching the conditions in criteria . More...

override DbCommand	OnFormulateCheckForManagedElement (DbConnection connection, uint id)
	Builds a command that returns the count of elements with id . More...

override DbCommand	OnFormulateDeleteManagedElement (DbConnection connection, Apac.Monitoring.ManagedElement element)
	Builds a command that removes element from the data store. More...

override DbCommand	OnFormulateDeleteMeasurements (DbConnection connection, Monitoring.ManagedElement element)
	Should build a command that removes measurements for element from the data store. More...

override DbCommand	OnFormulateDeleteWeightedAverages (DbConnection connection, Monitoring.ManagedElement element)
	Should build a command that removes averages for element from the data store. More...

override DbCommand	OnFormulateInsertManagedElement (DbConnection connection, Apac.Monitoring.ManagedElement element)
	Builds a command that insert the managed element. More...

override DbCommand	OnFormulateUpdateManagedElement (DbConnection connection, Apac.Monitoring.ManagedElement element)
	Builds a command that update the managed element. More...

override DbCommand	OnFormulateGetEcopConfigs (DbConnection connection)
	Builds a command that returns all configuration instances (shallow). More...

override DbCommand	OnFormulateGetEcopSettings (DbConnection connection, short configId)
	Builds a command that returns all settings for the configuration instance with configId . More...

override DbCommand	OnFormulateFetchMeasurementMappings (DbConnection connection, short configid)
	Builds a command that returns the data set containing all mappings in configuration 'configid ', and the associated managed element data (using a JOIN). More...

override DbCommand	OnFormulateDeleteMapping (DbConnection connection, Apac.Monitoring.MeasurementMapping mapping)
	Builds a command that deletes the mapping specified. More...

override DbCommand	OnFormulateInsertMeasurementMapping (DbConnection connection, Apac.Monitoring.MeasurementMapping mapping)
	Builds a command that creates the mapping specified. More...

override DbCommand	OnFormulateUpdateMeasurementMapping (DbConnection connection, Apac.Monitoring.MeasurementMapping oldmapping, Apac.Monitoring.MeasurementMapping newmapping)
	Builds a command that updates the mapping specified. More...

override DbCommand	OnFormulateUpdateMeasurementMapping (DbConnection connection, Apac.Monitoring.MeasurementMapping mapping)
	Builds a command that updates the mapping specified, using the ID. More...

override DbCommand	OnFormulateCheckForMeasurementMapping (DbConnection connection, short configid, uint elementid, ulong sensorid, uint sourceElementId, decimal constantValue, string inputTag)
	Should build a command that returns the count of mappings matching configid , elementid , sensorid , sourceElementId , constantValue , and inputTag ,. More...

override DbCommand	OnFormulateDeleteMappings (DbConnection connection, Apac.Monitoring.ManagedElement element)
	Builds a command that removes all Monitoring.MeasurementMappings associated with element . More...

override DbCommand	OnFormulateFetchManagedElement (DbConnection connection, uint id)
	Builds a command that returns the data set containing all columns for the requested managed element. More...

override DbCommand	OnFormulateFetchManagedElements (DbConnection connection)
	Builds a command that returns the data set containing all columns for all managed elements in the data store. More...

override DbCommand	OnFormulateFetchMappedManagedElements (DbConnection connection, short configid)
	Builds a command that returns the data set containing all columns for all managed elements in the data store that are mapping within the given configuration. More...

override DbCommand	OnFormulateInsertMeasurementMappings (DbConnection connection, Apac.Collections.MeasurementMappingCollection mappings)
	Builds a command that insert the set of mappings. More...

override DbCommand	OnFormulateUpdateMeasurementMappings (DbConnection connection, Apac.Collections.MeasurementMappingCollection mappings)
	Builds a command that updates the set of mappings. More...

override DbCommand	OnFormulateSetActiveConfig (DbConnection connection, short id)
	Should 'flip the active bit' to the configuration with id . More...

override DbCommand	OnFormulateWriteDailyAvgs (DbConnection connection, Apac.Monitoring.WeightedMeasurementAvgs avgs)
	Builds a command that writes the averages in avgs . More...

override DbCommand	OnFormulateWriteFiveMinAvgs (DbConnection connection, Apac.Monitoring.WeightedMeasurementAvgs avgs)
	Builds a command that writes the averages in avgs . More...

override DbCommand	OnFormulateWriteHourlyAvgs (DbConnection connection, Apac.Monitoring.WeightedMeasurementAvgs avgs)
	Builds a command that writes the averages in avgs . More...

override DbCommand	OnFormulateWriteMeasurements (DbConnection connection, Apac.Monitoring.Measurements measurements)
	Builds a command that writes the measurements in measurements . More...

override DbCommand	OnFormulateWriteMonthlyAvgs (DbConnection connection, Apac.Monitoring.WeightedMeasurementAvgs avgs)
	Builds a command that writes the averages in avgs . More...

override DbCommand	OnFormulateHasAverages (DbConnection connection, uint elementid)
	Builds a ccmmand that returns at least one row if the given element has averages in the data store. More...

override DbCommand	OnFormulateHasMeasurements (DbConnection connection, uint elementid)
	Builds a ccmmand that returns at least one row if the given element has measurements in the data store. More...

override DbCommand	OnFormulateCheckForThreshold (DbConnection connection, uint elementId)
	Builds a command that returns the count of thresholds with the element id. More...

override DbCommand	OnFormulateFetchThresholds (DbConnection connection, uint elementId)
	Builds a command that returns all thresholds with the element id. More...

override DbCommand	OnFormulateHasThresholds (DbConnection connection, Apac.Monitoring.EventDef eventDef)
	Builds a command that returns at least one threshold fo the event def, if it exists. More...

override DbCommand	OnFormulateInsertThreshold (DbConnection connection, Apac.Monitoring.Threshold threshold)
	Builds a command that inserts the threshold. More...

override DbCommand	OnFormulateUpdateThreshold (DbConnection connection, Apac.Monitoring.Threshold threshold)
	Builds a command that updates the threshold. More...

override DbCommand	OnFormulateDeleteThresholds (DbConnection connection, Apac.Monitoring.ManagedElement element)
	Builds a command that deletes all thresholds associated to the element. More...

override DbCommand	OnFormulateCheckForEventDef (DbConnection connection, uint eventDefId)
	Builds a command that returns the count of event defs with the id. More...

override DbCommand	OnFormulateFetchEventDef (DbConnection connection, uint eventDefId)
	Builds a command that returns the event def with the id. More...

override DbCommand	OnFormulateInsertEventDef (DbConnection connection, Apac.Monitoring.EventDef eventDef)
	Builds a command that inserts the event def. More...

override DbCommand	OnFormulateUpdateEventDef (DbConnection connection, Apac.Monitoring.EventDef eventDef)
	Builds a command that updates the event def. More...

override DbCommand	OnFormulateFetchEventDefs (DbConnection connection)
	Builds a command that returns all event defs. More...

override DbCommand	OnFormulateDeleteEventDef (DbConnection connection, Apac.Monitoring.EventDef eventDef)
	Builds a command the deletes the event def. More...

override DbCommand	OnFormulateHasActions (DbConnection connection, Apac.Monitoring.EventDef eventDef)
	Builds a command that returns at least one action for the event def, if it exists. More...

override DbCommand	OnFormulateFetchActions (DbConnection connection, uint elementId, uint eventId)
	Builds a command that returns all actions for the given element and event. More...

override DbCommand	OnFormulateInsertAction (DbConnection connection, Apac.Monitoring.ActionDef action)
	Builds a command that inserts the action. More...

override DbCommand	OnFormulateUpdateAction (DbConnection connection, Apac.Monitoring.ActionDef action)
	Builds a command that updates the action. More...

override DbCommand	OnFormulateCheckForAction (DbConnection connection, uint elementId, uint eventId)
	Builds a command that returns the count of actions with the element and event def ids. More...

override DbCommand	OnFormulateDeleteAction (DbConnection connection, Apac.Monitoring.ActionDef action)
	Builds a command the deletes the action. More...

override DbCommand	OnFormulateDeleteActions (DbConnection connection, Apac.Monitoring.EventDef eventDef)
	Builds a command the deletes the actions associated to the event def. More...

override DbCommand	OnFormulateDeleteActions (DbConnection connection, Apac.Monitoring.ManagedElement element)
	Builds a command the deletes the actions associated to the element. More...

override DbCommand	OnFormulateFetchAlerts (DbConnection connection, bool activeOnly)
	Builds a command that returns all alerts, possibly filtered by the active state (not cleared). More...

override DbCommand	OnFormulateInsertOrUpdateAlert (DbConnection connection, Apac.Monitoring.Alert alert)
	Builds a command that inserts the alert. More...

override DbCommand	OnFormulateClearAlert (DbConnection connection, Apac.Monitoring.Alert alert)
	Builds a command that updates the cleared time of the alert. More...

override DbCommand	OnFormulateFetchSensor (DbConnection connection, uint id)
	Should build a command that returns the requested sensor. More...

override DbCommand	OnFormulateFetchSensors (DbConnection connection, short configId, bool activeOnly)
	Builds a command that returns all sensor definitions in the specified configuration. More...

override DbCommand	OnFormulateInsertSensor (DbConnection connection, Monitoring.Sensor sensor)
	Builds a command that inserts the given sensor definition. More...

override DbCommand	OnFormulateUpdateSensor (DbConnection connection, Monitoring.Sensor sensor)
	Builds a command that updates the given sensor definition. More...

override DbCommand	OnFormulateCheckForSensor (DbConnection connection, uint id)
	Builds a command that returns the count of sensors with the given id. More...

override DbCommand	OnFormulateDeleteSensor (DbConnection connection, uint id)
	Builds a command that deletes the sensor with the given id. More...

override DbCommand	OnFormulatePruneMeasurements (DbConnection connection, DateTime cutoff)
	Builds a command that deletes measurements, for all elements, that are older than cutoff . More...

override DbCommand	OnFormulateGetUsers (DbConnection connection, Logic.PredicateSet filter)
	Builds a command the retrieves all users. More...

override DbCommand	OnFormulateInsertUser (DbConnection connection, Auth.User user)
	Builds a command the inserts the given user definition. More...

override DbCommand	OnFormulateUpdateUser (DbConnection connection, Auth.User user)
	Builds a command the updates the given user definition. More...

override DbCommand	OnFormulateDeleteUser (DbConnection connection, int id)
	Builds a command the deletes the given user definition. More...

override DbCommand	OnFormulateGetNotifGrps (DbConnection connection, Logic.PredicateSet filter)
	Builds a command the retrieves notification groups that match filter . More...

override DbCommand	OnFormulateGetNotifGrpXrefs (DbConnection connection, Auth.User user)
	Builds a command that retrieves notification groups matching the given filter. More...

override DbCommand	OnFormulateInsertNotifGrp (DbConnection connection, Auth.NotificationGroup ng)
	Builds a command the inserts the given notification group definition. More...

override DbCommand	OnFormulateUpdateNotifGrp (DbConnection connection, Auth.NotificationGroup ng)
	Builds a command the updates the given notification group definition. More...

override DbCommand	OnFormulateDeleteNotifGrp (DbConnection connection, short id)
	Builds a command the deletes the given notification group definition. More...

override DbCommand	OnFormulateGetRoles (DbConnection connection, Auth.User user)
	Builds a command that retrieves roles matching the given filter. More...

override DbCommand	OnFormulatePersistUserRoleXrefs (DbConnection connection, Auth.User user)
	Builds a command the persists the roles (xrefs) for the given user definition. More...

override DbCommand	OnFormulatePersistUserNotifGroupXrefs (DbConnection connection, Auth.User user)
	Builds a command the persists the notification groups (xrefs) for the given user definition. More...

Protected Member Functions inherited from Apac.Data.DatabaseStore
override void	OnInitializeDataStore (DataStoreConfig config)
	Called when [initialize data store]. More...

override TimeTrackingList< WeightedMeasurementAvgs >	OnFetchDailyAverages (MeasurementQueryCriteria criteria)
	Called when [fetch daily averages]. More...

override TimeTrackingList< WeightedMeasurementAvgs >	OnFetchFiveMinuteAverages (MeasurementQueryCriteria criteria)
	Called when [fetch five minute averages]. More...

override TimeTrackingList< WeightedMeasurementAvgs >	OnFetchHourlyAverages (MeasurementQueryCriteria criteria)
	Called when [fetch hourly averages]. More...

override TimeTrackingList< Measurements >	OnFetchMeasurements (MeasurementQueryCriteria criteria)
	Called when [fetch measurements]. More...

override TimeTrackingList< WeightedMeasurementAvgs >	OnFetchMonthlyAverages (MeasurementQueryCriteria criteria)
	Called when [fetch monthly averages]. More...

override void	OnWriteDailyAvgs (WeightedMeasurementAvgs averages)
	Called when [write daily avgs]. More...

override void	OnWriteFiveMinuteAvgs (WeightedMeasurementAvgs averages)
	Called when [write five minute avgs]. More...

override void	OnWriteHourlyAvgs (WeightedMeasurementAvgs averages)
	Called when [write hourly avgs]. More...

override void	OnWriteMeasurements (Measurements measurements)
	Called when [write measurements]. More...

override void	OnWriteMonthlyAvgs (WeightedMeasurementAvgs averages)
	Called when [write monthly avgs]. More...

override void	OnPruneRawMeasurements (DateTime cutoffDay)
	Called when [prune raw measurements]. More...

override void	OnOpen ()
	Called when [open]. More...

override void	OnClose ()
	Called when [close]. More...

override void	OnWriteAlerts (Alerts alerts)
	Called when [write alerts]. More...

override Alerts	OnRetrieveAlerts (bool activeOnly)
	Called when [retrieve alerts]. More...

virtual void	updateMeasurementCache (Measurements measurements)
	Updates the measurement cache. More...

virtual void	OnSettingsChanged ()
	Called when [settings changed]. More...

abstract DbCommand	OnFormulateDeleteMeasurements (DbConnection connection, ManagedElement element)
	Should build a command that removes measurements for element from the data store. More...

abstract DbCommand	OnFormulateDeleteWeightedAverages (DbConnection connection, ManagedElement element)
	Should build a command that removes averages for element from the data store. More...

abstract DbCommand	OnFormulateUpdateSensor (DbConnection connection, Sensor sensor)
	Should build a command that updates the given sensor definition. More...

abstract DbCommand	OnFormulateInsertSensor (DbConnection connection, Sensor sensor)
	Should build a command that inserts the given sensor definition. More...

abstract DbCommand	OnFormulateInsertUser (DbConnection connection, User user)
	Should build a command the inserts the given user definition. More...

abstract DbCommand	OnFormulateUpdateUser (DbConnection connection, User user)
	Should build a command the updates the given user definition. More...

abstract DbCommand	OnFormulateGetUsers (DbConnection connection, PredicateSet filter)
	Should build a command the retrieves all users. More...

abstract DbCommand	OnFormulatePersistUserNotifGroupXrefs (DbConnection connection, User user)
	Should build a command the persists the notification groups (xrefs) for the given user definition. More...

abstract DbCommand	OnFormulatePersistUserRoleXrefs (DbConnection connection, User user)
	Should build a command the persists the roles (xrefs) for the given user definition. More...

abstract DbCommand	OnFormulateInsertNotifGrp (DbConnection connection, NotificationGroup ng)
	Should build a command the inserts the given notification group definition. More...

abstract DbCommand	OnFormulateUpdateNotifGrp (DbConnection connection, NotificationGroup ng)
	Should build a command the updates the given notification group definition. More...

abstract DbCommand	OnFormulateGetNotifGrpXrefs (DbConnection connection, Auth.User user)
	Should build a command that retrieves notification groups for the given user. More...

abstract DbCommand	OnFormulateGetNotifGrps (DbConnection connection, PredicateSet filter)
	Should build a command the retrieves notification groups that match filter . More...

abstract DbCommand	OnFormulateGetRoles (DbConnection connection, User user)
	Should build a command that retrieves roles for the given user. More...

void	addParam (DbCommand cmd, string name, System.Data.DbType type, object value)
	Adds the parameter. More...

void	addParam (DbCommand cmd, string name, System.Data.DbType type, object value, System.Data.ParameterDirection direction)
	Adds the parameter. More...

Protected Member Functions inherited from Apac.Data.ThreadedMeasurementStore
override void	OnInitialize (Apac.Configuration.SupervisableConfig config)
	Prompts the supervisable component to initialize itself. More...

override void	OnResolveReferences ()
	Called when the supervisable component needs to resolve its runtime references to other components. More...

override void	OnCheckReferencesStates ()
	Called when the supervisable component needs to check the state of its runtime reference components. More...

override void	OnStart ()
	Prompts the supervisable component to start functioning. More...

override void	OnStop ()
	Prompts the supervisable component to stop functioning. More...

abstract void	OnInitializeDataStore (Configuration.DataStoreConfig config)

virtual void	Dispose (bool disposing)

Protected Member Functions inherited from Apac.Supervisable
abstract void	OnInitialize (Apac.Configuration.SupervisableConfig config)
	Called when the supervisable component is intitialized. More...

virtual void	OnStarting ()
	Called when the supervisable component is about to start. This differs from handling OnStart in that this method is called on the supervisor's thread, whereas Start is called on a new thread. Subclasses may override this to do work that is considered initialization work that should be done before all component threads are started. More...

virtual void	OnStateChanging (SupervisableState currentState, SupervisableState newState)
	Call chain for state changing notification. More...

virtual void	OnStateChanged (SupervisableState previousState, SupervisableState newState)
	Call chain for state changed notification. More...

virtual void	OnException (Exception ex)
	Call chain for exception notification. More...

void	SetState (SupervisableState newState)
	Changes the state of the controller to the new state. More...

virtual void	OnStateChangeStarting ()

virtual void	OnStateChangeRunning ()

virtual void	OnStateChangeStopping ()

virtual void	OnStateChangeStopped ()

virtual void	OnStateChangeInitializing ()

virtual void	OnStateChangeInitialized ()

virtual void	OnStateChangeErrored ()

virtual void	OnStateChangeImpaired ()

void	HandleException (string message, Exception e)
	Deals with the details of handling exceptions captured by the controller. More...

void	ResetException ()
	Allows subclasses to reset the last exception to an empty state. More...

void	HandleImpairment (string message, Exception e)
	Deals with the details of handling non-critical problems captured by the controller. More...

Additional Inherited Members
Public Member Functions inherited from Apac.Data.DatabaseStore
List< Threshold >	GetThresholds (uint elementId)
	Gets the thresholds. More...

bool	PersistThreshold (Threshold threshold)
	Persists the threshold. More...

EventDef	GetEventDef (uint eventId)
	Gets the event def. More...

List< EventDef >	GetEventDefs ()
	Gets all event defs. More...

bool	PersistEventDef (EventDef eventDef)
	Persists the event def. More...

void	DeleteEventDef (EventDef eventDef)
	Deletes the event def. More...

List< ActionDef >	GetActions (uint elementId, uint eventId)
	Gets the actions. More...

List< ActionDef >	GetActions ()
	Gets all actions. More...

bool	PersistAction (ActionDef action)
	Persists the action. More...

void	DeleteAction (ActionDef action)
	Deletes the action. More...

void	DeleteActions (EventDef eventDef)
	Deletes the actions associated with the event def. More...

void	DeleteSensor (Sensor sensor)
	Deletes the sensor. More...

void	PersistSensor (Sensor sensor)
	Perists the sensor. More...

void	ActivateCurrentConfiguration ()
	Promotes configuration changes that have been persisted to the runtime environment. This allows simple edits by the user to result in atomic commits of each change without reloading the entire system before all edits are complete. More...

void	SaveConfiguration (Apac.Settings.Configuration newConfig, bool activate)
	Saves the given configuration to the data store. More...

bool	PersistManagedElement (Apac.Monitoring.ManagedElement element)
	Creates or updates the given element in the datastore for use in setting up mappings to incoming data. More...

void	DeleteManagedElement (Apac.Monitoring.ManagedElement element)
	Removes the given element from the datastore. More...

List< ManagedElement >	GetManagedElements ()
	Retrieves the managed elements in the system. More...

Apac.Monitoring.ManagedElement	GetManagedElement (uint id)
	Retrieves the managed element specified by id . More...

bool	PersistMeasurementMapping (MeasurementMapping mapping, MeasurementMapping oldmapping)
	Should write the given mapping to the store. More...

bool	PersistMeasurementMappings (Apac.Collections.MeasurementMappingCollection mappings)
	Writes the given mappings to the data store. More...

bool	ChangeActiveConfiguration (string name)
	Changes the active set of mappings to be the one with the name name . More...

Apac.Settings.Configuration	GetConfiguration (string name)
	Gets the configuration. More...

Apac.Settings.Configuration	GetConfiguration (short id)
	Gets the configuration. More...

Apac.Collections.MeasurementMappingCollection	GetMeasurementMappings (short configid)
	Gets the mappings for configuration with ID of configid . More...

Apac.Collections.MeasurementMappingCollection	GetMeasurementMappings (string name)
	Gets the mappings for configuration named name . More...

List< Apac.Monitoring.MeasurementMapping >	LookupMappings (uint elementId)
	Gets a mapping for the requested element from the active mapping set. More...

List< Apac.Monitoring.MeasurementMapping >	LookupMappings (MeasurementSource source)
	Looks up the mapping by sensor source. More...

void	DeleteConfiguration (string name)
	Deletes the configuration with name . More...

void	DeleteMeasurementMapping (MeasurementMapping mapping)
	Deletes the given mapping from the store. More...

Apac.Collections.MeasurementMappingCollection	CloneMeasurementMappings (string origName, string copyName)
	Creates a copy of the mappings named origName in a configuration named copyName . More...

Sensor	GetSensor (uint id)
	Gets the sensor with the specified ID. More...

List< Sensor >	GetSensors (short configId, bool activeOnly)
	Gets all sensors. More...

List< Auth.User >	GetUsers (Logic.PredicateSet filter)
	Gets the users that match filter . More...

Logic.WhyBool	CreateUser (Auth.User user)
	Creates the user in the data store. This routine assumes the the data is valid and the password has already been hashed and salted and applied to the user object. More...

Logic.WhyBool	DeleteUser (int id)
	Deletes the user with id . More...

Logic.WhyBool	UpdateUser (Auth.User user)
	Updates the user and associations to look like user . More...

List< Auth.NotificationGroup >	GetNotificationGroups ()
	Gets all notification groups. More...

Logic.WhyBool	CreateNotificationGroup (string name, ref Auth.NotificationGroup group)
	Creates a notification group with name . More...

WhyBool	UpdateNotificationGroup (NotificationGroup ng)
	Updates the notificaton group. More...

Logic.WhyBool	DeleteNotificationGroup (short id)
	Deletes the notification group with id . More...

Public Member Functions inherited from Apac.Data.ThreadedMeasurementStore
	ThreadedMeasurementStore ()
	Default constructor. More...

override object	InitializeLifetimeService ()
	Obtains a lifetime service object to control the lifetime policy for this instance. More...

void	RecordAlerts (Alerts alerts)
	Should records the alerts. More...

void	RecordAlerts (Alerts alerts, StoreAccessCompleteHandler callout)
	Should records the alerts, will call back on callout . More...

void	RetrieveAlerts (bool activeOnly, StoreAccessCompleteHandler callout)
	Should retrieve the alerts. More...

void	RecordMeasurements (Measurements measurements)
	Enqueues the given averages for the raw data thread to record. More...

void	RecordMeasurements (Measurements measurements, StoreAccessCompleteHandler callout)
	Enqueues the given averages for the raw data thread to record. More...

void	RecordFiveMinAverages (WeightedMeasurementAvgs averages)
	Enqueues the given averages for the 5-minute thread to record. More...

void	RecordFiveMinAverages (WeightedMeasurementAvgs averages, StoreAccessCompleteHandler callout)
	Enqueues the given averages for the 5-minute thread to record. More...

void	RecordHourlyAverages (WeightedMeasurementAvgs averages)
	Enqueues the given averages for the hourly thread to record. More...

void	RecordHourlyAverages (WeightedMeasurementAvgs averages, StoreAccessCompleteHandler callout)
	Enqueues the given averages for the hourly thread to record. More...

void	RecordDailyAverages (WeightedMeasurementAvgs averages)
	Enqueues the given averages for the daily thread to record. More...

void	RecordDailyAverages (WeightedMeasurementAvgs averages, StoreAccessCompleteHandler callout)
	Enqueues the given averages for the daily thread to record. More...

void	RecordMonthlyAverages (WeightedMeasurementAvgs averages)
	Enqueues the given averages for the monthly thread to record. More...

void	RecordMonthlyAverages (WeightedMeasurementAvgs averages, StoreAccessCompleteHandler callout)
	Enqueues the given averages for the monthly thread to record. More...

TimeTrackingList< Measurements >	FetchMeasurements (MeasurementQueryCriteria criteria)
	Retrieves measurements according to the given criteria. More...

TimeTrackingList< Monitoring.WeightedMeasurementAvgs >	FetchFiveMinuteAverages (MeasurementQueryCriteria criteria)
	Retrieves five minute averages according to the given criteria. More...

TimeTrackingList< Monitoring.WeightedMeasurementAvgs >	FetchHourlyAverages (MeasurementQueryCriteria criteria)
	Retrieves hourly averages according to the given criteria. More...

TimeTrackingList< Monitoring.WeightedMeasurementAvgs >	FetchDailyAverages (MeasurementQueryCriteria criteria)
	Retrieves daily averages according to the given criteria. More...

TimeTrackingList< Monitoring.WeightedMeasurementAvgs >	FetchMonthlyAverages (MeasurementQueryCriteria criteria)
	Retrieves monthly averages according to the given criteria. More...

void	Initialize (Apac.Configuration.DataStoreConfig config)
	Starts the inheritance call chain for initializing the data store. More...

void	Open ()
	Prompts the store to prepare for recording and fetching data. More...

void	Close ()
	Prompts the store to clean up its resources used for recording and fetching data. More...

void	Dispose ()

Public Member Functions inherited from Apac.Supervisable
void	Initialize (Apac.Configuration.SupervisableConfig config, Supervisors.ISupervisor supervisor)
	Initializes the controller from configuration. More...

void	ResolveReferences ()
	Resolves any references this component might hold to other supervisable components. More...

void	CheckReferencesStates ()
	Checks the states of referenced components to be sure they are satisfactory for this component's operation. More...

void	Starting ()
	Signals that the component will be starting on its own thread. This implementation uses this opportunity to CheckReferencesStates, change state to Starting, and signal subclasses with OnStarting. More...

void	Start ()
	Starts the component. More...

void	Stop ()
	Stops the component. More...

Public Member Functions inherited from Apac.ISupervisable
void	Initialize (Apac.Configuration.SupervisableConfig config, Supervisors.ISupervisor exec)
	Initializes the component with the given SupervisableConfig (or derivative) and ISupervisor. More...

Public Member Functions inherited from Apac.Data.IDataStore
void	Initialize (Configuration.DataStoreConfig config)

Public Member Functions inherited from Apac.Data.IMeasurementStore
void	RecordAlerts (Monitoring.Alerts alerts)
	Should records the alerts. More...

void	RecordAlerts (Monitoring.Alerts alerts, StoreAccessCompleteHandler callout)
	Should records the alerts, will call back on callout . More...

void	RecordMeasurements (Monitoring.Measurements measurements)
	Should record raw measurements in the given bucket. More...

void	RecordFiveMinAverages (Monitoring.WeightedMeasurementAvgs averages)
	Should record the given averages to the given 5-minute store. More...

void	RecordHourlyAverages (Monitoring.WeightedMeasurementAvgs averages)
	Should record the given averages to the given 5-minute store. More...

void	RecordDailyAverages (Monitoring.WeightedMeasurementAvgs averages)
	Should record the given averages to the given daily store. More...

void	RecordMonthlyAverages (Monitoring.WeightedMeasurementAvgs averages)
	Should record the given averages to the given monthy store. More...

void	RecordMeasurements (Monitoring.Measurements measurements, StoreAccessCompleteHandler callout)
	Should record raw measurements in the given bucket and call out to the delegate when complete. More...

void	RecordFiveMinAverages (Monitoring.WeightedMeasurementAvgs averages, StoreAccessCompleteHandler callout)
	Should record the given averages to the given 5-minute store and call out to the delegate when complete. More...

void	RecordHourlyAverages (Monitoring.WeightedMeasurementAvgs averages, StoreAccessCompleteHandler callout)
	Should record the given averages to the given 5-minute store and call out to the delegate when complete. More...

void	RecordDailyAverages (Monitoring.WeightedMeasurementAvgs averages, StoreAccessCompleteHandler callout)
	Should record the given averages to the given daily store and call out to the delegate when complete. More...

void	RecordMonthlyAverages (Monitoring.WeightedMeasurementAvgs averages, StoreAccessCompleteHandler callout)
	Should record the given averages to the given monthy store and call out to the delegate when complete. More...

Public Member Functions inherited from Apac.Data.ISettingsStore
bool	PersistManagedElement (Apac.Monitoring.ManagedElement element)
	Should create or update the given element in the datastore for use in setting up mappings to incoming data. More...

void	DeleteManagedElement (Apac.Monitoring.ManagedElement element)
	Should remove the given element from the datastore. More...

bool	PersistMeasurementMappings (Apac.Collections.MeasurementMappingCollection mappings)
	Should write the given mappings to a location where they will remain pending until they are promoted. More...

void	SaveConfiguration (Settings.Configuration config, bool activate)
	Should save the given configuration to the data store. More...

bool	PersistThreshold (Monitoring.Threshold threshold)
	Perists the threshold. More...

bool	PersistEventDef (Monitoring.EventDef eventDef)
	Persistes the event def. More...

void	DeleteEventDef (Monitoring.EventDef eventDef)
	Deletes the event def. More...

bool	PersistAction (Monitoring.ActionDef action)
	Persists the action. More...

void	DeleteAction (Monitoring.ActionDef action)
	Deletes the action. More...

void	DeleteActions (Monitoring.EventDef eventDef)
	Deletes the actions associated with the event def. More...

void	PersistSensor (Monitoring.Sensor sensor)
	Persists the sensor. More...

void	DeleteSensor (Monitoring.Sensor sensor)
	Deletes the sensor. More...

Public Member Functions inherited from Apac.Data.IAuthStore
List< User >	GetUsers (PredicateSet filter)
	Gets the users that match filter . More...

WhyBool	CreateUser (User user)
	Validates the inputs and creates the user. This routine assumes the password has already been hashed and salted and applied to the user object. More...

WhyBool	UpdateUser (User user)
	Updates the user and associations to look like user . More...

WhyBool	CreateNotificationGroup (string name, ref NotificationGroup group)
	Creates a notification group with name . More...

Protected Attributes inherited from Apac.Data.ThreadedMeasurementStore
volatile Configuration.DataStoreConfig	_config = null

Properties inherited from Apac.Data.DatabaseStore
Apac.Settings.Configuration	CurrentConfiguration `[get]`
	Returns the system setting as they are cached at initialization. More...

List< string >	Roles `[get]`
	Gets the roles currently configured in the system. More...

List< Auth.NotificationGroup >	NotificationGroups `[get]`
	Gets the notification groups currently configured in the system. More...

Properties inherited from Apac.Data.ThreadedMeasurementStore
AlertCache	AlertCache `[get]`
	Gets the alert cache. More...

string?	Location `[get]`
	In this store implementation this property indicates the directory for the data file(s). The name of the data files is determined internally. This path also indicates where the mappings file can be located. More...

Properties inherited from Apac.Supervisable
string	Name `[get]`
	Gets the name of the controller, as specified by configuration. Note that if the name is not specified, then an index will be used. More...

string	Description `[get]`
	Gets the description of the controller, as specified by configuration. More...

bool	Prioritized `[get]`
	Indicates if the supervisable component should be executed on a higher thread priority. More...

DateTime	LastHeartbeat `[get]`
	The time of the last heartbeat. More...

Supervisors.ISupervisor	ExecutiveSupervisor `[get]`
	Walks the tree to find the top level supervisor. More...

bool	IsRunning `[get]`
	Gets a value indicating whether this instance is running. More...

SupervisableState	CurrentState `[get]`
	Gets the current overall state of the controller. More...

SupervisableState	PreviousState `[get]`
	Gets the previous overall state of the controller. More...

Exception	LastException `[get]`
	Gets the last exception encountered within the controller. More...

DateTime	StartTime `[get]`
	Gets the time this supervisable component was started. More...

DateTime	StopTime `[get]`
	Gets the time this supervisable component was stopped. More...

TimeSpan	UpTime `[get]`
	Gets the amount of time this supervisable component has been running, or did run before it was stopped (if IsRunning is `false`). More...

Supervisors.ISupervisor	Supervisor `[get]`
	Gets the supervisor. More...

SupervisableConfig	Config `[get]`
	The configuration object used by the supervisable component. More...

log4net.ILog	Log `[get]`
	Lazy-initialized logger for subclass usage. More...

Properties inherited from Apac.ISupervisable
string	Name `[get]`
	The name of the component, for unique identification purposes. More...

string	Description `[get]`
	The description of the component, for human consumption. More...

bool	Prioritized `[get]`
	Indicates if the component should be high priority. More...

Supervisors.ISupervisor	ExecutiveSupervisor `[get]`
	Walks the tree to find the top level supervisor. More...

bool	IsRunning `[get]`
	Indicates that the component is running. More...

DateTime	LastHeartbeat `[get]`

DateTime	StartTime `[get]`
	Gets the time this supervisable component was started. More...

DateTime	StopTime `[get]`
	Gets the time this supervisable component was stopped. More...

TimeSpan	UpTime `[get]`
	Gets the amount of time this supervisable component has been running, or did run before it was stopped (if IsRunning is `false`). More...

SupervisableState	CurrentState `[get]`
	Gets the current SupervisableState of this component. More...

SupervisableState	PreviousState `[get]`
	Gets the previous SupervisableState of this component. More...

Exception	LastException `[get]`
	Gets the last exception to have occurred and been trapped by this component. More...

Properties inherited from Apac.Data.IDataStore
string	Location `[get]`

Properties inherited from Apac.Data.IMeasurementStore
Monitoring.AlertCache	AlertCache `[get]`
	Gets the alert cache. More...

Properties inherited from Apac.Data.ISettingsStore
Settings.Configuration	CurrentConfiguration `[get]`
	Should get the currently held settings. More...

Properties inherited from Apac.Data.IAuthStore
List< string >	Roles `[get]`
	Gets the currently configured roles, possibly from cache. More...

List< NotificationGroup >	NotificationGroups `[get]`
	Gets the currently configured notification groups, possibly from cache. More...

Events inherited from Apac.Data.DatabaseStore
SettingsChangedHandler	SettingsChanged
	Occurs when any settings have changed. More...

Events inherited from Apac.Supervisable
SupervisableStateChangingHandler	SupervisableStateChanging
	Notifies listeners that the state is about to change. More...

SupervisableStateChangedHandler	SupervisableStateChanged
	Notifies listeners that the state has changed. More...

SupervisableErroredHandler	SupervisableErrored
	Notifies listeners that an error occured within the controller. More...

SupervisableHeartbeatHandler	SupervisableHeartbeat
	Notifies listeners that the component is still active. More...

Events inherited from Apac.ISupervisable
SupervisableStateChangingHandler	SupervisableStateChanging
	Notifies listeners that the state is about to change. More...

SupervisableStateChangedHandler	SupervisableStateChanged
	Notifies listeners that the state has changed. More...

SupervisableErroredHandler	SupervisableErrored
	Notifies listeners that an error occured within the controller. More...

SupervisableHeartbeatHandler	SupervisableHeartbeat
	Notifies listeners that the component is still active. More...

Events inherited from Apac.Data.ISettingsStore
SettingsChangedHandler	SettingsChanged
	Occurs when any settings have changed. More...

Detailed Description

Implements a (hopefully) data provider agnostic store for keeping ECOP data in an RDBMS. The goal here is to provide a data store implementation that can be used to scale ECOP from its current scope to an enterprise scope by altering the RDBMS underneath.

It turns out that this method of storage uses about 88 bytes per measurement.

Member Function Documentation

◆ OnFormulateCheckForAction()

override DbCommand Apac.Data.FirebirdStore.OnFormulateCheckForAction	(	DbConnection	connection,
		uint	elementId,
		uint	eventId
	)

inlineprotectedvirtual

Builds a command that returns the count of actions with the element and event def ids.

Parameters

connection	The DbConnection used for the work.
elementId	The element id.
eventId	The event def id.

Returns: A DbCommand instance set up to perform the operation.

connection	The DbConnection used for the work.
configid	The datastore identifier for the configuration being searched.
elementid	The datastore identifier for the managed element being searched.
sensorid	The identifier for the sensor being searched.
sourceElementId	The identifier for the source element.
constantValue	The constant value used for this mapping.
inputTag	The input tag value used for this mapping.

connection	The DbConnection used for the work.
id	The data store identifier for the sensor.

connection	The DbConnection used for the work.
alert	The alert.

connection	The DbConnection used for the work.
name	The name for the new configuration.

connection	The DbConnection used for the work.
action	The action.

connection	The DbConnection used for the work.
element	The element.

connection	The DbConnection used for the work.
id	The data store identifier for the configuration to be deleted.

connection	The DbConnection used for the work.
mapping	The the mapping to be deleted.

connection	The DbConnection used for the work.
activeOnly	Instructs the query to only return alerts that are not cleared.

connection	The DbConnection used for the work.
criteria	The query conditions requested by the caller.

connection	The DbConnection used for the work.
eventDefId	The event def id.

connection	The DbConnection used for the work.
id	The id of the element needed.

connection	The connection.
configId	The config id.
activeOnly	if set to `true` then only active sensors are returned.

connection	The connection.
user	The User used to filter the results.

connection	The DbConnection used for the work.
mappings	The mappings to be persisted.

connection	The DbConnection used for the work.
threshold	The threshold to be persisted.

connection	The DbConnection used for the work.
cutoff	The oldest date to keep in the data store.

connection	The DbConnection used for the work.
id	The data store identifier of the configuration to become active.

connection	The DbConnection used for the work.
oldmapping	The the mapping object with the old data.
newmapping	The the mapping object with the new data.

connection	The DbConnection used for the work.
avgs	The Monitoring.WeightedMeasurementAvgs to be persisted.

Protected Member Functions

Additional Inherited Members

Detailed Description

Member Function Documentation

◆ OnFormulateCheckForAction()

◆ OnFormulateCheckForEventDef()

◆ OnFormulateCheckForManagedElement()

◆ OnFormulateCheckForMeasurementMapping()

◆ OnFormulateCheckForSensor()

◆ OnFormulateCheckForThreshold()

◆ OnFormulateClearAlert()

◆ OnFormulateCreateConfig()

◆ OnFormulateDeleteAction()

◆ OnFormulateDeleteActions() [1/2]

◆ OnFormulateDeleteActions() [2/2]

◆ OnFormulateDeleteConfig()

◆ OnFormulateDeleteEventDef()

◆ OnFormulateDeleteManagedElement()

◆ OnFormulateDeleteMapping()

◆ OnFormulateDeleteMappings()

◆ OnFormulateDeleteMeasurements()

◆ OnFormulateDeleteNotifGrp()

◆ OnFormulateDeleteSensor()

◆ OnFormulateDeleteThresholds()

◆ OnFormulateDeleteUser()

◆ OnFormulateDeleteWeightedAverages()

◆ OnFormulateFetchActions()

◆ OnFormulateFetchAlerts()

◆ OnFormulateFetchDailyAvgs()

◆ OnFormulateFetchEventDef()

◆ OnFormulateFetchEventDefs()

◆ OnFormulateFetchFiveMinAvgs()

◆ OnFormulateFetchHourlyAvgs()

◆ OnFormulateFetchManagedElement()

◆ OnFormulateFetchManagedElements()

◆ OnFormulateFetchMappedManagedElements()

◆ OnFormulateFetchMeasurementMappings()

◆ OnFormulateFetchMeasurements()

◆ OnFormulateFetchMonthlyAvgs()

◆ OnFormulateFetchSensor()

◆ OnFormulateFetchSensors()

◆ OnFormulateFetchThresholds()

◆ OnFormulateGetActiveEcopConfig()

◆ OnFormulateGetConfigId()

◆ OnFormulateGetEcopConfig() [1/2]

◆ OnFormulateGetEcopConfig() [2/2]

◆ OnFormulateGetEcopConfigs()

◆ OnFormulateGetEcopSettings()

◆ OnFormulateGetNotifGrps()

◆ OnFormulateGetNotifGrpXrefs()

◆ OnFormulateGetRoles()

◆ OnFormulateGetUsers()

◆ OnFormulateHasActions()

◆ OnFormulateHasAverages()

◆ OnFormulateHasMeasurements()

◆ OnFormulateHasThresholds()

◆ OnFormulateInsertAction()

◆ OnFormulateInsertEventDef()

◆ OnFormulateInsertManagedElement()

◆ OnFormulateInsertMeasurementMapping()

◆ OnFormulateInsertMeasurementMappings()

◆ OnFormulateInsertNotifGrp()

◆ OnFormulateInsertOrUpdateAlert()

◆ OnFormulateInsertSensor()

◆ OnFormulateInsertThreshold()

◆ OnFormulateInsertUser()

◆ OnFormulateMergeSetting()

◆ OnFormulatePersistUserNotifGroupXrefs()

◆ OnFormulatePersistUserRoleXrefs()

◆ OnFormulatePruneMeasurements()

◆ OnFormulateSetActiveConfig()

◆ OnFormulateUpdateAction()

◆ OnFormulateUpdateEventDef()

◆ OnFormulateUpdateManagedElement()

◆ OnFormulateUpdateMeasurementMapping() [1/2]

◆ OnFormulateUpdateMeasurementMapping() [2/2]

◆ OnFormulateUpdateMeasurementMappings()

◆ OnFormulateUpdateNotifGrp()

◆ OnFormulateUpdateSensor()

◆ OnFormulateUpdateThreshold()

connection	The DbConnection used for the work.
measurements	The T:Monitoring.Measurements<ushort> to be persisted.