SQLMonitoringService.h

Go to the documentation of this file.

#ifndef COND_SQLMONITORINGSERVICE_H
#define COND_SQLMONITORINGSERVICE_H

#include "RelationalAccess/IMonitoringService.h"
#include "RelationalAccess/IMonitoringReporter.h"

#include "CoralCommon/MonitoringReportTypes.h"
#include "CoralCommon/MonitoringEvent.h"

#include "CoralKernel/Service.h"

#include <string>
#include <map>
#include <vector>

namespace coral
{
  class MessageStream;
}

namespace cond
{
  typedef std::vector<coral::monitor::Event::Record> EventStream;

  struct SessionMonitor{
      SessionMonitor();
      SessionMonitor( bool, coral::monitor::Level );

      bool                  active;
      coral::monitor::Level level;
      EventStream           stream;
  };

  typedef std::map< std::string, SessionMonitor > Repository;

  class SQLMonitoringService : public coral::Service, virtual public coral::monitor::IMonitoringService, virtual public coral::IMonitoringReporter
    {

      public:
        explicit SQLMonitoringService( const std::string& );        
        virtual ~SQLMonitoringService();

      public:
        virtual void setLevel( const std::string& contextKey, coral::monitor::Level level );

        virtual coral::monitor::Level level( const std::string& contextKey ) const;

        virtual bool active( const std::string& contextKey ) const;

        virtual void enable( const std::string& contextKey );
        virtual void disable( const std::string& contextKey );
        
        virtual void record( const std::string& contextKey,
                             coral::monitor::Source source,
                             coral::monitor::Type type,
                             const std::string& description );

        virtual void record( const std::string& contextKey,
                             coral::monitor::Source source,
                             coral::monitor::Type type,
                             const std::string& description,
                             int data );

        virtual void record( const std::string& contextKey,
                             coral::monitor::Source source,
                             coral::monitor::Type type,
                             const std::string& description,
                             long long data );
    
        virtual void record( const std::string& contextKey,
                             coral::monitor::Source source,
                             coral::monitor::Type type,
                             const std::string& description,
                             double data );

        virtual void record( const std::string& contextKey,
                             coral::monitor::Source source,
                             coral::monitor::Type type,
                             const std::string& description,
                             const std::string& data );

        virtual const coral::IMonitoringReporter& reporter() const;

        //
        // The coral::IMonitoringReporter interface implementation
        //
        
        virtual std::set< std::string > monitoredDataSources() const;
        
        virtual void report( unsigned int level ) const;

        virtual void report( const std::string& contextKey, unsigned int level ) const;

        virtual void reportToOutputStream( const std::string& contextKey, std::ostream& os, unsigned int level ) const;

        void reportOnEvent( EventStream::const_iterator& it, std::ostream&        os ) const;
        void reportOnEvent( EventStream::const_iterator& it, coral::MessageStream& os ) const;

        void reportForSession( Repository::const_iterator& it, std::ostream&        os ) const;
        void reportForSession( Repository::const_iterator& it, coral::MessageStream& os ) const;
      private:

        Repository            m_events;
        std::set<std::string> m_monitoredDS;
    };
} // namespace cond

#endif // COND_SQLMONITORINGSERVICE_H