memcached_writer.cpp

#include "memcached_writer.h"
#include <string>
#include <stdio.h>
#include <stdlib.h>
#include <iostream>
#include <cstring>
#include <ctime>

using namespace std;

MemcachedWriter::MemcachedWriter(config_t cfg)
{
	this->cfg = cfg;
}

MemcachedWriter::~MemcachedWriter()
{
}

void MemcachedWriter::connect()
{
	const char *host;
	int port = 11211;

	if(!config_lookup_string(&this->cfg, "memcached.host", &host)) {
		host = "localhost";
	}
	if(!config_lookup_int(&this->cfg, "memcached.port", &port)) {
		port = 11211;
	}

	memcached_server_st *memcached_servers_parse (char *server_strings);
	memcached_return rc;

	this->memc = memcached_create(NULL);
	this->servers = NULL;
	this->servers = memcached_server_list_append(this->servers, host, port, &rc);

	rc = memcached_server_push(memc, servers);
	if (rc != MEMCACHED_SUCCESS) {
		throw memcached_strerror(memc, rc);
	}
}

void MemcachedWriter::saveNumericValue(double value, int dataSourceId)
{
	//std::cout << "MemcachedWriter::saveNumericValue\n";
	char key[32];
	snprintf(key, sizeof(key), "ds_v_%d", dataSourceId);
	char buffer[80];
	snprintf(buffer, sizeof(buffer), "%g", value);
	memcached_set(this->memc, key, strlen(key), buffer, strlen(buffer), (time_t)0, (uint32_t)0);

	snprintf(key, sizeof(key), "ds_d_%d", dataSourceId);
	time_t rawtime;
	struct tm * timeinfo;
	time (&rawtime);
	timeinfo = localtime(&rawtime);
	strftime(buffer, sizeof(buffer),"%Y-%m-%d %H:%M:%S",timeinfo);
	memcached_set(this->memc, key, strlen(key), buffer, strlen(buffer), (time_t)0, (uint32_t)0);
}