sensorconfig_internal.h

//================================================================================
// Name        : sensorconfig_internal.h
// Author      : Axel Auweter, Daniele Tafani
// Copyright   : Leibniz Supercomputing Centre
// Description : Internal Interface for configuring libdcdb public sensors.
//================================================================================

//================================================================================
// This file is part of DCDB (DataCenter DataBase)
// Copyright (C) 2011-2016 Leibniz Supercomputing Centre
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
// Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public
// License along with this library; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
//================================================================================

#include <list>
#include <string>
#include <unordered_map>

#include "cassandra.h"

#include "dcdb/connection.h"
#include "dcdb/timestamp.h"
#include "dcdb/sensorid.h"

#include "dcdb/sensorconfig.h"

#ifndef DCDB_SENSORCONFIG_INTERNAL_H
#define DCDB_SENSORCONFIG_INTERNAL_H

namespace DCDB {

class SensorConfigImpl
{
protected:
  Connection* connection;
  CassSession* session;

  typedef std::unordered_map<std::string, PublicSensor> SensorPropertyCache_t;
  static SensorPropertyCache_t sensorPropertyCache;

  bool validateSensorPattern(const char* sensorPattern);
  bool validateSensorPublicName(std::string publicName);

public:
  SCError publishSensor(std::string publicName, std::string sensorPattern);
  SCError publishVirtualSensor(std::string publicName, std::string vSensorExpression, std::string vSensorId, TimeStamp tZero, uint64_t frequency);
  SCError unPublishSensor(std::string publicName);
  SCError getPublicSensorNames(std::list<std::string>& publicSensors);
  SCError getPublicSensorsVerbose(std::list<PublicSensor>& publicSensors);

  SCError getPublicSensorByName(PublicSensor& sensor, const char* publicName);

  SCError isVirtual(bool& isVirtual, std::string publicName);

  SCError getSensorPattern(std::string& pattern, std::string publicName);
  SCError getSensorListForPattern(std::list<SensorId>& sensorIds, std::string pattern);
  SCError getSensorListForPattern(std::list<SensorId>& sensorIds, std::string pattern, TimeStamp start, TimeStamp end);

  SCError setSensorScalingFactor(std::string publicName, double scalingFactor);
  SCError setSensorUnit(std::string publicName, std::string unit);
  SCError setSensorMask(std::string publicName, uint64_t mask);

  SCError setVirtualSensorExpression(std::string publicName, std::string expression);
  SCError setVirtualSensorTZero(std::string publicName, TimeStamp tZero);
  SCError setVirtualSensorFrequency(std::string publicName, uint64_t frequency);

  SensorConfigImpl(Connection* conn);
  virtual ~SensorConfigImpl();
};

} /* End of namespace DCDB */

#endif /* DCDB_SENSORCONFIG_INTERNAL_H */