cassandra-thrift (empty) → 0.0.1
raw patch · 7 files changed
+2633/−0 lines, 7 filesdep +Thriftdep +basedep +containerssetup-changed
Dependencies added: Thrift, base, containers, haskell98
Files
- Database/Cassandra/Thrift/Cassandra.hs +1700/−0
- Database/Cassandra/Thrift/Cassandra_Client.hs +399/−0
- Database/Cassandra/Thrift/Cassandra_Consts.hs +19/−0
- Database/Cassandra/Thrift/Cassandra_Iface.hs +23/−0
- Database/Cassandra/Thrift/Cassandra_Types.hs +461/−0
- Setup.hs +3/−0
- cassandra-thrift.cabal +28/−0
+ Database/Cassandra/Thrift/Cassandra.hs view
@@ -0,0 +1,1700 @@+{-# LANGUAGE DeriveDataTypeable #-}+-----------------------------------------------------------------+-- Autogenerated by Thrift --+-- --+-- DO NOT EDIT UNLESS YOU ARE SURE YOU KNOW WHAT YOU ARE DOING --+-----------------------------------------------------------------++module Database.Cassandra.Thrift.Cassandra where+import Thrift+import Data.Typeable ( Typeable )+import Control.Exception+import qualified Data.Map as Map+import qualified Data.Set as Set+import Data.Int+import Database.Cassandra.Thrift.Cassandra_Types+import qualified Database.Cassandra.Thrift.Cassandra_Iface as Iface+-- HELPER FUNCTIONS AND STRUCTURES --++data Get_args = Get_args{f_Get_args_keyspace :: Maybe String,f_Get_args_key :: Maybe String,f_Get_args_column_path :: Maybe ColumnPath,f_Get_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Get_args oprot rec = do+ writeStructBegin oprot "Get_args"+ case f_Get_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_args_key rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("key",T_STRING,2)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_args_column_path rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_path",T_STRUCT,3)+ write_ColumnPath oprot _v+ writeFieldEnd oprot}+ case f_Get_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,4)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_args_fields iprot rec = do+ (_,_t81,_id82) <- readFieldBegin iprot+ if _t81 == T_STOP then return rec else+ case _id82 of + 1 -> if _t81 == T_STRING then do+ s <- readString iprot+ read_Get_args_fields iprot rec{f_Get_args_keyspace=Just s}+ else do+ skip iprot _t81+ read_Get_args_fields iprot rec+ 2 -> if _t81 == T_STRING then do+ s <- readString iprot+ read_Get_args_fields iprot rec{f_Get_args_key=Just s}+ else do+ skip iprot _t81+ read_Get_args_fields iprot rec+ 3 -> if _t81 == T_STRUCT then do+ s <- (read_ColumnPath iprot)+ read_Get_args_fields iprot rec{f_Get_args_column_path=Just s}+ else do+ skip iprot _t81+ read_Get_args_fields iprot rec+ 4 -> if _t81 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Get_args_fields iprot rec{f_Get_args_consistency_level=Just s}+ else do+ skip iprot _t81+ read_Get_args_fields iprot rec+ _ -> do+ skip iprot _t81+ readFieldEnd iprot+ read_Get_args_fields iprot rec+read_Get_args iprot = do+ readStructBegin iprot+ rec <- read_Get_args_fields iprot (Get_args{f_Get_args_keyspace=Nothing,f_Get_args_key=Nothing,f_Get_args_column_path=Nothing,f_Get_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Get_result = Get_result{f_Get_result_success :: Maybe ColumnOrSuperColumn,f_Get_result_ire :: Maybe InvalidRequestException,f_Get_result_nfe :: Maybe NotFoundException,f_Get_result_ue :: Maybe UnavailableException,f_Get_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Get_result oprot rec = do+ writeStructBegin oprot "Get_result"+ case f_Get_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_STRUCT,0)+ write_ColumnOrSuperColumn oprot _v+ writeFieldEnd oprot}+ case f_Get_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Get_result_nfe rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("nfe",T_STRUCT,2)+ write_NotFoundException oprot _v+ writeFieldEnd oprot}+ case f_Get_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,3)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Get_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,4)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_result_fields iprot rec = do+ (_,_t86,_id87) <- readFieldBegin iprot+ if _t86 == T_STOP then return rec else+ case _id87 of + 0 -> if _t86 == T_STRUCT then do+ s <- (read_ColumnOrSuperColumn iprot)+ read_Get_result_fields iprot rec{f_Get_result_success=Just s}+ else do+ skip iprot _t86+ read_Get_result_fields iprot rec+ 1 -> if _t86 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Get_result_fields iprot rec{f_Get_result_ire=Just s}+ else do+ skip iprot _t86+ read_Get_result_fields iprot rec+ 2 -> if _t86 == T_STRUCT then do+ s <- (read_NotFoundException iprot)+ read_Get_result_fields iprot rec{f_Get_result_nfe=Just s}+ else do+ skip iprot _t86+ read_Get_result_fields iprot rec+ 3 -> if _t86 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Get_result_fields iprot rec{f_Get_result_ue=Just s}+ else do+ skip iprot _t86+ read_Get_result_fields iprot rec+ 4 -> if _t86 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Get_result_fields iprot rec{f_Get_result_te=Just s}+ else do+ skip iprot _t86+ read_Get_result_fields iprot rec+ _ -> do+ skip iprot _t86+ readFieldEnd iprot+ read_Get_result_fields iprot rec+read_Get_result iprot = do+ readStructBegin iprot+ rec <- read_Get_result_fields iprot (Get_result{f_Get_result_success=Nothing,f_Get_result_ire=Nothing,f_Get_result_nfe=Nothing,f_Get_result_ue=Nothing,f_Get_result_te=Nothing})+ readStructEnd iprot+ return rec+data Get_slice_args = Get_slice_args{f_Get_slice_args_keyspace :: Maybe String,f_Get_slice_args_key :: Maybe String,f_Get_slice_args_column_parent :: Maybe ColumnParent,f_Get_slice_args_predicate :: Maybe SlicePredicate,f_Get_slice_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Get_slice_args oprot rec = do+ writeStructBegin oprot "Get_slice_args"+ case f_Get_slice_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_slice_args_key rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("key",T_STRING,2)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_slice_args_column_parent rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_parent",T_STRUCT,3)+ write_ColumnParent oprot _v+ writeFieldEnd oprot}+ case f_Get_slice_args_predicate rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("predicate",T_STRUCT,4)+ write_SlicePredicate oprot _v+ writeFieldEnd oprot}+ case f_Get_slice_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,5)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_slice_args_fields iprot rec = do+ (_,_t91,_id92) <- readFieldBegin iprot+ if _t91 == T_STOP then return rec else+ case _id92 of + 1 -> if _t91 == T_STRING then do+ s <- readString iprot+ read_Get_slice_args_fields iprot rec{f_Get_slice_args_keyspace=Just s}+ else do+ skip iprot _t91+ read_Get_slice_args_fields iprot rec+ 2 -> if _t91 == T_STRING then do+ s <- readString iprot+ read_Get_slice_args_fields iprot rec{f_Get_slice_args_key=Just s}+ else do+ skip iprot _t91+ read_Get_slice_args_fields iprot rec+ 3 -> if _t91 == T_STRUCT then do+ s <- (read_ColumnParent iprot)+ read_Get_slice_args_fields iprot rec{f_Get_slice_args_column_parent=Just s}+ else do+ skip iprot _t91+ read_Get_slice_args_fields iprot rec+ 4 -> if _t91 == T_STRUCT then do+ s <- (read_SlicePredicate iprot)+ read_Get_slice_args_fields iprot rec{f_Get_slice_args_predicate=Just s}+ else do+ skip iprot _t91+ read_Get_slice_args_fields iprot rec+ 5 -> if _t91 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Get_slice_args_fields iprot rec{f_Get_slice_args_consistency_level=Just s}+ else do+ skip iprot _t91+ read_Get_slice_args_fields iprot rec+ _ -> do+ skip iprot _t91+ readFieldEnd iprot+ read_Get_slice_args_fields iprot rec+read_Get_slice_args iprot = do+ readStructBegin iprot+ rec <- read_Get_slice_args_fields iprot (Get_slice_args{f_Get_slice_args_keyspace=Nothing,f_Get_slice_args_key=Nothing,f_Get_slice_args_column_parent=Nothing,f_Get_slice_args_predicate=Nothing,f_Get_slice_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Get_slice_result = Get_slice_result{f_Get_slice_result_success :: Maybe [ColumnOrSuperColumn],f_Get_slice_result_ire :: Maybe InvalidRequestException,f_Get_slice_result_ue :: Maybe UnavailableException,f_Get_slice_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Get_slice_result oprot rec = do+ writeStructBegin oprot "Get_slice_result"+ case f_Get_slice_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_LIST,0)+ (let {f [] = return (); f (_viter95:t) = do {write_ColumnOrSuperColumn oprot _viter95;f t}} in do {writeListBegin oprot (T_STRUCT,length _v); f _v;writeListEnd oprot})+ writeFieldEnd oprot}+ case f_Get_slice_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Get_slice_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,2)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Get_slice_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,3)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_slice_result_fields iprot rec = do+ (_,_t97,_id98) <- readFieldBegin iprot+ if _t97 == T_STOP then return rec else+ case _id98 of + 0 -> if _t97 == T_LIST then do+ s <- (let {f 0 = return []; f n = do {v <- (read_ColumnOrSuperColumn iprot);r <- f (n-1); return $ v:r}} in do {(_etype102,_size99) <- readListBegin iprot; f _size99})+ read_Get_slice_result_fields iprot rec{f_Get_slice_result_success=Just s}+ else do+ skip iprot _t97+ read_Get_slice_result_fields iprot rec+ 1 -> if _t97 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Get_slice_result_fields iprot rec{f_Get_slice_result_ire=Just s}+ else do+ skip iprot _t97+ read_Get_slice_result_fields iprot rec+ 2 -> if _t97 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Get_slice_result_fields iprot rec{f_Get_slice_result_ue=Just s}+ else do+ skip iprot _t97+ read_Get_slice_result_fields iprot rec+ 3 -> if _t97 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Get_slice_result_fields iprot rec{f_Get_slice_result_te=Just s}+ else do+ skip iprot _t97+ read_Get_slice_result_fields iprot rec+ _ -> do+ skip iprot _t97+ readFieldEnd iprot+ read_Get_slice_result_fields iprot rec+read_Get_slice_result iprot = do+ readStructBegin iprot+ rec <- read_Get_slice_result_fields iprot (Get_slice_result{f_Get_slice_result_success=Nothing,f_Get_slice_result_ire=Nothing,f_Get_slice_result_ue=Nothing,f_Get_slice_result_te=Nothing})+ readStructEnd iprot+ return rec+data Multiget_args = Multiget_args{f_Multiget_args_keyspace :: Maybe String,f_Multiget_args_keys :: Maybe [String],f_Multiget_args_column_path :: Maybe ColumnPath,f_Multiget_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Multiget_args oprot rec = do+ writeStructBegin oprot "Multiget_args"+ case f_Multiget_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Multiget_args_keys rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keys",T_LIST,2)+ (let {f [] = return (); f (_viter106:t) = do {writeString oprot _viter106;f t}} in do {writeListBegin oprot (T_STRING,length _v); f _v;writeListEnd oprot})+ writeFieldEnd oprot}+ case f_Multiget_args_column_path rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_path",T_STRUCT,3)+ write_ColumnPath oprot _v+ writeFieldEnd oprot}+ case f_Multiget_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,4)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Multiget_args_fields iprot rec = do+ (_,_t108,_id109) <- readFieldBegin iprot+ if _t108 == T_STOP then return rec else+ case _id109 of + 1 -> if _t108 == T_STRING then do+ s <- readString iprot+ read_Multiget_args_fields iprot rec{f_Multiget_args_keyspace=Just s}+ else do+ skip iprot _t108+ read_Multiget_args_fields iprot rec+ 2 -> if _t108 == T_LIST then do+ s <- (let {f 0 = return []; f n = do {v <- readString iprot;r <- f (n-1); return $ v:r}} in do {(_etype113,_size110) <- readListBegin iprot; f _size110})+ read_Multiget_args_fields iprot rec{f_Multiget_args_keys=Just s}+ else do+ skip iprot _t108+ read_Multiget_args_fields iprot rec+ 3 -> if _t108 == T_STRUCT then do+ s <- (read_ColumnPath iprot)+ read_Multiget_args_fields iprot rec{f_Multiget_args_column_path=Just s}+ else do+ skip iprot _t108+ read_Multiget_args_fields iprot rec+ 4 -> if _t108 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Multiget_args_fields iprot rec{f_Multiget_args_consistency_level=Just s}+ else do+ skip iprot _t108+ read_Multiget_args_fields iprot rec+ _ -> do+ skip iprot _t108+ readFieldEnd iprot+ read_Multiget_args_fields iprot rec+read_Multiget_args iprot = do+ readStructBegin iprot+ rec <- read_Multiget_args_fields iprot (Multiget_args{f_Multiget_args_keyspace=Nothing,f_Multiget_args_keys=Nothing,f_Multiget_args_column_path=Nothing,f_Multiget_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Multiget_result = Multiget_result{f_Multiget_result_success :: Maybe (Map.Map String ColumnOrSuperColumn),f_Multiget_result_ire :: Maybe InvalidRequestException,f_Multiget_result_ue :: Maybe UnavailableException,f_Multiget_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Multiget_result oprot rec = do+ writeStructBegin oprot "Multiget_result"+ case f_Multiget_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_MAP,0)+ (let {f [] = return (); f ((_kiter117,_viter118):t) = do {do {writeString oprot _kiter117;write_ColumnOrSuperColumn oprot _viter118};f t}} in do {writeMapBegin oprot (T_STRING,T_STRUCT,Map.size _v); f (Map.toList _v);writeMapEnd oprot})+ writeFieldEnd oprot}+ case f_Multiget_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Multiget_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,2)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Multiget_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,3)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Multiget_result_fields iprot rec = do+ (_,_t120,_id121) <- readFieldBegin iprot+ if _t120 == T_STOP then return rec else+ case _id121 of + 0 -> if _t120 == T_MAP then do+ s <- (let {f 0 = return []; f n = do {k <- readString iprot; v <- (read_ColumnOrSuperColumn iprot);r <- f (n-1); return $ (k,v):r}} in do {(_ktype123,_vtype124,_size122) <- readMapBegin iprot; l <- f _size122; return $ Map.fromList l})+ read_Multiget_result_fields iprot rec{f_Multiget_result_success=Just s}+ else do+ skip iprot _t120+ read_Multiget_result_fields iprot rec+ 1 -> if _t120 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Multiget_result_fields iprot rec{f_Multiget_result_ire=Just s}+ else do+ skip iprot _t120+ read_Multiget_result_fields iprot rec+ 2 -> if _t120 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Multiget_result_fields iprot rec{f_Multiget_result_ue=Just s}+ else do+ skip iprot _t120+ read_Multiget_result_fields iprot rec+ 3 -> if _t120 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Multiget_result_fields iprot rec{f_Multiget_result_te=Just s}+ else do+ skip iprot _t120+ read_Multiget_result_fields iprot rec+ _ -> do+ skip iprot _t120+ readFieldEnd iprot+ read_Multiget_result_fields iprot rec+read_Multiget_result iprot = do+ readStructBegin iprot+ rec <- read_Multiget_result_fields iprot (Multiget_result{f_Multiget_result_success=Nothing,f_Multiget_result_ire=Nothing,f_Multiget_result_ue=Nothing,f_Multiget_result_te=Nothing})+ readStructEnd iprot+ return rec+data Multiget_slice_args = Multiget_slice_args{f_Multiget_slice_args_keyspace :: Maybe String,f_Multiget_slice_args_keys :: Maybe [String],f_Multiget_slice_args_column_parent :: Maybe ColumnParent,f_Multiget_slice_args_predicate :: Maybe SlicePredicate,f_Multiget_slice_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Multiget_slice_args oprot rec = do+ writeStructBegin oprot "Multiget_slice_args"+ case f_Multiget_slice_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Multiget_slice_args_keys rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keys",T_LIST,2)+ (let {f [] = return (); f (_viter129:t) = do {writeString oprot _viter129;f t}} in do {writeListBegin oprot (T_STRING,length _v); f _v;writeListEnd oprot})+ writeFieldEnd oprot}+ case f_Multiget_slice_args_column_parent rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_parent",T_STRUCT,3)+ write_ColumnParent oprot _v+ writeFieldEnd oprot}+ case f_Multiget_slice_args_predicate rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("predicate",T_STRUCT,4)+ write_SlicePredicate oprot _v+ writeFieldEnd oprot}+ case f_Multiget_slice_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,5)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Multiget_slice_args_fields iprot rec = do+ (_,_t131,_id132) <- readFieldBegin iprot+ if _t131 == T_STOP then return rec else+ case _id132 of + 1 -> if _t131 == T_STRING then do+ s <- readString iprot+ read_Multiget_slice_args_fields iprot rec{f_Multiget_slice_args_keyspace=Just s}+ else do+ skip iprot _t131+ read_Multiget_slice_args_fields iprot rec+ 2 -> if _t131 == T_LIST then do+ s <- (let {f 0 = return []; f n = do {v <- readString iprot;r <- f (n-1); return $ v:r}} in do {(_etype136,_size133) <- readListBegin iprot; f _size133})+ read_Multiget_slice_args_fields iprot rec{f_Multiget_slice_args_keys=Just s}+ else do+ skip iprot _t131+ read_Multiget_slice_args_fields iprot rec+ 3 -> if _t131 == T_STRUCT then do+ s <- (read_ColumnParent iprot)+ read_Multiget_slice_args_fields iprot rec{f_Multiget_slice_args_column_parent=Just s}+ else do+ skip iprot _t131+ read_Multiget_slice_args_fields iprot rec+ 4 -> if _t131 == T_STRUCT then do+ s <- (read_SlicePredicate iprot)+ read_Multiget_slice_args_fields iprot rec{f_Multiget_slice_args_predicate=Just s}+ else do+ skip iprot _t131+ read_Multiget_slice_args_fields iprot rec+ 5 -> if _t131 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Multiget_slice_args_fields iprot rec{f_Multiget_slice_args_consistency_level=Just s}+ else do+ skip iprot _t131+ read_Multiget_slice_args_fields iprot rec+ _ -> do+ skip iprot _t131+ readFieldEnd iprot+ read_Multiget_slice_args_fields iprot rec+read_Multiget_slice_args iprot = do+ readStructBegin iprot+ rec <- read_Multiget_slice_args_fields iprot (Multiget_slice_args{f_Multiget_slice_args_keyspace=Nothing,f_Multiget_slice_args_keys=Nothing,f_Multiget_slice_args_column_parent=Nothing,f_Multiget_slice_args_predicate=Nothing,f_Multiget_slice_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Multiget_slice_result = Multiget_slice_result{f_Multiget_slice_result_success :: Maybe (Map.Map String [ColumnOrSuperColumn]),f_Multiget_slice_result_ire :: Maybe InvalidRequestException,f_Multiget_slice_result_ue :: Maybe UnavailableException,f_Multiget_slice_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Multiget_slice_result oprot rec = do+ writeStructBegin oprot "Multiget_slice_result"+ case f_Multiget_slice_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_MAP,0)+ (let {f [] = return (); f ((_kiter140,_viter141):t) = do {do {writeString oprot _kiter140;(let {f [] = return (); f (_viter142:t) = do {write_ColumnOrSuperColumn oprot _viter142;f t}} in do {writeListBegin oprot (T_STRUCT,length _viter141); f _viter141;writeListEnd oprot})};f t}} in do {writeMapBegin oprot (T_STRING,T_LIST,Map.size _v); f (Map.toList _v);writeMapEnd oprot})+ writeFieldEnd oprot}+ case f_Multiget_slice_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Multiget_slice_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,2)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Multiget_slice_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,3)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Multiget_slice_result_fields iprot rec = do+ (_,_t144,_id145) <- readFieldBegin iprot+ if _t144 == T_STOP then return rec else+ case _id145 of + 0 -> if _t144 == T_MAP then do+ s <- (let {f 0 = return []; f n = do {k <- readString iprot; v <- (let {f 0 = return []; f n = do {v <- (read_ColumnOrSuperColumn iprot);r <- f (n-1); return $ v:r}} in do {(_etype154,_size151) <- readListBegin iprot; f _size151});r <- f (n-1); return $ (k,v):r}} in do {(_ktype147,_vtype148,_size146) <- readMapBegin iprot; l <- f _size146; return $ Map.fromList l})+ read_Multiget_slice_result_fields iprot rec{f_Multiget_slice_result_success=Just s}+ else do+ skip iprot _t144+ read_Multiget_slice_result_fields iprot rec+ 1 -> if _t144 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Multiget_slice_result_fields iprot rec{f_Multiget_slice_result_ire=Just s}+ else do+ skip iprot _t144+ read_Multiget_slice_result_fields iprot rec+ 2 -> if _t144 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Multiget_slice_result_fields iprot rec{f_Multiget_slice_result_ue=Just s}+ else do+ skip iprot _t144+ read_Multiget_slice_result_fields iprot rec+ 3 -> if _t144 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Multiget_slice_result_fields iprot rec{f_Multiget_slice_result_te=Just s}+ else do+ skip iprot _t144+ read_Multiget_slice_result_fields iprot rec+ _ -> do+ skip iprot _t144+ readFieldEnd iprot+ read_Multiget_slice_result_fields iprot rec+read_Multiget_slice_result iprot = do+ readStructBegin iprot+ rec <- read_Multiget_slice_result_fields iprot (Multiget_slice_result{f_Multiget_slice_result_success=Nothing,f_Multiget_slice_result_ire=Nothing,f_Multiget_slice_result_ue=Nothing,f_Multiget_slice_result_te=Nothing})+ readStructEnd iprot+ return rec+data Get_count_args = Get_count_args{f_Get_count_args_keyspace :: Maybe String,f_Get_count_args_key :: Maybe String,f_Get_count_args_column_parent :: Maybe ColumnParent,f_Get_count_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Get_count_args oprot rec = do+ writeStructBegin oprot "Get_count_args"+ case f_Get_count_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_count_args_key rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("key",T_STRING,2)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_count_args_column_parent rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_parent",T_STRUCT,3)+ write_ColumnParent oprot _v+ writeFieldEnd oprot}+ case f_Get_count_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,4)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_count_args_fields iprot rec = do+ (_,_t159,_id160) <- readFieldBegin iprot+ if _t159 == T_STOP then return rec else+ case _id160 of + 1 -> if _t159 == T_STRING then do+ s <- readString iprot+ read_Get_count_args_fields iprot rec{f_Get_count_args_keyspace=Just s}+ else do+ skip iprot _t159+ read_Get_count_args_fields iprot rec+ 2 -> if _t159 == T_STRING then do+ s <- readString iprot+ read_Get_count_args_fields iprot rec{f_Get_count_args_key=Just s}+ else do+ skip iprot _t159+ read_Get_count_args_fields iprot rec+ 3 -> if _t159 == T_STRUCT then do+ s <- (read_ColumnParent iprot)+ read_Get_count_args_fields iprot rec{f_Get_count_args_column_parent=Just s}+ else do+ skip iprot _t159+ read_Get_count_args_fields iprot rec+ 4 -> if _t159 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Get_count_args_fields iprot rec{f_Get_count_args_consistency_level=Just s}+ else do+ skip iprot _t159+ read_Get_count_args_fields iprot rec+ _ -> do+ skip iprot _t159+ readFieldEnd iprot+ read_Get_count_args_fields iprot rec+read_Get_count_args iprot = do+ readStructBegin iprot+ rec <- read_Get_count_args_fields iprot (Get_count_args{f_Get_count_args_keyspace=Nothing,f_Get_count_args_key=Nothing,f_Get_count_args_column_parent=Nothing,f_Get_count_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Get_count_result = Get_count_result{f_Get_count_result_success :: Maybe Int,f_Get_count_result_ire :: Maybe InvalidRequestException,f_Get_count_result_ue :: Maybe UnavailableException,f_Get_count_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Get_count_result oprot rec = do+ writeStructBegin oprot "Get_count_result"+ case f_Get_count_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_I32,0)+ writeI32 oprot _v+ writeFieldEnd oprot}+ case f_Get_count_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Get_count_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,2)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Get_count_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,3)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_count_result_fields iprot rec = do+ (_,_t164,_id165) <- readFieldBegin iprot+ if _t164 == T_STOP then return rec else+ case _id165 of + 0 -> if _t164 == T_I32 then do+ s <- readI32 iprot+ read_Get_count_result_fields iprot rec{f_Get_count_result_success=Just s}+ else do+ skip iprot _t164+ read_Get_count_result_fields iprot rec+ 1 -> if _t164 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Get_count_result_fields iprot rec{f_Get_count_result_ire=Just s}+ else do+ skip iprot _t164+ read_Get_count_result_fields iprot rec+ 2 -> if _t164 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Get_count_result_fields iprot rec{f_Get_count_result_ue=Just s}+ else do+ skip iprot _t164+ read_Get_count_result_fields iprot rec+ 3 -> if _t164 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Get_count_result_fields iprot rec{f_Get_count_result_te=Just s}+ else do+ skip iprot _t164+ read_Get_count_result_fields iprot rec+ _ -> do+ skip iprot _t164+ readFieldEnd iprot+ read_Get_count_result_fields iprot rec+read_Get_count_result iprot = do+ readStructBegin iprot+ rec <- read_Get_count_result_fields iprot (Get_count_result{f_Get_count_result_success=Nothing,f_Get_count_result_ire=Nothing,f_Get_count_result_ue=Nothing,f_Get_count_result_te=Nothing})+ readStructEnd iprot+ return rec+data Get_key_range_args = Get_key_range_args{f_Get_key_range_args_keyspace :: Maybe String,f_Get_key_range_args_column_family :: Maybe String,f_Get_key_range_args_start :: Maybe String,f_Get_key_range_args_finish :: Maybe String,f_Get_key_range_args_count :: Maybe Int,f_Get_key_range_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Get_key_range_args oprot rec = do+ writeStructBegin oprot "Get_key_range_args"+ case f_Get_key_range_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_key_range_args_column_family rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_family",T_STRING,2)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_key_range_args_start rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("start",T_STRING,3)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_key_range_args_finish rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("finish",T_STRING,4)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_key_range_args_count rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("count",T_I32,5)+ writeI32 oprot _v+ writeFieldEnd oprot}+ case f_Get_key_range_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,6)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_key_range_args_fields iprot rec = do+ (_,_t169,_id170) <- readFieldBegin iprot+ if _t169 == T_STOP then return rec else+ case _id170 of + 1 -> if _t169 == T_STRING then do+ s <- readString iprot+ read_Get_key_range_args_fields iprot rec{f_Get_key_range_args_keyspace=Just s}+ else do+ skip iprot _t169+ read_Get_key_range_args_fields iprot rec+ 2 -> if _t169 == T_STRING then do+ s <- readString iprot+ read_Get_key_range_args_fields iprot rec{f_Get_key_range_args_column_family=Just s}+ else do+ skip iprot _t169+ read_Get_key_range_args_fields iprot rec+ 3 -> if _t169 == T_STRING then do+ s <- readString iprot+ read_Get_key_range_args_fields iprot rec{f_Get_key_range_args_start=Just s}+ else do+ skip iprot _t169+ read_Get_key_range_args_fields iprot rec+ 4 -> if _t169 == T_STRING then do+ s <- readString iprot+ read_Get_key_range_args_fields iprot rec{f_Get_key_range_args_finish=Just s}+ else do+ skip iprot _t169+ read_Get_key_range_args_fields iprot rec+ 5 -> if _t169 == T_I32 then do+ s <- readI32 iprot+ read_Get_key_range_args_fields iprot rec{f_Get_key_range_args_count=Just s}+ else do+ skip iprot _t169+ read_Get_key_range_args_fields iprot rec+ 6 -> if _t169 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Get_key_range_args_fields iprot rec{f_Get_key_range_args_consistency_level=Just s}+ else do+ skip iprot _t169+ read_Get_key_range_args_fields iprot rec+ _ -> do+ skip iprot _t169+ readFieldEnd iprot+ read_Get_key_range_args_fields iprot rec+read_Get_key_range_args iprot = do+ readStructBegin iprot+ rec <- read_Get_key_range_args_fields iprot (Get_key_range_args{f_Get_key_range_args_keyspace=Nothing,f_Get_key_range_args_column_family=Nothing,f_Get_key_range_args_start=Nothing,f_Get_key_range_args_finish=Nothing,f_Get_key_range_args_count=Nothing,f_Get_key_range_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Get_key_range_result = Get_key_range_result{f_Get_key_range_result_success :: Maybe [String],f_Get_key_range_result_ire :: Maybe InvalidRequestException,f_Get_key_range_result_ue :: Maybe UnavailableException,f_Get_key_range_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Get_key_range_result oprot rec = do+ writeStructBegin oprot "Get_key_range_result"+ case f_Get_key_range_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_LIST,0)+ (let {f [] = return (); f (_viter173:t) = do {writeString oprot _viter173;f t}} in do {writeListBegin oprot (T_STRING,length _v); f _v;writeListEnd oprot})+ writeFieldEnd oprot}+ case f_Get_key_range_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Get_key_range_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,2)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Get_key_range_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,3)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_key_range_result_fields iprot rec = do+ (_,_t175,_id176) <- readFieldBegin iprot+ if _t175 == T_STOP then return rec else+ case _id176 of + 0 -> if _t175 == T_LIST then do+ s <- (let {f 0 = return []; f n = do {v <- readString iprot;r <- f (n-1); return $ v:r}} in do {(_etype180,_size177) <- readListBegin iprot; f _size177})+ read_Get_key_range_result_fields iprot rec{f_Get_key_range_result_success=Just s}+ else do+ skip iprot _t175+ read_Get_key_range_result_fields iprot rec+ 1 -> if _t175 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Get_key_range_result_fields iprot rec{f_Get_key_range_result_ire=Just s}+ else do+ skip iprot _t175+ read_Get_key_range_result_fields iprot rec+ 2 -> if _t175 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Get_key_range_result_fields iprot rec{f_Get_key_range_result_ue=Just s}+ else do+ skip iprot _t175+ read_Get_key_range_result_fields iprot rec+ 3 -> if _t175 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Get_key_range_result_fields iprot rec{f_Get_key_range_result_te=Just s}+ else do+ skip iprot _t175+ read_Get_key_range_result_fields iprot rec+ _ -> do+ skip iprot _t175+ readFieldEnd iprot+ read_Get_key_range_result_fields iprot rec+read_Get_key_range_result iprot = do+ readStructBegin iprot+ rec <- read_Get_key_range_result_fields iprot (Get_key_range_result{f_Get_key_range_result_success=Nothing,f_Get_key_range_result_ire=Nothing,f_Get_key_range_result_ue=Nothing,f_Get_key_range_result_te=Nothing})+ readStructEnd iprot+ return rec+data Get_range_slice_args = Get_range_slice_args{f_Get_range_slice_args_keyspace :: Maybe String,f_Get_range_slice_args_column_parent :: Maybe ColumnParent,f_Get_range_slice_args_predicate :: Maybe SlicePredicate,f_Get_range_slice_args_start_key :: Maybe String,f_Get_range_slice_args_finish_key :: Maybe String,f_Get_range_slice_args_row_count :: Maybe Int,f_Get_range_slice_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Get_range_slice_args oprot rec = do+ writeStructBegin oprot "Get_range_slice_args"+ case f_Get_range_slice_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_range_slice_args_column_parent rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_parent",T_STRUCT,2)+ write_ColumnParent oprot _v+ writeFieldEnd oprot}+ case f_Get_range_slice_args_predicate rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("predicate",T_STRUCT,3)+ write_SlicePredicate oprot _v+ writeFieldEnd oprot}+ case f_Get_range_slice_args_start_key rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("start_key",T_STRING,4)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_range_slice_args_finish_key rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("finish_key",T_STRING,5)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Get_range_slice_args_row_count rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("row_count",T_I32,6)+ writeI32 oprot _v+ writeFieldEnd oprot}+ case f_Get_range_slice_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,7)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_range_slice_args_fields iprot rec = do+ (_,_t185,_id186) <- readFieldBegin iprot+ if _t185 == T_STOP then return rec else+ case _id186 of + 1 -> if _t185 == T_STRING then do+ s <- readString iprot+ read_Get_range_slice_args_fields iprot rec{f_Get_range_slice_args_keyspace=Just s}+ else do+ skip iprot _t185+ read_Get_range_slice_args_fields iprot rec+ 2 -> if _t185 == T_STRUCT then do+ s <- (read_ColumnParent iprot)+ read_Get_range_slice_args_fields iprot rec{f_Get_range_slice_args_column_parent=Just s}+ else do+ skip iprot _t185+ read_Get_range_slice_args_fields iprot rec+ 3 -> if _t185 == T_STRUCT then do+ s <- (read_SlicePredicate iprot)+ read_Get_range_slice_args_fields iprot rec{f_Get_range_slice_args_predicate=Just s}+ else do+ skip iprot _t185+ read_Get_range_slice_args_fields iprot rec+ 4 -> if _t185 == T_STRING then do+ s <- readString iprot+ read_Get_range_slice_args_fields iprot rec{f_Get_range_slice_args_start_key=Just s}+ else do+ skip iprot _t185+ read_Get_range_slice_args_fields iprot rec+ 5 -> if _t185 == T_STRING then do+ s <- readString iprot+ read_Get_range_slice_args_fields iprot rec{f_Get_range_slice_args_finish_key=Just s}+ else do+ skip iprot _t185+ read_Get_range_slice_args_fields iprot rec+ 6 -> if _t185 == T_I32 then do+ s <- readI32 iprot+ read_Get_range_slice_args_fields iprot rec{f_Get_range_slice_args_row_count=Just s}+ else do+ skip iprot _t185+ read_Get_range_slice_args_fields iprot rec+ 7 -> if _t185 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Get_range_slice_args_fields iprot rec{f_Get_range_slice_args_consistency_level=Just s}+ else do+ skip iprot _t185+ read_Get_range_slice_args_fields iprot rec+ _ -> do+ skip iprot _t185+ readFieldEnd iprot+ read_Get_range_slice_args_fields iprot rec+read_Get_range_slice_args iprot = do+ readStructBegin iprot+ rec <- read_Get_range_slice_args_fields iprot (Get_range_slice_args{f_Get_range_slice_args_keyspace=Nothing,f_Get_range_slice_args_column_parent=Nothing,f_Get_range_slice_args_predicate=Nothing,f_Get_range_slice_args_start_key=Nothing,f_Get_range_slice_args_finish_key=Nothing,f_Get_range_slice_args_row_count=Nothing,f_Get_range_slice_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Get_range_slice_result = Get_range_slice_result{f_Get_range_slice_result_success :: Maybe [KeySlice],f_Get_range_slice_result_ire :: Maybe InvalidRequestException,f_Get_range_slice_result_ue :: Maybe UnavailableException,f_Get_range_slice_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Get_range_slice_result oprot rec = do+ writeStructBegin oprot "Get_range_slice_result"+ case f_Get_range_slice_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_LIST,0)+ (let {f [] = return (); f (_viter189:t) = do {write_KeySlice oprot _viter189;f t}} in do {writeListBegin oprot (T_STRUCT,length _v); f _v;writeListEnd oprot})+ writeFieldEnd oprot}+ case f_Get_range_slice_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Get_range_slice_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,2)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Get_range_slice_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,3)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_range_slice_result_fields iprot rec = do+ (_,_t191,_id192) <- readFieldBegin iprot+ if _t191 == T_STOP then return rec else+ case _id192 of + 0 -> if _t191 == T_LIST then do+ s <- (let {f 0 = return []; f n = do {v <- (read_KeySlice iprot);r <- f (n-1); return $ v:r}} in do {(_etype196,_size193) <- readListBegin iprot; f _size193})+ read_Get_range_slice_result_fields iprot rec{f_Get_range_slice_result_success=Just s}+ else do+ skip iprot _t191+ read_Get_range_slice_result_fields iprot rec+ 1 -> if _t191 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Get_range_slice_result_fields iprot rec{f_Get_range_slice_result_ire=Just s}+ else do+ skip iprot _t191+ read_Get_range_slice_result_fields iprot rec+ 2 -> if _t191 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Get_range_slice_result_fields iprot rec{f_Get_range_slice_result_ue=Just s}+ else do+ skip iprot _t191+ read_Get_range_slice_result_fields iprot rec+ 3 -> if _t191 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Get_range_slice_result_fields iprot rec{f_Get_range_slice_result_te=Just s}+ else do+ skip iprot _t191+ read_Get_range_slice_result_fields iprot rec+ _ -> do+ skip iprot _t191+ readFieldEnd iprot+ read_Get_range_slice_result_fields iprot rec+read_Get_range_slice_result iprot = do+ readStructBegin iprot+ rec <- read_Get_range_slice_result_fields iprot (Get_range_slice_result{f_Get_range_slice_result_success=Nothing,f_Get_range_slice_result_ire=Nothing,f_Get_range_slice_result_ue=Nothing,f_Get_range_slice_result_te=Nothing})+ readStructEnd iprot+ return rec+data Insert_args = Insert_args{f_Insert_args_keyspace :: Maybe String,f_Insert_args_key :: Maybe String,f_Insert_args_column_path :: Maybe ColumnPath,f_Insert_args_value :: Maybe String,f_Insert_args_timestamp :: Maybe Int64,f_Insert_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Insert_args oprot rec = do+ writeStructBegin oprot "Insert_args"+ case f_Insert_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Insert_args_key rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("key",T_STRING,2)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Insert_args_column_path rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_path",T_STRUCT,3)+ write_ColumnPath oprot _v+ writeFieldEnd oprot}+ case f_Insert_args_value rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("value",T_STRING,4)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Insert_args_timestamp rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("timestamp",T_I64,5)+ writeI64 oprot _v+ writeFieldEnd oprot}+ case f_Insert_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,6)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Insert_args_fields iprot rec = do+ (_,_t201,_id202) <- readFieldBegin iprot+ if _t201 == T_STOP then return rec else+ case _id202 of + 1 -> if _t201 == T_STRING then do+ s <- readString iprot+ read_Insert_args_fields iprot rec{f_Insert_args_keyspace=Just s}+ else do+ skip iprot _t201+ read_Insert_args_fields iprot rec+ 2 -> if _t201 == T_STRING then do+ s <- readString iprot+ read_Insert_args_fields iprot rec{f_Insert_args_key=Just s}+ else do+ skip iprot _t201+ read_Insert_args_fields iprot rec+ 3 -> if _t201 == T_STRUCT then do+ s <- (read_ColumnPath iprot)+ read_Insert_args_fields iprot rec{f_Insert_args_column_path=Just s}+ else do+ skip iprot _t201+ read_Insert_args_fields iprot rec+ 4 -> if _t201 == T_STRING then do+ s <- readString iprot+ read_Insert_args_fields iprot rec{f_Insert_args_value=Just s}+ else do+ skip iprot _t201+ read_Insert_args_fields iprot rec+ 5 -> if _t201 == T_I64 then do+ s <- readI64 iprot+ read_Insert_args_fields iprot rec{f_Insert_args_timestamp=Just s}+ else do+ skip iprot _t201+ read_Insert_args_fields iprot rec+ 6 -> if _t201 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Insert_args_fields iprot rec{f_Insert_args_consistency_level=Just s}+ else do+ skip iprot _t201+ read_Insert_args_fields iprot rec+ _ -> do+ skip iprot _t201+ readFieldEnd iprot+ read_Insert_args_fields iprot rec+read_Insert_args iprot = do+ readStructBegin iprot+ rec <- read_Insert_args_fields iprot (Insert_args{f_Insert_args_keyspace=Nothing,f_Insert_args_key=Nothing,f_Insert_args_column_path=Nothing,f_Insert_args_value=Nothing,f_Insert_args_timestamp=Nothing,f_Insert_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Insert_result = Insert_result{f_Insert_result_ire :: Maybe InvalidRequestException,f_Insert_result_ue :: Maybe UnavailableException,f_Insert_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Insert_result oprot rec = do+ writeStructBegin oprot "Insert_result"+ case f_Insert_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Insert_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,2)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Insert_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,3)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Insert_result_fields iprot rec = do+ (_,_t206,_id207) <- readFieldBegin iprot+ if _t206 == T_STOP then return rec else+ case _id207 of + 1 -> if _t206 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Insert_result_fields iprot rec{f_Insert_result_ire=Just s}+ else do+ skip iprot _t206+ read_Insert_result_fields iprot rec+ 2 -> if _t206 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Insert_result_fields iprot rec{f_Insert_result_ue=Just s}+ else do+ skip iprot _t206+ read_Insert_result_fields iprot rec+ 3 -> if _t206 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Insert_result_fields iprot rec{f_Insert_result_te=Just s}+ else do+ skip iprot _t206+ read_Insert_result_fields iprot rec+ _ -> do+ skip iprot _t206+ readFieldEnd iprot+ read_Insert_result_fields iprot rec+read_Insert_result iprot = do+ readStructBegin iprot+ rec <- read_Insert_result_fields iprot (Insert_result{f_Insert_result_ire=Nothing,f_Insert_result_ue=Nothing,f_Insert_result_te=Nothing})+ readStructEnd iprot+ return rec+data Batch_insert_args = Batch_insert_args{f_Batch_insert_args_keyspace :: Maybe String,f_Batch_insert_args_key :: Maybe String,f_Batch_insert_args_cfmap :: Maybe (Map.Map String [ColumnOrSuperColumn]),f_Batch_insert_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Batch_insert_args oprot rec = do+ writeStructBegin oprot "Batch_insert_args"+ case f_Batch_insert_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Batch_insert_args_key rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("key",T_STRING,2)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Batch_insert_args_cfmap rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("cfmap",T_MAP,3)+ (let {f [] = return (); f ((_kiter210,_viter211):t) = do {do {writeString oprot _kiter210;(let {f [] = return (); f (_viter212:t) = do {write_ColumnOrSuperColumn oprot _viter212;f t}} in do {writeListBegin oprot (T_STRUCT,length _viter211); f _viter211;writeListEnd oprot})};f t}} in do {writeMapBegin oprot (T_STRING,T_LIST,Map.size _v); f (Map.toList _v);writeMapEnd oprot})+ writeFieldEnd oprot}+ case f_Batch_insert_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,4)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Batch_insert_args_fields iprot rec = do+ (_,_t214,_id215) <- readFieldBegin iprot+ if _t214 == T_STOP then return rec else+ case _id215 of + 1 -> if _t214 == T_STRING then do+ s <- readString iprot+ read_Batch_insert_args_fields iprot rec{f_Batch_insert_args_keyspace=Just s}+ else do+ skip iprot _t214+ read_Batch_insert_args_fields iprot rec+ 2 -> if _t214 == T_STRING then do+ s <- readString iprot+ read_Batch_insert_args_fields iprot rec{f_Batch_insert_args_key=Just s}+ else do+ skip iprot _t214+ read_Batch_insert_args_fields iprot rec+ 3 -> if _t214 == T_MAP then do+ s <- (let {f 0 = return []; f n = do {k <- readString iprot; v <- (let {f 0 = return []; f n = do {v <- (read_ColumnOrSuperColumn iprot);r <- f (n-1); return $ v:r}} in do {(_etype224,_size221) <- readListBegin iprot; f _size221});r <- f (n-1); return $ (k,v):r}} in do {(_ktype217,_vtype218,_size216) <- readMapBegin iprot; l <- f _size216; return $ Map.fromList l})+ read_Batch_insert_args_fields iprot rec{f_Batch_insert_args_cfmap=Just s}+ else do+ skip iprot _t214+ read_Batch_insert_args_fields iprot rec+ 4 -> if _t214 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Batch_insert_args_fields iprot rec{f_Batch_insert_args_consistency_level=Just s}+ else do+ skip iprot _t214+ read_Batch_insert_args_fields iprot rec+ _ -> do+ skip iprot _t214+ readFieldEnd iprot+ read_Batch_insert_args_fields iprot rec+read_Batch_insert_args iprot = do+ readStructBegin iprot+ rec <- read_Batch_insert_args_fields iprot (Batch_insert_args{f_Batch_insert_args_keyspace=Nothing,f_Batch_insert_args_key=Nothing,f_Batch_insert_args_cfmap=Nothing,f_Batch_insert_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Batch_insert_result = Batch_insert_result{f_Batch_insert_result_ire :: Maybe InvalidRequestException,f_Batch_insert_result_ue :: Maybe UnavailableException,f_Batch_insert_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Batch_insert_result oprot rec = do+ writeStructBegin oprot "Batch_insert_result"+ case f_Batch_insert_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Batch_insert_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,2)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Batch_insert_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,3)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Batch_insert_result_fields iprot rec = do+ (_,_t229,_id230) <- readFieldBegin iprot+ if _t229 == T_STOP then return rec else+ case _id230 of + 1 -> if _t229 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Batch_insert_result_fields iprot rec{f_Batch_insert_result_ire=Just s}+ else do+ skip iprot _t229+ read_Batch_insert_result_fields iprot rec+ 2 -> if _t229 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Batch_insert_result_fields iprot rec{f_Batch_insert_result_ue=Just s}+ else do+ skip iprot _t229+ read_Batch_insert_result_fields iprot rec+ 3 -> if _t229 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Batch_insert_result_fields iprot rec{f_Batch_insert_result_te=Just s}+ else do+ skip iprot _t229+ read_Batch_insert_result_fields iprot rec+ _ -> do+ skip iprot _t229+ readFieldEnd iprot+ read_Batch_insert_result_fields iprot rec+read_Batch_insert_result iprot = do+ readStructBegin iprot+ rec <- read_Batch_insert_result_fields iprot (Batch_insert_result{f_Batch_insert_result_ire=Nothing,f_Batch_insert_result_ue=Nothing,f_Batch_insert_result_te=Nothing})+ readStructEnd iprot+ return rec+data Remove_args = Remove_args{f_Remove_args_keyspace :: Maybe String,f_Remove_args_key :: Maybe String,f_Remove_args_column_path :: Maybe ColumnPath,f_Remove_args_timestamp :: Maybe Int64,f_Remove_args_consistency_level :: Maybe ConsistencyLevel} deriving (Show,Eq,Ord,Typeable)+write_Remove_args oprot rec = do+ writeStructBegin oprot "Remove_args"+ case f_Remove_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Remove_args_key rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("key",T_STRING,2)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Remove_args_column_path rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_path",T_STRUCT,3)+ write_ColumnPath oprot _v+ writeFieldEnd oprot}+ case f_Remove_args_timestamp rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("timestamp",T_I64,4)+ writeI64 oprot _v+ writeFieldEnd oprot}+ case f_Remove_args_consistency_level rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("consistency_level",T_I32,5)+ writeI32 oprot (fromEnum _v)+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Remove_args_fields iprot rec = do+ (_,_t234,_id235) <- readFieldBegin iprot+ if _t234 == T_STOP then return rec else+ case _id235 of + 1 -> if _t234 == T_STRING then do+ s <- readString iprot+ read_Remove_args_fields iprot rec{f_Remove_args_keyspace=Just s}+ else do+ skip iprot _t234+ read_Remove_args_fields iprot rec+ 2 -> if _t234 == T_STRING then do+ s <- readString iprot+ read_Remove_args_fields iprot rec{f_Remove_args_key=Just s}+ else do+ skip iprot _t234+ read_Remove_args_fields iprot rec+ 3 -> if _t234 == T_STRUCT then do+ s <- (read_ColumnPath iprot)+ read_Remove_args_fields iprot rec{f_Remove_args_column_path=Just s}+ else do+ skip iprot _t234+ read_Remove_args_fields iprot rec+ 4 -> if _t234 == T_I64 then do+ s <- readI64 iprot+ read_Remove_args_fields iprot rec{f_Remove_args_timestamp=Just s}+ else do+ skip iprot _t234+ read_Remove_args_fields iprot rec+ 5 -> if _t234 == T_I32 then do+ s <- (do {i <- readI32 iprot; return (toEnum i :: ConsistencyLevel)})+ read_Remove_args_fields iprot rec{f_Remove_args_consistency_level=Just s}+ else do+ skip iprot _t234+ read_Remove_args_fields iprot rec+ _ -> do+ skip iprot _t234+ readFieldEnd iprot+ read_Remove_args_fields iprot rec+read_Remove_args iprot = do+ readStructBegin iprot+ rec <- read_Remove_args_fields iprot (Remove_args{f_Remove_args_keyspace=Nothing,f_Remove_args_key=Nothing,f_Remove_args_column_path=Nothing,f_Remove_args_timestamp=Nothing,f_Remove_args_consistency_level=Nothing})+ readStructEnd iprot+ return rec+data Remove_result = Remove_result{f_Remove_result_ire :: Maybe InvalidRequestException,f_Remove_result_ue :: Maybe UnavailableException,f_Remove_result_te :: Maybe TimedOutException} deriving (Show,Eq,Ord,Typeable)+write_Remove_result oprot rec = do+ writeStructBegin oprot "Remove_result"+ case f_Remove_result_ire rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ire",T_STRUCT,1)+ write_InvalidRequestException oprot _v+ writeFieldEnd oprot}+ case f_Remove_result_ue rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("ue",T_STRUCT,2)+ write_UnavailableException oprot _v+ writeFieldEnd oprot}+ case f_Remove_result_te rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("te",T_STRUCT,3)+ write_TimedOutException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Remove_result_fields iprot rec = do+ (_,_t239,_id240) <- readFieldBegin iprot+ if _t239 == T_STOP then return rec else+ case _id240 of + 1 -> if _t239 == T_STRUCT then do+ s <- (read_InvalidRequestException iprot)+ read_Remove_result_fields iprot rec{f_Remove_result_ire=Just s}+ else do+ skip iprot _t239+ read_Remove_result_fields iprot rec+ 2 -> if _t239 == T_STRUCT then do+ s <- (read_UnavailableException iprot)+ read_Remove_result_fields iprot rec{f_Remove_result_ue=Just s}+ else do+ skip iprot _t239+ read_Remove_result_fields iprot rec+ 3 -> if _t239 == T_STRUCT then do+ s <- (read_TimedOutException iprot)+ read_Remove_result_fields iprot rec{f_Remove_result_te=Just s}+ else do+ skip iprot _t239+ read_Remove_result_fields iprot rec+ _ -> do+ skip iprot _t239+ readFieldEnd iprot+ read_Remove_result_fields iprot rec+read_Remove_result iprot = do+ readStructBegin iprot+ rec <- read_Remove_result_fields iprot (Remove_result{f_Remove_result_ire=Nothing,f_Remove_result_ue=Nothing,f_Remove_result_te=Nothing})+ readStructEnd iprot+ return rec+data Get_string_property_args = Get_string_property_args{f_Get_string_property_args_property :: Maybe String} deriving (Show,Eq,Ord,Typeable)+write_Get_string_property_args oprot rec = do+ writeStructBegin oprot "Get_string_property_args"+ case f_Get_string_property_args_property rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("property",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_string_property_args_fields iprot rec = do+ (_,_t244,_id245) <- readFieldBegin iprot+ if _t244 == T_STOP then return rec else+ case _id245 of + 1 -> if _t244 == T_STRING then do+ s <- readString iprot+ read_Get_string_property_args_fields iprot rec{f_Get_string_property_args_property=Just s}+ else do+ skip iprot _t244+ read_Get_string_property_args_fields iprot rec+ _ -> do+ skip iprot _t244+ readFieldEnd iprot+ read_Get_string_property_args_fields iprot rec+read_Get_string_property_args iprot = do+ readStructBegin iprot+ rec <- read_Get_string_property_args_fields iprot (Get_string_property_args{f_Get_string_property_args_property=Nothing})+ readStructEnd iprot+ return rec+data Get_string_property_result = Get_string_property_result{f_Get_string_property_result_success :: Maybe String} deriving (Show,Eq,Ord,Typeable)+write_Get_string_property_result oprot rec = do+ writeStructBegin oprot "Get_string_property_result"+ case f_Get_string_property_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_STRING,0)+ writeString oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_string_property_result_fields iprot rec = do+ (_,_t249,_id250) <- readFieldBegin iprot+ if _t249 == T_STOP then return rec else+ case _id250 of + 0 -> if _t249 == T_STRING then do+ s <- readString iprot+ read_Get_string_property_result_fields iprot rec{f_Get_string_property_result_success=Just s}+ else do+ skip iprot _t249+ read_Get_string_property_result_fields iprot rec+ _ -> do+ skip iprot _t249+ readFieldEnd iprot+ read_Get_string_property_result_fields iprot rec+read_Get_string_property_result iprot = do+ readStructBegin iprot+ rec <- read_Get_string_property_result_fields iprot (Get_string_property_result{f_Get_string_property_result_success=Nothing})+ readStructEnd iprot+ return rec+data Get_string_list_property_args = Get_string_list_property_args{f_Get_string_list_property_args_property :: Maybe String} deriving (Show,Eq,Ord,Typeable)+write_Get_string_list_property_args oprot rec = do+ writeStructBegin oprot "Get_string_list_property_args"+ case f_Get_string_list_property_args_property rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("property",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_string_list_property_args_fields iprot rec = do+ (_,_t254,_id255) <- readFieldBegin iprot+ if _t254 == T_STOP then return rec else+ case _id255 of + 1 -> if _t254 == T_STRING then do+ s <- readString iprot+ read_Get_string_list_property_args_fields iprot rec{f_Get_string_list_property_args_property=Just s}+ else do+ skip iprot _t254+ read_Get_string_list_property_args_fields iprot rec+ _ -> do+ skip iprot _t254+ readFieldEnd iprot+ read_Get_string_list_property_args_fields iprot rec+read_Get_string_list_property_args iprot = do+ readStructBegin iprot+ rec <- read_Get_string_list_property_args_fields iprot (Get_string_list_property_args{f_Get_string_list_property_args_property=Nothing})+ readStructEnd iprot+ return rec+data Get_string_list_property_result = Get_string_list_property_result{f_Get_string_list_property_result_success :: Maybe [String]} deriving (Show,Eq,Ord,Typeable)+write_Get_string_list_property_result oprot rec = do+ writeStructBegin oprot "Get_string_list_property_result"+ case f_Get_string_list_property_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_LIST,0)+ (let {f [] = return (); f (_viter258:t) = do {writeString oprot _viter258;f t}} in do {writeListBegin oprot (T_STRING,length _v); f _v;writeListEnd oprot})+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Get_string_list_property_result_fields iprot rec = do+ (_,_t260,_id261) <- readFieldBegin iprot+ if _t260 == T_STOP then return rec else+ case _id261 of + 0 -> if _t260 == T_LIST then do+ s <- (let {f 0 = return []; f n = do {v <- readString iprot;r <- f (n-1); return $ v:r}} in do {(_etype265,_size262) <- readListBegin iprot; f _size262})+ read_Get_string_list_property_result_fields iprot rec{f_Get_string_list_property_result_success=Just s}+ else do+ skip iprot _t260+ read_Get_string_list_property_result_fields iprot rec+ _ -> do+ skip iprot _t260+ readFieldEnd iprot+ read_Get_string_list_property_result_fields iprot rec+read_Get_string_list_property_result iprot = do+ readStructBegin iprot+ rec <- read_Get_string_list_property_result_fields iprot (Get_string_list_property_result{f_Get_string_list_property_result_success=Nothing})+ readStructEnd iprot+ return rec+data Describe_keyspace_args = Describe_keyspace_args{f_Describe_keyspace_args_keyspace :: Maybe String} deriving (Show,Eq,Ord,Typeable)+write_Describe_keyspace_args oprot rec = do+ writeStructBegin oprot "Describe_keyspace_args"+ case f_Describe_keyspace_args_keyspace rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("keyspace",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Describe_keyspace_args_fields iprot rec = do+ (_,_t270,_id271) <- readFieldBegin iprot+ if _t270 == T_STOP then return rec else+ case _id271 of + 1 -> if _t270 == T_STRING then do+ s <- readString iprot+ read_Describe_keyspace_args_fields iprot rec{f_Describe_keyspace_args_keyspace=Just s}+ else do+ skip iprot _t270+ read_Describe_keyspace_args_fields iprot rec+ _ -> do+ skip iprot _t270+ readFieldEnd iprot+ read_Describe_keyspace_args_fields iprot rec+read_Describe_keyspace_args iprot = do+ readStructBegin iprot+ rec <- read_Describe_keyspace_args_fields iprot (Describe_keyspace_args{f_Describe_keyspace_args_keyspace=Nothing})+ readStructEnd iprot+ return rec+data Describe_keyspace_result = Describe_keyspace_result{f_Describe_keyspace_result_success :: Maybe (Map.Map String (Map.Map String String)),f_Describe_keyspace_result_nfe :: Maybe NotFoundException} deriving (Show,Eq,Ord,Typeable)+write_Describe_keyspace_result oprot rec = do+ writeStructBegin oprot "Describe_keyspace_result"+ case f_Describe_keyspace_result_success rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("success",T_MAP,0)+ (let {f [] = return (); f ((_kiter274,_viter275):t) = do {do {writeString oprot _kiter274;(let {f [] = return (); f ((_kiter276,_viter277):t) = do {do {writeString oprot _kiter276;writeString oprot _viter277};f t}} in do {writeMapBegin oprot (T_STRING,T_STRING,Map.size _viter275); f (Map.toList _viter275);writeMapEnd oprot})};f t}} in do {writeMapBegin oprot (T_STRING,T_MAP,Map.size _v); f (Map.toList _v);writeMapEnd oprot})+ writeFieldEnd oprot}+ case f_Describe_keyspace_result_nfe rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("nfe",T_STRUCT,1)+ write_NotFoundException oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Describe_keyspace_result_fields iprot rec = do+ (_,_t279,_id280) <- readFieldBegin iprot+ if _t279 == T_STOP then return rec else+ case _id280 of + 0 -> if _t279 == T_MAP then do+ s <- (let {f 0 = return []; f n = do {k <- readString iprot; v <- (let {f 0 = return []; f n = do {k <- readString iprot; v <- readString iprot;r <- f (n-1); return $ (k,v):r}} in do {(_ktype287,_vtype288,_size286) <- readMapBegin iprot; l <- f _size286; return $ Map.fromList l});r <- f (n-1); return $ (k,v):r}} in do {(_ktype282,_vtype283,_size281) <- readMapBegin iprot; l <- f _size281; return $ Map.fromList l})+ read_Describe_keyspace_result_fields iprot rec{f_Describe_keyspace_result_success=Just s}+ else do+ skip iprot _t279+ read_Describe_keyspace_result_fields iprot rec+ 1 -> if _t279 == T_STRUCT then do+ s <- (read_NotFoundException iprot)+ read_Describe_keyspace_result_fields iprot rec{f_Describe_keyspace_result_nfe=Just s}+ else do+ skip iprot _t279+ read_Describe_keyspace_result_fields iprot rec+ _ -> do+ skip iprot _t279+ readFieldEnd iprot+ read_Describe_keyspace_result_fields iprot rec+read_Describe_keyspace_result iprot = do+ readStructBegin iprot+ rec <- read_Describe_keyspace_result_fields iprot (Describe_keyspace_result{f_Describe_keyspace_result_success=Nothing,f_Describe_keyspace_result_nfe=Nothing})+ readStructEnd iprot+ return rec+process_get (seqid, iprot, oprot, handler) = do+ args <- read_Get_args iprot+ readMessageEnd iprot+ rs <- return (Get_result Nothing Nothing Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ res <- Iface.get handler (f_Get_args_keyspace args) (f_Get_args_key args) (f_Get_args_column_path args) (f_Get_args_consistency_level args)+ return rs{f_Get_result_success= Just res})+ (\e -> + return rs{f_Get_result_ire =Just e}))+ (\e -> + return rs{f_Get_result_nfe =Just e}))+ (\e -> + return rs{f_Get_result_ue =Just e}))+ (\e -> + return rs{f_Get_result_te =Just e}))+ writeMessageBegin oprot ("get", M_REPLY, seqid);+ write_Get_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_get_slice (seqid, iprot, oprot, handler) = do+ args <- read_Get_slice_args iprot+ readMessageEnd iprot+ rs <- return (Get_slice_result Nothing Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ res <- Iface.get_slice handler (f_Get_slice_args_keyspace args) (f_Get_slice_args_key args) (f_Get_slice_args_column_parent args) (f_Get_slice_args_predicate args) (f_Get_slice_args_consistency_level args)+ return rs{f_Get_slice_result_success= Just res})+ (\e -> + return rs{f_Get_slice_result_ire =Just e}))+ (\e -> + return rs{f_Get_slice_result_ue =Just e}))+ (\e -> + return rs{f_Get_slice_result_te =Just e}))+ writeMessageBegin oprot ("get_slice", M_REPLY, seqid);+ write_Get_slice_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_multiget (seqid, iprot, oprot, handler) = do+ args <- read_Multiget_args iprot+ readMessageEnd iprot+ rs <- return (Multiget_result Nothing Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ res <- Iface.multiget handler (f_Multiget_args_keyspace args) (f_Multiget_args_keys args) (f_Multiget_args_column_path args) (f_Multiget_args_consistency_level args)+ return rs{f_Multiget_result_success= Just res})+ (\e -> + return rs{f_Multiget_result_ire =Just e}))+ (\e -> + return rs{f_Multiget_result_ue =Just e}))+ (\e -> + return rs{f_Multiget_result_te =Just e}))+ writeMessageBegin oprot ("multiget", M_REPLY, seqid);+ write_Multiget_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_multiget_slice (seqid, iprot, oprot, handler) = do+ args <- read_Multiget_slice_args iprot+ readMessageEnd iprot+ rs <- return (Multiget_slice_result Nothing Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ res <- Iface.multiget_slice handler (f_Multiget_slice_args_keyspace args) (f_Multiget_slice_args_keys args) (f_Multiget_slice_args_column_parent args) (f_Multiget_slice_args_predicate args) (f_Multiget_slice_args_consistency_level args)+ return rs{f_Multiget_slice_result_success= Just res})+ (\e -> + return rs{f_Multiget_slice_result_ire =Just e}))+ (\e -> + return rs{f_Multiget_slice_result_ue =Just e}))+ (\e -> + return rs{f_Multiget_slice_result_te =Just e}))+ writeMessageBegin oprot ("multiget_slice", M_REPLY, seqid);+ write_Multiget_slice_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_get_count (seqid, iprot, oprot, handler) = do+ args <- read_Get_count_args iprot+ readMessageEnd iprot+ rs <- return (Get_count_result Nothing Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ res <- Iface.get_count handler (f_Get_count_args_keyspace args) (f_Get_count_args_key args) (f_Get_count_args_column_parent args) (f_Get_count_args_consistency_level args)+ return rs{f_Get_count_result_success= Just res})+ (\e -> + return rs{f_Get_count_result_ire =Just e}))+ (\e -> + return rs{f_Get_count_result_ue =Just e}))+ (\e -> + return rs{f_Get_count_result_te =Just e}))+ writeMessageBegin oprot ("get_count", M_REPLY, seqid);+ write_Get_count_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_get_key_range (seqid, iprot, oprot, handler) = do+ args <- read_Get_key_range_args iprot+ readMessageEnd iprot+ rs <- return (Get_key_range_result Nothing Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ res <- Iface.get_key_range handler (f_Get_key_range_args_keyspace args) (f_Get_key_range_args_column_family args) (f_Get_key_range_args_start args) (f_Get_key_range_args_finish args) (f_Get_key_range_args_count args) (f_Get_key_range_args_consistency_level args)+ return rs{f_Get_key_range_result_success= Just res})+ (\e -> + return rs{f_Get_key_range_result_ire =Just e}))+ (\e -> + return rs{f_Get_key_range_result_ue =Just e}))+ (\e -> + return rs{f_Get_key_range_result_te =Just e}))+ writeMessageBegin oprot ("get_key_range", M_REPLY, seqid);+ write_Get_key_range_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_get_range_slice (seqid, iprot, oprot, handler) = do+ args <- read_Get_range_slice_args iprot+ readMessageEnd iprot+ rs <- return (Get_range_slice_result Nothing Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ res <- Iface.get_range_slice handler (f_Get_range_slice_args_keyspace args) (f_Get_range_slice_args_column_parent args) (f_Get_range_slice_args_predicate args) (f_Get_range_slice_args_start_key args) (f_Get_range_slice_args_finish_key args) (f_Get_range_slice_args_row_count args) (f_Get_range_slice_args_consistency_level args)+ return rs{f_Get_range_slice_result_success= Just res})+ (\e -> + return rs{f_Get_range_slice_result_ire =Just e}))+ (\e -> + return rs{f_Get_range_slice_result_ue =Just e}))+ (\e -> + return rs{f_Get_range_slice_result_te =Just e}))+ writeMessageBegin oprot ("get_range_slice", M_REPLY, seqid);+ write_Get_range_slice_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_insert (seqid, iprot, oprot, handler) = do+ args <- read_Insert_args iprot+ readMessageEnd iprot+ rs <- return (Insert_result Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ Iface.insert handler (f_Insert_args_keyspace args) (f_Insert_args_key args) (f_Insert_args_column_path args) (f_Insert_args_value args) (f_Insert_args_timestamp args) (f_Insert_args_consistency_level args)+ return rs)+ (\e -> + return rs{f_Insert_result_ire =Just e}))+ (\e -> + return rs{f_Insert_result_ue =Just e}))+ (\e -> + return rs{f_Insert_result_te =Just e}))+ writeMessageBegin oprot ("insert", M_REPLY, seqid);+ write_Insert_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_batch_insert (seqid, iprot, oprot, handler) = do+ args <- read_Batch_insert_args iprot+ readMessageEnd iprot+ rs <- return (Batch_insert_result Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ Iface.batch_insert handler (f_Batch_insert_args_keyspace args) (f_Batch_insert_args_key args) (f_Batch_insert_args_cfmap args) (f_Batch_insert_args_consistency_level args)+ return rs)+ (\e -> + return rs{f_Batch_insert_result_ire =Just e}))+ (\e -> + return rs{f_Batch_insert_result_ue =Just e}))+ (\e -> + return rs{f_Batch_insert_result_te =Just e}))+ writeMessageBegin oprot ("batch_insert", M_REPLY, seqid);+ write_Batch_insert_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_remove (seqid, iprot, oprot, handler) = do+ args <- read_Remove_args iprot+ readMessageEnd iprot+ rs <- return (Remove_result Nothing Nothing Nothing)+ res <- (Control.Exception.catch+ (Control.Exception.catch+ (Control.Exception.catch+ (do+ Iface.remove handler (f_Remove_args_keyspace args) (f_Remove_args_key args) (f_Remove_args_column_path args) (f_Remove_args_timestamp args) (f_Remove_args_consistency_level args)+ return rs)+ (\e -> + return rs{f_Remove_result_ire =Just e}))+ (\e -> + return rs{f_Remove_result_ue =Just e}))+ (\e -> + return rs{f_Remove_result_te =Just e}))+ writeMessageBegin oprot ("remove", M_REPLY, seqid);+ write_Remove_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_get_string_property (seqid, iprot, oprot, handler) = do+ args <- read_Get_string_property_args iprot+ readMessageEnd iprot+ rs <- return (Get_string_property_result Nothing)+ res <- (do+ res <- Iface.get_string_property handler (f_Get_string_property_args_property args)+ return rs{f_Get_string_property_result_success= Just res})+ writeMessageBegin oprot ("get_string_property", M_REPLY, seqid);+ write_Get_string_property_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_get_string_list_property (seqid, iprot, oprot, handler) = do+ args <- read_Get_string_list_property_args iprot+ readMessageEnd iprot+ rs <- return (Get_string_list_property_result Nothing)+ res <- (do+ res <- Iface.get_string_list_property handler (f_Get_string_list_property_args_property args)+ return rs{f_Get_string_list_property_result_success= Just res})+ writeMessageBegin oprot ("get_string_list_property", M_REPLY, seqid);+ write_Get_string_list_property_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process_describe_keyspace (seqid, iprot, oprot, handler) = do+ args <- read_Describe_keyspace_args iprot+ readMessageEnd iprot+ rs <- return (Describe_keyspace_result Nothing Nothing)+ res <- (Control.Exception.catch+ (do+ res <- Iface.describe_keyspace handler (f_Describe_keyspace_args_keyspace args)+ return rs{f_Describe_keyspace_result_success= Just res})+ (\e -> + return rs{f_Describe_keyspace_result_nfe =Just e}))+ writeMessageBegin oprot ("describe_keyspace", M_REPLY, seqid);+ write_Describe_keyspace_result oprot res+ writeMessageEnd oprot+ tFlush (getTransport oprot)+proc handler (iprot,oprot) (name,typ,seqid) = case name of+ "get" -> process_get (seqid,iprot,oprot,handler)+ "get_slice" -> process_get_slice (seqid,iprot,oprot,handler)+ "multiget" -> process_multiget (seqid,iprot,oprot,handler)+ "multiget_slice" -> process_multiget_slice (seqid,iprot,oprot,handler)+ "get_count" -> process_get_count (seqid,iprot,oprot,handler)+ "get_key_range" -> process_get_key_range (seqid,iprot,oprot,handler)+ "get_range_slice" -> process_get_range_slice (seqid,iprot,oprot,handler)+ "insert" -> process_insert (seqid,iprot,oprot,handler)+ "batch_insert" -> process_batch_insert (seqid,iprot,oprot,handler)+ "remove" -> process_remove (seqid,iprot,oprot,handler)+ "get_string_property" -> process_get_string_property (seqid,iprot,oprot,handler)+ "get_string_list_property" -> process_get_string_list_property (seqid,iprot,oprot,handler)+ "describe_keyspace" -> process_describe_keyspace (seqid,iprot,oprot,handler)+ _ -> do+ skip iprot T_STRUCT+ readMessageEnd iprot+ writeMessageBegin oprot (name,M_EXCEPTION,seqid)+ writeAppExn oprot (AppExn AE_UNKNOWN_METHOD ("Unknown function " ++ name))+ writeMessageEnd oprot+ tFlush (getTransport oprot)+process handler (iprot, oprot) = do+ (name, typ, seqid) <- readMessageBegin iprot+ proc handler (iprot,oprot) (name,typ,seqid)+ return True
+ Database/Cassandra/Thrift/Cassandra_Client.hs view
@@ -0,0 +1,399 @@+{-# LANGUAGE DeriveDataTypeable #-}++module Database.Cassandra.Thrift.Cassandra_Client(get,get_slice,multiget,multiget_slice,get_count,get_key_range,get_range_slice,insert,batch_insert,remove,get_string_property,get_string_list_property,describe_keyspace) where+import Data.IORef+import Thrift+import Data.Typeable ( Typeable )+import Control.Exception+import qualified Data.Map as Map+import qualified Data.Set as Set+import Data.Int+import Database.Cassandra.Thrift.Cassandra_Types+import Database.Cassandra.Thrift.Cassandra+seqid = newIORef 0+get (ip,op) arg_keyspace arg_key arg_column_path arg_consistency_level = do+ send_get op arg_keyspace arg_key arg_column_path arg_consistency_level+ recv_get ip+send_get op arg_keyspace arg_key arg_column_path arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("get", M_CALL, seqn)+ write_Get_args op (Get_args{f_Get_args_keyspace=Just arg_keyspace,f_Get_args_key=Just arg_key,f_Get_args_column_path=Just arg_column_path,f_Get_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_get ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Get_result ip+ readMessageEnd ip+ case f_Get_result_success res of+ Just v -> return v+ Nothing -> do+ case f_Get_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_result_nfe res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ throw (AppExn AE_MISSING_RESULT "get failed: unknown result")+get_slice (ip,op) arg_keyspace arg_key arg_column_parent arg_predicate arg_consistency_level = do+ send_get_slice op arg_keyspace arg_key arg_column_parent arg_predicate arg_consistency_level+ recv_get_slice ip+send_get_slice op arg_keyspace arg_key arg_column_parent arg_predicate arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("get_slice", M_CALL, seqn)+ write_Get_slice_args op (Get_slice_args{f_Get_slice_args_keyspace=Just arg_keyspace,f_Get_slice_args_key=Just arg_key,f_Get_slice_args_column_parent=Just arg_column_parent,f_Get_slice_args_predicate=Just arg_predicate,f_Get_slice_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_get_slice ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Get_slice_result ip+ readMessageEnd ip+ case f_Get_slice_result_success res of+ Just v -> return v+ Nothing -> do+ case f_Get_slice_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_slice_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_slice_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ throw (AppExn AE_MISSING_RESULT "get_slice failed: unknown result")+multiget (ip,op) arg_keyspace arg_keys arg_column_path arg_consistency_level = do+ send_multiget op arg_keyspace arg_keys arg_column_path arg_consistency_level+ recv_multiget ip+send_multiget op arg_keyspace arg_keys arg_column_path arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("multiget", M_CALL, seqn)+ write_Multiget_args op (Multiget_args{f_Multiget_args_keyspace=Just arg_keyspace,f_Multiget_args_keys=Just arg_keys,f_Multiget_args_column_path=Just arg_column_path,f_Multiget_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_multiget ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Multiget_result ip+ readMessageEnd ip+ case f_Multiget_result_success res of+ Just v -> return v+ Nothing -> do+ case f_Multiget_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Multiget_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Multiget_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ throw (AppExn AE_MISSING_RESULT "multiget failed: unknown result")+multiget_slice (ip,op) arg_keyspace arg_keys arg_column_parent arg_predicate arg_consistency_level = do+ send_multiget_slice op arg_keyspace arg_keys arg_column_parent arg_predicate arg_consistency_level+ recv_multiget_slice ip+send_multiget_slice op arg_keyspace arg_keys arg_column_parent arg_predicate arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("multiget_slice", M_CALL, seqn)+ write_Multiget_slice_args op (Multiget_slice_args{f_Multiget_slice_args_keyspace=Just arg_keyspace,f_Multiget_slice_args_keys=Just arg_keys,f_Multiget_slice_args_column_parent=Just arg_column_parent,f_Multiget_slice_args_predicate=Just arg_predicate,f_Multiget_slice_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_multiget_slice ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Multiget_slice_result ip+ readMessageEnd ip+ case f_Multiget_slice_result_success res of+ Just v -> return v+ Nothing -> do+ case f_Multiget_slice_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Multiget_slice_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Multiget_slice_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ throw (AppExn AE_MISSING_RESULT "multiget_slice failed: unknown result")+get_count (ip,op) arg_keyspace arg_key arg_column_parent arg_consistency_level = do+ send_get_count op arg_keyspace arg_key arg_column_parent arg_consistency_level+ recv_get_count ip+send_get_count op arg_keyspace arg_key arg_column_parent arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("get_count", M_CALL, seqn)+ write_Get_count_args op (Get_count_args{f_Get_count_args_keyspace=Just arg_keyspace,f_Get_count_args_key=Just arg_key,f_Get_count_args_column_parent=Just arg_column_parent,f_Get_count_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_get_count ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Get_count_result ip+ readMessageEnd ip+ case f_Get_count_result_success res of+ Just v -> return v+ Nothing -> do+ case f_Get_count_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_count_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_count_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ throw (AppExn AE_MISSING_RESULT "get_count failed: unknown result")+get_key_range (ip,op) arg_keyspace arg_column_family arg_start arg_finish arg_count arg_consistency_level = do+ send_get_key_range op arg_keyspace arg_column_family arg_start arg_finish arg_count arg_consistency_level+ recv_get_key_range ip+send_get_key_range op arg_keyspace arg_column_family arg_start arg_finish arg_count arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("get_key_range", M_CALL, seqn)+ write_Get_key_range_args op (Get_key_range_args{f_Get_key_range_args_keyspace=Just arg_keyspace,f_Get_key_range_args_column_family=Just arg_column_family,f_Get_key_range_args_start=Just arg_start,f_Get_key_range_args_finish=Just arg_finish,f_Get_key_range_args_count=Just arg_count,f_Get_key_range_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_get_key_range ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Get_key_range_result ip+ readMessageEnd ip+ case f_Get_key_range_result_success res of+ Just v -> return v+ Nothing -> do+ case f_Get_key_range_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_key_range_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_key_range_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ throw (AppExn AE_MISSING_RESULT "get_key_range failed: unknown result")+get_range_slice (ip,op) arg_keyspace arg_column_parent arg_predicate arg_start_key arg_finish_key arg_row_count arg_consistency_level = do+ send_get_range_slice op arg_keyspace arg_column_parent arg_predicate arg_start_key arg_finish_key arg_row_count arg_consistency_level+ recv_get_range_slice ip+send_get_range_slice op arg_keyspace arg_column_parent arg_predicate arg_start_key arg_finish_key arg_row_count arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("get_range_slice", M_CALL, seqn)+ write_Get_range_slice_args op (Get_range_slice_args{f_Get_range_slice_args_keyspace=Just arg_keyspace,f_Get_range_slice_args_column_parent=Just arg_column_parent,f_Get_range_slice_args_predicate=Just arg_predicate,f_Get_range_slice_args_start_key=Just arg_start_key,f_Get_range_slice_args_finish_key=Just arg_finish_key,f_Get_range_slice_args_row_count=Just arg_row_count,f_Get_range_slice_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_get_range_slice ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Get_range_slice_result ip+ readMessageEnd ip+ case f_Get_range_slice_result_success res of+ Just v -> return v+ Nothing -> do+ case f_Get_range_slice_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_range_slice_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Get_range_slice_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ throw (AppExn AE_MISSING_RESULT "get_range_slice failed: unknown result")+insert (ip,op) arg_keyspace arg_key arg_column_path arg_value arg_timestamp arg_consistency_level = do+ send_insert op arg_keyspace arg_key arg_column_path arg_value arg_timestamp arg_consistency_level+ recv_insert ip+send_insert op arg_keyspace arg_key arg_column_path arg_value arg_timestamp arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("insert", M_CALL, seqn)+ write_Insert_args op (Insert_args{f_Insert_args_keyspace=Just arg_keyspace,f_Insert_args_key=Just arg_key,f_Insert_args_column_path=Just arg_column_path,f_Insert_args_value=Just arg_value,f_Insert_args_timestamp=Just arg_timestamp,f_Insert_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_insert ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Insert_result ip+ readMessageEnd ip+ case f_Insert_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Insert_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Insert_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ return ()+batch_insert (ip,op) arg_keyspace arg_key arg_cfmap arg_consistency_level = do+ send_batch_insert op arg_keyspace arg_key arg_cfmap arg_consistency_level+ recv_batch_insert ip+send_batch_insert op arg_keyspace arg_key arg_cfmap arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("batch_insert", M_CALL, seqn)+ write_Batch_insert_args op (Batch_insert_args{f_Batch_insert_args_keyspace=Just arg_keyspace,f_Batch_insert_args_key=Just arg_key,f_Batch_insert_args_cfmap=Just arg_cfmap,f_Batch_insert_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_batch_insert ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Batch_insert_result ip+ readMessageEnd ip+ case f_Batch_insert_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Batch_insert_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Batch_insert_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ return ()+remove (ip,op) arg_keyspace arg_key arg_column_path arg_timestamp arg_consistency_level = do+ send_remove op arg_keyspace arg_key arg_column_path arg_timestamp arg_consistency_level+ recv_remove ip+send_remove op arg_keyspace arg_key arg_column_path arg_timestamp arg_consistency_level = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("remove", M_CALL, seqn)+ write_Remove_args op (Remove_args{f_Remove_args_keyspace=Just arg_keyspace,f_Remove_args_key=Just arg_key,f_Remove_args_column_path=Just arg_column_path,f_Remove_args_timestamp=Just arg_timestamp,f_Remove_args_consistency_level=Just arg_consistency_level})+ writeMessageEnd op+ tFlush (getTransport op)+recv_remove ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Remove_result ip+ readMessageEnd ip+ case f_Remove_result_ire res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Remove_result_ue res of+ Nothing -> return ()+ Just _v -> throw _v+ case f_Remove_result_te res of+ Nothing -> return ()+ Just _v -> throw _v+ return ()+get_string_property (ip,op) arg_property = do+ send_get_string_property op arg_property+ recv_get_string_property ip+send_get_string_property op arg_property = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("get_string_property", M_CALL, seqn)+ write_Get_string_property_args op (Get_string_property_args{f_Get_string_property_args_property=Just arg_property})+ writeMessageEnd op+ tFlush (getTransport op)+recv_get_string_property ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Get_string_property_result ip+ readMessageEnd ip+ case f_Get_string_property_result_success res of+ Just v -> return v+ Nothing -> do+ throw (AppExn AE_MISSING_RESULT "get_string_property failed: unknown result")+get_string_list_property (ip,op) arg_property = do+ send_get_string_list_property op arg_property+ recv_get_string_list_property ip+send_get_string_list_property op arg_property = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("get_string_list_property", M_CALL, seqn)+ write_Get_string_list_property_args op (Get_string_list_property_args{f_Get_string_list_property_args_property=Just arg_property})+ writeMessageEnd op+ tFlush (getTransport op)+recv_get_string_list_property ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Get_string_list_property_result ip+ readMessageEnd ip+ case f_Get_string_list_property_result_success res of+ Just v -> return v+ Nothing -> do+ throw (AppExn AE_MISSING_RESULT "get_string_list_property failed: unknown result")+describe_keyspace (ip,op) arg_keyspace = do+ send_describe_keyspace op arg_keyspace+ recv_describe_keyspace ip+send_describe_keyspace op arg_keyspace = do+ seq <- seqid+ seqn <- readIORef seq+ writeMessageBegin op ("describe_keyspace", M_CALL, seqn)+ write_Describe_keyspace_args op (Describe_keyspace_args{f_Describe_keyspace_args_keyspace=Just arg_keyspace})+ writeMessageEnd op+ tFlush (getTransport op)+recv_describe_keyspace ip = do+ (fname, mtype, rseqid) <- readMessageBegin ip+ if mtype == M_EXCEPTION then do+ x <- readAppExn ip+ readMessageEnd ip+ throw x+ else return ()+ res <- read_Describe_keyspace_result ip+ readMessageEnd ip+ case f_Describe_keyspace_result_success res of+ Just v -> return v+ Nothing -> do+ case f_Describe_keyspace_result_nfe res of+ Nothing -> return ()+ Just _v -> throw _v+ throw (AppExn AE_MISSING_RESULT "describe_keyspace failed: unknown result")
+ Database/Cassandra/Thrift/Cassandra_Consts.hs view
@@ -0,0 +1,19 @@+{-# LANGUAGE DeriveDataTypeable #-}++-----------------------------------------------------------------+-- Autogenerated by Thrift --+-- --+-- DO NOT EDIT UNLESS YOU ARE SURE YOU KNOW WHAT YOU ARE DOING --+-----------------------------------------------------------------++module Database.Cassandra.Thrift.Cassandra_Consts where+import Thrift+import Data.Typeable ( Typeable )+import Control.Exception+import qualified Data.Map as Map+import qualified Data.Set as Set+import Data.Int+import Database.Cassandra.Thrift.Cassandra_Types+vERSION :: String+vERSION = "0.5.1"+
+ Database/Cassandra/Thrift/Cassandra_Iface.hs view
@@ -0,0 +1,23 @@+module Database.Cassandra.Thrift.Cassandra_Iface where+import Thrift+import Data.Typeable ( Typeable )+import Control.Exception+import qualified Data.Map as Map+import qualified Data.Set as Set+import Data.Int+import Database.Cassandra.Thrift.Cassandra_Types++class Cassandra_Iface a where+ get :: a -> Maybe String -> Maybe String -> Maybe ColumnPath -> Maybe ConsistencyLevel -> IO ColumnOrSuperColumn+ get_slice :: a -> Maybe String -> Maybe String -> Maybe ColumnParent -> Maybe SlicePredicate -> Maybe ConsistencyLevel -> IO [ColumnOrSuperColumn]+ multiget :: a -> Maybe String -> Maybe [String] -> Maybe ColumnPath -> Maybe ConsistencyLevel -> IO (Map.Map String ColumnOrSuperColumn)+ multiget_slice :: a -> Maybe String -> Maybe [String] -> Maybe ColumnParent -> Maybe SlicePredicate -> Maybe ConsistencyLevel -> IO (Map.Map String [ColumnOrSuperColumn])+ get_count :: a -> Maybe String -> Maybe String -> Maybe ColumnParent -> Maybe ConsistencyLevel -> IO Int+ get_key_range :: a -> Maybe String -> Maybe String -> Maybe String -> Maybe String -> Maybe Int -> Maybe ConsistencyLevel -> IO [String]+ get_range_slice :: a -> Maybe String -> Maybe ColumnParent -> Maybe SlicePredicate -> Maybe String -> Maybe String -> Maybe Int -> Maybe ConsistencyLevel -> IO [KeySlice]+ insert :: a -> Maybe String -> Maybe String -> Maybe ColumnPath -> Maybe String -> Maybe Int64 -> Maybe ConsistencyLevel -> IO ()+ batch_insert :: a -> Maybe String -> Maybe String -> Maybe (Map.Map String [ColumnOrSuperColumn]) -> Maybe ConsistencyLevel -> IO ()+ remove :: a -> Maybe String -> Maybe String -> Maybe ColumnPath -> Maybe Int64 -> Maybe ConsistencyLevel -> IO ()+ get_string_property :: a -> Maybe String -> IO String+ get_string_list_property :: a -> Maybe String -> IO [String]+ describe_keyspace :: a -> Maybe String -> IO (Map.Map String (Map.Map String String))
+ Database/Cassandra/Thrift/Cassandra_Types.hs view
@@ -0,0 +1,461 @@+{-# LANGUAGE DeriveDataTypeable #-}+-----------------------------------------------------------------+-- Autogenerated by Thrift --+-- --+-- DO NOT EDIT UNLESS YOU ARE SURE YOU KNOW WHAT YOU ARE DOING --+-----------------------------------------------------------------++module Database.Cassandra.Thrift.Cassandra_Types where+import Thrift+import Data.Typeable ( Typeable )+import Control.Exception+import qualified Data.Map as Map+import qualified Data.Set as Set+import Data.Int+data ConsistencyLevel = ZERO|ONE|QUORUM|DCQUORUM|DCQUORUMSYNC|ALL deriving (Show,Eq, Typeable, Ord)+instance Enum ConsistencyLevel where+ fromEnum t = case t of+ ZERO -> 0+ ONE -> 1+ QUORUM -> 2+ DCQUORUM -> 3+ DCQUORUMSYNC -> 4+ ALL -> 5+ toEnum t = case t of+ 0 -> ZERO+ 1 -> ONE+ 2 -> QUORUM+ 3 -> DCQUORUM+ 4 -> DCQUORUMSYNC+ 5 -> ALL+ _ -> throw ThriftException+data Column = Column{f_Column_name :: Maybe String,f_Column_value :: Maybe String,f_Column_timestamp :: Maybe Int64} deriving (Show,Eq,Ord,Typeable)+write_Column oprot rec = do+ writeStructBegin oprot "Column"+ case f_Column_name rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("name",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Column_value rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("value",T_STRING,2)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_Column_timestamp rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("timestamp",T_I64,3)+ writeI64 oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_Column_fields iprot rec = do+ (_,_t3,_id4) <- readFieldBegin iprot+ if _t3 == T_STOP then return rec else+ case _id4 of + 1 -> if _t3 == T_STRING then do+ s <- readString iprot+ read_Column_fields iprot rec{f_Column_name=Just s}+ else do+ skip iprot _t3+ read_Column_fields iprot rec+ 2 -> if _t3 == T_STRING then do+ s <- readString iprot+ read_Column_fields iprot rec{f_Column_value=Just s}+ else do+ skip iprot _t3+ read_Column_fields iprot rec+ 3 -> if _t3 == T_I64 then do+ s <- readI64 iprot+ read_Column_fields iprot rec{f_Column_timestamp=Just s}+ else do+ skip iprot _t3+ read_Column_fields iprot rec+ _ -> do+ skip iprot _t3+ readFieldEnd iprot+ read_Column_fields iprot rec+read_Column iprot = do+ readStructBegin iprot+ rec <- read_Column_fields iprot (Column{f_Column_name=Nothing,f_Column_value=Nothing,f_Column_timestamp=Nothing})+ readStructEnd iprot+ return rec+data SuperColumn = SuperColumn{f_SuperColumn_name :: Maybe String,f_SuperColumn_columns :: Maybe [Column]} deriving (Show,Eq,Ord,Typeable)+write_SuperColumn oprot rec = do+ writeStructBegin oprot "SuperColumn"+ case f_SuperColumn_name rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("name",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_SuperColumn_columns rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("columns",T_LIST,2)+ (let {f [] = return (); f (_viter7:t) = do {write_Column oprot _viter7;f t}} in do {writeListBegin oprot (T_STRUCT,length _v); f _v;writeListEnd oprot})+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_SuperColumn_fields iprot rec = do+ (_,_t9,_id10) <- readFieldBegin iprot+ if _t9 == T_STOP then return rec else+ case _id10 of + 1 -> if _t9 == T_STRING then do+ s <- readString iprot+ read_SuperColumn_fields iprot rec{f_SuperColumn_name=Just s}+ else do+ skip iprot _t9+ read_SuperColumn_fields iprot rec+ 2 -> if _t9 == T_LIST then do+ s <- (let {f 0 = return []; f n = do {v <- (read_Column iprot);r <- f (n-1); return $ v:r}} in do {(_etype14,_size11) <- readListBegin iprot; f _size11})+ read_SuperColumn_fields iprot rec{f_SuperColumn_columns=Just s}+ else do+ skip iprot _t9+ read_SuperColumn_fields iprot rec+ _ -> do+ skip iprot _t9+ readFieldEnd iprot+ read_SuperColumn_fields iprot rec+read_SuperColumn iprot = do+ readStructBegin iprot+ rec <- read_SuperColumn_fields iprot (SuperColumn{f_SuperColumn_name=Nothing,f_SuperColumn_columns=Nothing})+ readStructEnd iprot+ return rec+data ColumnOrSuperColumn = ColumnOrSuperColumn{f_ColumnOrSuperColumn_column :: Maybe Column,f_ColumnOrSuperColumn_super_column :: Maybe SuperColumn} deriving (Show,Eq,Ord,Typeable)+write_ColumnOrSuperColumn oprot rec = do+ writeStructBegin oprot "ColumnOrSuperColumn"+ case f_ColumnOrSuperColumn_column rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column",T_STRUCT,1)+ write_Column oprot _v+ writeFieldEnd oprot}+ case f_ColumnOrSuperColumn_super_column rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("super_column",T_STRUCT,2)+ write_SuperColumn oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_ColumnOrSuperColumn_fields iprot rec = do+ (_,_t19,_id20) <- readFieldBegin iprot+ if _t19 == T_STOP then return rec else+ case _id20 of + 1 -> if _t19 == T_STRUCT then do+ s <- (read_Column iprot)+ read_ColumnOrSuperColumn_fields iprot rec{f_ColumnOrSuperColumn_column=Just s}+ else do+ skip iprot _t19+ read_ColumnOrSuperColumn_fields iprot rec+ 2 -> if _t19 == T_STRUCT then do+ s <- (read_SuperColumn iprot)+ read_ColumnOrSuperColumn_fields iprot rec{f_ColumnOrSuperColumn_super_column=Just s}+ else do+ skip iprot _t19+ read_ColumnOrSuperColumn_fields iprot rec+ _ -> do+ skip iprot _t19+ readFieldEnd iprot+ read_ColumnOrSuperColumn_fields iprot rec+read_ColumnOrSuperColumn iprot = do+ readStructBegin iprot+ rec <- read_ColumnOrSuperColumn_fields iprot (ColumnOrSuperColumn{f_ColumnOrSuperColumn_column=Nothing,f_ColumnOrSuperColumn_super_column=Nothing})+ readStructEnd iprot+ return rec+data NotFoundException = NotFoundException deriving (Show,Eq,Ord,Typeable)+instance Exception NotFoundException+write_NotFoundException oprot rec = do+ writeStructBegin oprot "NotFoundException"+ writeFieldStop oprot+ writeStructEnd oprot+read_NotFoundException_fields iprot rec = do+ (_,_t24,_id25) <- readFieldBegin iprot+ if _t24 == T_STOP then return rec else+ case _id25 of + _ -> do+ skip iprot _t24+ readFieldEnd iprot+ read_NotFoundException_fields iprot rec+read_NotFoundException iprot = do+ readStructBegin iprot+ rec <- read_NotFoundException_fields iprot (NotFoundException{})+ readStructEnd iprot+ return rec+data InvalidRequestException = InvalidRequestException{f_InvalidRequestException_why :: Maybe String} deriving (Show,Eq,Ord,Typeable)+instance Exception InvalidRequestException+write_InvalidRequestException oprot rec = do+ writeStructBegin oprot "InvalidRequestException"+ case f_InvalidRequestException_why rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("why",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_InvalidRequestException_fields iprot rec = do+ (_,_t29,_id30) <- readFieldBegin iprot+ if _t29 == T_STOP then return rec else+ case _id30 of + 1 -> if _t29 == T_STRING then do+ s <- readString iprot+ read_InvalidRequestException_fields iprot rec{f_InvalidRequestException_why=Just s}+ else do+ skip iprot _t29+ read_InvalidRequestException_fields iprot rec+ _ -> do+ skip iprot _t29+ readFieldEnd iprot+ read_InvalidRequestException_fields iprot rec+read_InvalidRequestException iprot = do+ readStructBegin iprot+ rec <- read_InvalidRequestException_fields iprot (InvalidRequestException{f_InvalidRequestException_why=Nothing})+ readStructEnd iprot+ return rec+data UnavailableException = UnavailableException deriving (Show,Eq,Ord,Typeable)+instance Exception UnavailableException+write_UnavailableException oprot rec = do+ writeStructBegin oprot "UnavailableException"+ writeFieldStop oprot+ writeStructEnd oprot+read_UnavailableException_fields iprot rec = do+ (_,_t34,_id35) <- readFieldBegin iprot+ if _t34 == T_STOP then return rec else+ case _id35 of + _ -> do+ skip iprot _t34+ readFieldEnd iprot+ read_UnavailableException_fields iprot rec+read_UnavailableException iprot = do+ readStructBegin iprot+ rec <- read_UnavailableException_fields iprot (UnavailableException{})+ readStructEnd iprot+ return rec+data TimedOutException = TimedOutException deriving (Show,Eq,Ord,Typeable)+instance Exception TimedOutException+write_TimedOutException oprot rec = do+ writeStructBegin oprot "TimedOutException"+ writeFieldStop oprot+ writeStructEnd oprot+read_TimedOutException_fields iprot rec = do+ (_,_t39,_id40) <- readFieldBegin iprot+ if _t39 == T_STOP then return rec else+ case _id40 of + _ -> do+ skip iprot _t39+ readFieldEnd iprot+ read_TimedOutException_fields iprot rec+read_TimedOutException iprot = do+ readStructBegin iprot+ rec <- read_TimedOutException_fields iprot (TimedOutException{})+ readStructEnd iprot+ return rec+data ColumnParent = ColumnParent{f_ColumnParent_column_family :: Maybe String,f_ColumnParent_super_column :: Maybe String} deriving (Show,Eq,Ord,Typeable)+write_ColumnParent oprot rec = do+ writeStructBegin oprot "ColumnParent"+ case f_ColumnParent_column_family rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_family",T_STRING,3)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_ColumnParent_super_column rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("super_column",T_STRING,4)+ writeString oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_ColumnParent_fields iprot rec = do+ (_,_t44,_id45) <- readFieldBegin iprot+ if _t44 == T_STOP then return rec else+ case _id45 of + 3 -> if _t44 == T_STRING then do+ s <- readString iprot+ read_ColumnParent_fields iprot rec{f_ColumnParent_column_family=Just s}+ else do+ skip iprot _t44+ read_ColumnParent_fields iprot rec+ 4 -> if _t44 == T_STRING then do+ s <- readString iprot+ read_ColumnParent_fields iprot rec{f_ColumnParent_super_column=Just s}+ else do+ skip iprot _t44+ read_ColumnParent_fields iprot rec+ _ -> do+ skip iprot _t44+ readFieldEnd iprot+ read_ColumnParent_fields iprot rec+read_ColumnParent iprot = do+ readStructBegin iprot+ rec <- read_ColumnParent_fields iprot (ColumnParent{f_ColumnParent_column_family=Nothing,f_ColumnParent_super_column=Nothing})+ readStructEnd iprot+ return rec+data ColumnPath = ColumnPath{f_ColumnPath_column_family :: Maybe String,f_ColumnPath_super_column :: Maybe String,f_ColumnPath_column :: Maybe String} deriving (Show,Eq,Ord,Typeable)+write_ColumnPath oprot rec = do+ writeStructBegin oprot "ColumnPath"+ case f_ColumnPath_column_family rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_family",T_STRING,3)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_ColumnPath_super_column rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("super_column",T_STRING,4)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_ColumnPath_column rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column",T_STRING,5)+ writeString oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_ColumnPath_fields iprot rec = do+ (_,_t49,_id50) <- readFieldBegin iprot+ if _t49 == T_STOP then return rec else+ case _id50 of + 3 -> if _t49 == T_STRING then do+ s <- readString iprot+ read_ColumnPath_fields iprot rec{f_ColumnPath_column_family=Just s}+ else do+ skip iprot _t49+ read_ColumnPath_fields iprot rec+ 4 -> if _t49 == T_STRING then do+ s <- readString iprot+ read_ColumnPath_fields iprot rec{f_ColumnPath_super_column=Just s}+ else do+ skip iprot _t49+ read_ColumnPath_fields iprot rec+ 5 -> if _t49 == T_STRING then do+ s <- readString iprot+ read_ColumnPath_fields iprot rec{f_ColumnPath_column=Just s}+ else do+ skip iprot _t49+ read_ColumnPath_fields iprot rec+ _ -> do+ skip iprot _t49+ readFieldEnd iprot+ read_ColumnPath_fields iprot rec+read_ColumnPath iprot = do+ readStructBegin iprot+ rec <- read_ColumnPath_fields iprot (ColumnPath{f_ColumnPath_column_family=Nothing,f_ColumnPath_super_column=Nothing,f_ColumnPath_column=Nothing})+ readStructEnd iprot+ return rec+data SliceRange = SliceRange{f_SliceRange_start :: Maybe String,f_SliceRange_finish :: Maybe String,f_SliceRange_reversed :: Maybe Bool,f_SliceRange_count :: Maybe Int} deriving (Show,Eq,Ord,Typeable)+write_SliceRange oprot rec = do+ writeStructBegin oprot "SliceRange"+ case f_SliceRange_start rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("start",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_SliceRange_finish rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("finish",T_STRING,2)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_SliceRange_reversed rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("reversed",T_BOOL,3)+ writeBool oprot _v+ writeFieldEnd oprot}+ case f_SliceRange_count rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("count",T_I32,4)+ writeI32 oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_SliceRange_fields iprot rec = do+ (_,_t54,_id55) <- readFieldBegin iprot+ if _t54 == T_STOP then return rec else+ case _id55 of + 1 -> if _t54 == T_STRING then do+ s <- readString iprot+ read_SliceRange_fields iprot rec{f_SliceRange_start=Just s}+ else do+ skip iprot _t54+ read_SliceRange_fields iprot rec+ 2 -> if _t54 == T_STRING then do+ s <- readString iprot+ read_SliceRange_fields iprot rec{f_SliceRange_finish=Just s}+ else do+ skip iprot _t54+ read_SliceRange_fields iprot rec+ 3 -> if _t54 == T_BOOL then do+ s <- readBool iprot+ read_SliceRange_fields iprot rec{f_SliceRange_reversed=Just s}+ else do+ skip iprot _t54+ read_SliceRange_fields iprot rec+ 4 -> if _t54 == T_I32 then do+ s <- readI32 iprot+ read_SliceRange_fields iprot rec{f_SliceRange_count=Just s}+ else do+ skip iprot _t54+ read_SliceRange_fields iprot rec+ _ -> do+ skip iprot _t54+ readFieldEnd iprot+ read_SliceRange_fields iprot rec+read_SliceRange iprot = do+ readStructBegin iprot+ rec <- read_SliceRange_fields iprot (SliceRange{f_SliceRange_start=Nothing,f_SliceRange_finish=Nothing,f_SliceRange_reversed=Nothing,f_SliceRange_count=Nothing})+ readStructEnd iprot+ return rec+data SlicePredicate = SlicePredicate{f_SlicePredicate_column_names :: Maybe [String],f_SlicePredicate_slice_range :: Maybe SliceRange} deriving (Show,Eq,Ord,Typeable)+write_SlicePredicate oprot rec = do+ writeStructBegin oprot "SlicePredicate"+ case f_SlicePredicate_column_names rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("column_names",T_LIST,1)+ (let {f [] = return (); f (_viter58:t) = do {writeString oprot _viter58;f t}} in do {writeListBegin oprot (T_STRING,length _v); f _v;writeListEnd oprot})+ writeFieldEnd oprot}+ case f_SlicePredicate_slice_range rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("slice_range",T_STRUCT,2)+ write_SliceRange oprot _v+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_SlicePredicate_fields iprot rec = do+ (_,_t60,_id61) <- readFieldBegin iprot+ if _t60 == T_STOP then return rec else+ case _id61 of + 1 -> if _t60 == T_LIST then do+ s <- (let {f 0 = return []; f n = do {v <- readString iprot;r <- f (n-1); return $ v:r}} in do {(_etype65,_size62) <- readListBegin iprot; f _size62})+ read_SlicePredicate_fields iprot rec{f_SlicePredicate_column_names=Just s}+ else do+ skip iprot _t60+ read_SlicePredicate_fields iprot rec+ 2 -> if _t60 == T_STRUCT then do+ s <- (read_SliceRange iprot)+ read_SlicePredicate_fields iprot rec{f_SlicePredicate_slice_range=Just s}+ else do+ skip iprot _t60+ read_SlicePredicate_fields iprot rec+ _ -> do+ skip iprot _t60+ readFieldEnd iprot+ read_SlicePredicate_fields iprot rec+read_SlicePredicate iprot = do+ readStructBegin iprot+ rec <- read_SlicePredicate_fields iprot (SlicePredicate{f_SlicePredicate_column_names=Nothing,f_SlicePredicate_slice_range=Nothing})+ readStructEnd iprot+ return rec+data KeySlice = KeySlice{f_KeySlice_key :: Maybe String,f_KeySlice_columns :: Maybe [ColumnOrSuperColumn]} deriving (Show,Eq,Ord,Typeable)+write_KeySlice oprot rec = do+ writeStructBegin oprot "KeySlice"+ case f_KeySlice_key rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("key",T_STRING,1)+ writeString oprot _v+ writeFieldEnd oprot}+ case f_KeySlice_columns rec of {Nothing -> return (); Just _v -> do+ writeFieldBegin oprot ("columns",T_LIST,2)+ (let {f [] = return (); f (_viter69:t) = do {write_ColumnOrSuperColumn oprot _viter69;f t}} in do {writeListBegin oprot (T_STRUCT,length _v); f _v;writeListEnd oprot})+ writeFieldEnd oprot}+ writeFieldStop oprot+ writeStructEnd oprot+read_KeySlice_fields iprot rec = do+ (_,_t71,_id72) <- readFieldBegin iprot+ if _t71 == T_STOP then return rec else+ case _id72 of + 1 -> if _t71 == T_STRING then do+ s <- readString iprot+ read_KeySlice_fields iprot rec{f_KeySlice_key=Just s}+ else do+ skip iprot _t71+ read_KeySlice_fields iprot rec+ 2 -> if _t71 == T_LIST then do+ s <- (let {f 0 = return []; f n = do {v <- (read_ColumnOrSuperColumn iprot);r <- f (n-1); return $ v:r}} in do {(_etype76,_size73) <- readListBegin iprot; f _size73})+ read_KeySlice_fields iprot rec{f_KeySlice_columns=Just s}+ else do+ skip iprot _t71+ read_KeySlice_fields iprot rec+ _ -> do+ skip iprot _t71+ readFieldEnd iprot+ read_KeySlice_fields iprot rec+read_KeySlice iprot = do+ readStructBegin iprot+ rec <- read_KeySlice_fields iprot (KeySlice{f_KeySlice_key=Nothing,f_KeySlice_columns=Nothing})+ readStructEnd iprot+ return rec
+ Setup.hs view
@@ -0,0 +1,3 @@+import Distribution.Simple+main = defaultMain+
+ cassandra-thrift.cabal view
@@ -0,0 +1,28 @@+name: cassandra-thrift +version: 0.0.1+license: OtherLicense +cabal-version: >= 1.4+author: Thrift v.0.2.0 +maintainer: kirk@glyphsoftware.com +stability: alpha+synopsis: thrift bindings to the cassandra database +description:+ The Cassandra (v.0.5.1) database bindings, generated using the Thrift (v.0.2) compliler, Released under the Apache 2.0 license. + +category: Database +build-type: Simple+homepage: http://cassandra.apache.org/ +Library+ exposed-modules: Database.Cassandra.Thrift.Cassandra+ Database.Cassandra.Thrift.Cassandra_Client+ Database.Cassandra.Thrift.Cassandra_Consts + Database.Cassandra.Thrift.Cassandra_Iface+ Database.Cassandra.Thrift.Cassandra_Types++ build-depends: base >= 4 && < 5, + haskell98,+ containers,+ Thrift++ include-dirs: Database +