Category

Development Platform
Home > SourceCode/Document > Database system > MySQL > View Code
ExtAPI.hpp
Package: mysql-4.1.16-win-src.zip　[view]
Upload User: romrleung
Upload Date: 2022-05-23
Package Size: 18897k
Code Size: 3k
Category:

MySQL

Development Platform:

Visual C++

ExtAPI.hpp：Code Content
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. #ifndef EXTAPI_HPP
  18. #define EXTAPI_HPP
  20. #include <signaldata/RepImpl.hpp>
  21. #include <signaldata/GrepImpl.hpp>
  22. #include <signaldata/SumaImpl.hpp>
  24. #include <rep/ExtSender.hpp>
  26. /**
  27.  * The abstract class for all extractors
  28.  */
  29. class ExtAPI
  30. {
  31. public:
  32.   /***************************************************************************
  33.    * Constructor / Destructor
  34.    ***************************************************************************/
  35. #if 0
  36.   bool init(const char * connectString = NULL);
  37.   
  38.   GrepError::Code dataLogStarted(Uint32 epoch, 
  39.  Uint32 subId, Uint32 subKey) = 0;
  40.   GrepError::Code metaLogStarted(Uint32 epoch, 
  41.  Uint32 subId, Uint32 subKey) = 0;
  42.   GrepError::Code epochComleted() = 0;
  43.   GrepError::Code subscriptionCreated() = 0;
  44.   GrepError::Code subscriptionRemoved() = 0;
  45.   GrepError::Code metaScanCompleted() = 0;
  46.   GrepError::Code dataScanCompleted() = 0;
  47.   GrepError::Code subscriptionRemoveFailed() = 0;
  48.   GrepError::Code metaScanFailed() = 0;
  49.   GrepError::Code dataScanFailed() = 0;
  50.   GrepError::Code subscriptiodIdCreateFailed() = 0;
  51.   GrepError::Code dataLogFailed() = 0;
  52.   GrepError::Code metaLogFailed() = 0;
  53.   GrepError::Code subscriptionCreateFailed() = 0;
  55.   /**Above to be deleted*/
  56. #endif
  58.   virtual GrepError::Code 
  59.   eventSubscriptionIdCreated(Uint32 subId, Uint32 subKey) ;
  61. #if 0
  62.   GrepError::Code 
  63.   eventSubscriptionDeleted(Uint32 subId, Uint32 subKey);
  65.   GrepError::Code 
  66.   eventMetaLogStarted(NdbApiSignal*, Uint32 subId, Uint32 subKey);
  67.   
  68.   GrepError::Code 
  69.   eventDataLogStarted(NdbApiSignal*, Uint32 subId, Uint32 subKey);
  71.   GrepError::Code 
  72.   eventMetaScanCompleted(NdbApiSignal*, Uint32 subId, Uint32 subKey,
  73.  Interval epochs);
  75.   GrepError::Code 
  76.   eventDataScanCompleted(NdbApiSignal*, Uint32 subId, Uint32 subKey, 
  77.  Interval epochs);
  79.   GrepError::Code 
  80.   eventMetaScanFailed(Uint32 subId, Uint32 subKey, GrepError::Code error);
  82.   GrepError::Code 
  83.   eventDataScanFailed(Uint32 subId, Uint32 subKey, GrepError::Code error);
  84. #endif
  86.   /***************************************************************************
  87.    * Public Methods
  88.    ***************************************************************************/
  89.   void  setRepSender(ExtSender * es) { m_repSender = es; };
  90.   //void  signalErrorHandler(NdbApiSignal * s, Uint32 nodeId);
  92. protected:
  93.   ExtSender * m_repSender;
  94. };
  97. #if 0
  98. class TestExtAPI : public ExtAPI
  99. {
  100.   GrepError::Code 
  101.   eventSubscriptionIdCreated(Uint32 subId, Uint32 subKey) {
  102.     ndbout_c("Received subscription:%d-%d");
  103.   };
  104. };
  105. #endif
  107. #endif // EXTAPI_HPP