30 #ifndef NIDAS_DYNLD_PSQL_PSQLSAMPLEOUTPUT_H
31 #define NIDAS_DYNLD_PSQL_PSQLSAMPLEOUTPUT_H
38 namespace nidas {
namespace dynld {
namespace psql {
56 bool isRaw()
const {
return false; }
76 void connect() throw(nidas::util::IOException);
84 int getFd()
const {
return -1; }
88 void close() throw(nidas::util::IOException);
95 void submitCommand(const std::
string& command) throw(nidas::util::IOException);
105 void addCategory(const std::
string& varName, const std::
string& category)
106 throw(nidas::util::IOException);
133 #endif // NIDAS_DYNLD_PSQL_PSQLSAMPLEOUTPUT_H
Interface for an object that requests connections SampleOutputs.
Definition: ConnectionRequester.h:42
void initializeGlobalAttributes()
Definition: PSQLSampleOutput.cc:243
void requestConnection(SampleConnectionRequester *)
Request a connection, but don't wait for it.
Definition: PSQLSampleOutput.cc:67
void addCategory(const std::string &varName, const std::string &category)
Definition: PSQLSampleOutput.cc:332
std::map< float, std::string > tablesByRate
Definition: PSQLSampleOutput.h:120
void setPseudoPort(int val)
Definition: PSQLSampleOutput.h:58
unsigned int dsm_sample_id_t
Definition: Sample.h:63
void connected(SampleOutput *origout, SampleOutput *newout)
Definition: PSQLSampleOutput.cc:102
int getPseudoPort() const
Definition: PSQLSampleOutput.h:60
bool isRaw() const
Definition: PSQLSampleOutput.h:56
A class for serializing Samples on an OutputStream.
Definition: SampleOutputStream.h:40
std::string name
Definition: PSQLSampleOutput.h:108
Interface of an output stream of samples.
Definition: SampleOutput.h:47
Class describing a sampled variable.
Definition: Variable.h:46
void fromDOMElement(const xercesc::DOMElement *node)
Initialize myself from a xercesc::DOMElement.
Definition: PSQLSampleOutput.cc:428
Definition: PSQLChannel.h:38
Class that should include all that is configurable about a DSM.
Definition: DSMConfig.h:55
void addSampleTag(const SampleTag *tag)
PSQLChannel * psqlChannel
Definition: PSQLSampleOutput.h:114
A channel for Input or Output of data.
Definition: IOChannel.h:64
void setDSMConfigs(const std::list< const DSMConfig * > &val)
Definition: PSQLSampleOutput.cc:84
SampleConnectionRequester * connectionRequester
Definition: PSQLSampleOutput.h:110
void connect()
Definition: PSQLSampleOutput.cc:77
bool receive(const Sample *)
Method called to pass a sample to this client.
Definition: PSQLSampleOutput.cc:342
void submitCommand(const std::string &command)
Definition: PSQLSampleOutput.cc:174
PSQLSampleOutput * clone(IOChannel *iochannel=0) const
Definition: PSQLSampleOutput.cc:59
void createTables()
Definition: PSQLSampleOutput.cc:180
const std::list< const DSMConfig * > & getDSMConfigs() const
Definition: PSQLSampleOutput.cc:94
const std::string & getName() const
Definition: PSQLSampleOutput.h:54
void dropAllTables()
Definition: PSQLSampleOutput.cc:224
bool first
Definition: PSQLSampleOutput.h:126
void setName(const std::string &val)
Definition: PSQLSampleOutput.h:52
Interface to a data sample.
Definition: Sample.h:189
std::map< float, const SampleTag * > tagsByRate
Definition: PSQLSampleOutput.h:118
PSQLSampleOutput()
Definition: PSQLSampleOutput.cc:41
float missingValue
Definition: PSQLSampleOutput.h:124
Definition: IOException.h:37
std::list< const DSMConfig * > dsms
Definition: PSQLSampleOutput.h:112
Class describing a group of variables that are sampled and handled together.
Definition: SampleTag.h:87
int dberrors
Definition: PSQLSampleOutput.h:128
std::map< dsm_sample_id_t, const SampleTag * > tagsById
Definition: PSQLSampleOutput.h:122
void flush()
Ask that this SampleClient send out any buffered Samples that it may be holding.
Definition: PSQLSampleOutput.cc:119
void close()
Definition: PSQLSampleOutput.cc:126
virtual ~PSQLSampleOutput()
Definition: PSQLSampleOutput.cc:54
Definition: PSQLSampleOutput.h:40
int getFd() const
Definition: PSQLSampleOutput.h:84
void addDSMConfig(const DSMConfig *)
Definition: PSQLSampleOutput.cc:89
Definition: InvalidParameterException.h:35
void init()
Definition: PSQLSampleOutput.cc:159
void addVariable(const Variable *var)