summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBryanOSullivan <>2011-03-01 06:56:14 (GMT)
committerLuite Stegeman <luite@luite.com>2011-03-01 06:56:14 (GMT)
commitf9e1ddecadf2768bdeb43f2717a492351e6b26d5 (patch)
treecda0756018d42d71d1d077d618f9f809bc5c2405
version 0.14.0.00.14.0.0
-rw-r--r--LICENSE178
-rw-r--r--README.markdown28
-rw-r--r--Setup.hs2
-rw-r--r--proto.sh40
-rw-r--r--riak-protobuf.cabal68
-rw-r--r--src/Network/Riak/Protocol.hs19
-rw-r--r--src/Network/Riak/Protocol/BucketProps.hs65
-rw-r--r--src/Network/Riak/Protocol/Content.hs100
-rw-r--r--src/Network/Riak/Protocol/DeleteRequest.hs68
-rw-r--r--src/Network/Riak/Protocol/ErrorResponse.hs65
-rw-r--r--src/Network/Riak/Protocol/GetBucketRequest.hs63
-rw-r--r--src/Network/Riak/Protocol/GetBucketResponse.hs64
-rw-r--r--src/Network/Riak/Protocol/GetClientIDRequest.hs62
-rw-r--r--src/Network/Riak/Protocol/GetClientIDResponse.hs63
-rw-r--r--src/Network/Riak/Protocol/GetRequest.hs68
-rw-r--r--src/Network/Riak/Protocol/GetResponse.hs66
-rw-r--r--src/Network/Riak/Protocol/GetServerInfoRequest.hs62
-rw-r--r--src/Network/Riak/Protocol/Link.hs68
-rw-r--r--src/Network/Riak/Protocol/ListBucketsRequest.hs62
-rw-r--r--src/Network/Riak/Protocol/ListBucketsResponse.hs63
-rw-r--r--src/Network/Riak/Protocol/ListKeysRequest.hs63
-rw-r--r--src/Network/Riak/Protocol/ListKeysResponse.hs66
-rw-r--r--src/Network/Riak/Protocol/MapReduce.hs68
-rw-r--r--src/Network/Riak/Protocol/MapReduceRequest.hs66
-rw-r--r--src/Network/Riak/Protocol/Pair.hs65
-rw-r--r--src/Network/Riak/Protocol/PingRequest.hs62
-rw-r--r--src/Network/Riak/Protocol/PutRequest.hs87
-rw-r--r--src/Network/Riak/Protocol/PutResponse.hs66
-rw-r--r--src/Network/Riak/Protocol/ServerInfo.hs65
-rw-r--r--src/Network/Riak/Protocol/SetBucketRequest.hs67
-rw-r--r--src/Network/Riak/Protocol/SetClientIDRequest.hs63
-rw-r--r--src/riakclient.proto246
-rw-r--r--src/riakextra.proto4
33 files changed, 2262 insertions, 0 deletions
diff --git a/LICENSE b/LICENSE
new file mode 100644
index 0000000..e454a52
--- /dev/null
+++ b/LICENSE
@@ -0,0 +1,178 @@
+
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
diff --git a/README.markdown b/README.markdown
new file mode 100644
index 0000000..325dd7c
--- /dev/null
+++ b/README.markdown
@@ -0,0 +1,28 @@
+# Welcome to riak-protobuf
+
+This library is a set of Haskell types for the protocol buffers API to the
+[Riak](http://www.basho.com/Riak.html) decentralized data store.
+
+# Join in!
+
+We are happy to receive bug reports, fixes, documentation enhancements,
+and other improvements.
+
+Please report bugs via the
+[github issue tracker](http://github.com/mailrank/riak-haskell-client/issues).
+
+Master [git repository](http://github.com/mailrank/riak-haskell-client):
+
+* `git clone git://github.com/mailrank/riak-haskell-client.git`
+
+There's also a [Mercurial mirror](http://bitbucket.org/bos/riak-haskell-client):
+
+* `hg clone http://bitbucket.org/bos/riak-haskell-client`
+
+(You can create and contribute changes using either git or Mercurial.)
+
+Authors
+-------
+
+This library is written and maintained by Bryan O'Sullivan,
+<bos@mailrank.com>.
diff --git a/Setup.hs b/Setup.hs
new file mode 100644
index 0000000..9a994af
--- /dev/null
+++ b/Setup.hs
@@ -0,0 +1,2 @@
+import Distribution.Simple
+main = defaultMain
diff --git a/proto.sh b/proto.sh
new file mode 100644
index 0000000..44a67b0
--- /dev/null
+++ b/proto.sh
@@ -0,0 +1,40 @@
+#!/bin/bash
+
+root="$(hg root)"
+
+if [[ -z "$root" ]]; then
+ echo "error: don't know where we are!" 1>&2
+ exit 1
+fi
+
+cd "$root"
+
+hprotoc="$(which hprotoc)"
+
+if [[ -z "$hprotoc" ]]; then
+ echo "error: can't continue without hprotoc" 1>&2
+ echo "to fix:" 1>&2
+ echo 1>&2
+ echo "cabal install hprotoc" 1>&2
+ exit 1
+fi
+
+sed -e 's/Rpb//g' -e 's/Req\>/Request/g' -e 's/Resp\>/Response/g' \
+ -e 's/MapRedR/MapReduceR/g' -e 's/DelR/DeleteR/' -e 's/ClientId/ClientID/' \
+ -e 's/GetServerInfoResponse/ServerInfo/g' \
+ -e 's/MapReduceResponse/MapReduce/g' \
+ protobuf/riakclient.proto protobuf/riakextra.proto > protobuf/Protocol.proto
+
+(cd protobuf && hprotoc -p Network.Riak Protocol.proto)
+for i in $(find protobuf/Network/Riak/Protocol -name '*.hs';
+ echo protobuf/Network/Riak/Protocol.hs); do
+ cp /dev/null $i.$$
+ echo '{-# LANGUAGE DeriveDataTypeable #-}' >> $i.$$
+ echo '{-# LANGUAGE FlexibleInstances #-}' >> $i.$$
+ echo '{-# LANGUAGE MultiParamTypeClasses #-}' >> $i.$$
+ echo '{-# OPTIONS_GHC -fno-warn-unused-imports #-}' >> $i.$$
+ cat $i >> $i.$$
+ mv $i.$$ $i
+done
+
+rm protobuf/Protocol.proto
diff --git a/riak-protobuf.cabal b/riak-protobuf.cabal
new file mode 100644
index 0000000..90ccb61
--- /dev/null
+++ b/riak-protobuf.cabal
@@ -0,0 +1,68 @@
+name: riak-protobuf
+version: 0.14.0.0
+synopsis: Haskell types for the Riak protocol buffer API
+description:
+ A set of Haskell types for interacting with the protocol buffer
+ API of the Riak decentralized data store.
+
+homepage: http://github.com/mailrank/riak-haskell-client
+license: OtherLicense
+license-file: LICENSE
+author: Bryan O'Sullivan <bos@mailrank.com>
+maintainer: Bryan O'Sullivan <bos@mailrank.com>
+copyright: Copyright 2011 MailRank, Inc.
+ Portions copyright 2007-2010 Basho Technologies, Inc.
+category: Network
+build-type: Simple
+extra-source-files:
+ README.markdown
+ proto.sh
+ src/riakclient.proto
+ src/riakextra.proto
+
+cabal-version: >=1.8
+
+library
+ hs-source-dirs: src
+
+ exposed-modules:
+ Network.Riak.Protocol.BucketProps
+ Network.Riak.Protocol.Content
+ Network.Riak.Protocol.DeleteRequest
+ Network.Riak.Protocol.ErrorResponse
+ Network.Riak.Protocol.GetBucketRequest
+ Network.Riak.Protocol.GetBucketResponse
+ Network.Riak.Protocol.GetClientIDRequest
+ Network.Riak.Protocol.GetClientIDResponse
+ Network.Riak.Protocol.GetRequest
+ Network.Riak.Protocol.GetResponse
+ Network.Riak.Protocol.GetServerInfoRequest
+ Network.Riak.Protocol.Link
+ Network.Riak.Protocol.ListBucketsRequest
+ Network.Riak.Protocol.ListBucketsResponse
+ Network.Riak.Protocol.ListKeysRequest
+ Network.Riak.Protocol.ListKeysResponse
+ Network.Riak.Protocol.MapReduce
+ Network.Riak.Protocol.MapReduceRequest
+ Network.Riak.Protocol.Pair
+ Network.Riak.Protocol.PingRequest
+ Network.Riak.Protocol.PutRequest
+ Network.Riak.Protocol.PutResponse
+ Network.Riak.Protocol.ServerInfo
+ Network.Riak.Protocol.SetBucketRequest
+ Network.Riak.Protocol.SetClientIDRequest
+
+ other-modules:
+ Network.Riak.Protocol
+
+ build-depends:
+ base == 4.*,
+ parsec >= 3,
+ protocol-buffers >= 1.8.0,
+ protocol-buffers-descriptor >= 1.8.1
+
+ ghc-options: -Wall -fno-warn-orphans
+
+source-repository head
+ type: git
+ location: http://github.com/mailrank/riak-haskell-client
diff --git a/src/Network/Riak/Protocol.hs b/src/Network/Riak/Protocol.hs
new file mode 100644
index 0000000..d4735b6
--- /dev/null
+++ b/src/Network/Riak/Protocol.hs
@@ -0,0 +1,19 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol (protoInfo, fileDescriptorProto) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+import Text.DescriptorProtos.FileDescriptorProto (FileDescriptorProto)
+import Text.ProtocolBuffers.Reflections (ProtoInfo)
+import qualified Text.ProtocolBuffers.WireMessage as P' (wireGet,getFromBS)
+
+protoInfo :: ProtoInfo
+protoInfo
+ = P'.read
+ "ProtoInfo {protoMod = ProtoName {protobufName = FIName \".Protocol\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [], baseName = MName \"Protocol\"}, protoFilePath = [\"Network\",\"Riak\",\"Protocol.hs\"], protoSource = \"Protocol.proto\", extensionKeys = fromList [], messages = [], enums = [], knownKeyMap = fromList []}"
+
+fileDescriptorProto :: FileDescriptorProto
+fileDescriptorProto = P'.getFromBS (P'.wireGet 11) (P'.pack "\DLE\n\SOProtocol.proto") \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/BucketProps.hs b/src/Network/Riak/Protocol/BucketProps.hs
new file mode 100644
index 0000000..1db9261
--- /dev/null
+++ b/src/Network/Riak/Protocol/BucketProps.hs
@@ -0,0 +1,65 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.BucketProps (BucketProps(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data BucketProps = BucketProps{n_val :: P'.Maybe P'.Word32, allow_mult :: P'.Maybe P'.Bool}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable BucketProps where
+ mergeEmpty = BucketProps P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (BucketProps x'1 x'2) (BucketProps y'1 y'2) = BucketProps (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2)
+
+instance P'.Default BucketProps where
+ defaultValue = BucketProps P'.defaultValue P'.defaultValue
+
+instance P'.Wire BucketProps where
+ wireSize ft' self'@(BucketProps x'1 x'2)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeOpt 1 13 x'1 + P'.wireSizeOpt 1 8 x'2)
+ wirePut ft' self'@(BucketProps x'1 x'2)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutOpt 8 13 x'1
+ P'.wirePutOpt 16 8 x'2
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 8 -> P'.fmap (\ new'Field -> old'Self{n_val = P'.Just new'Field}) (P'.wireGet 13)
+ 16 -> P'.fmap (\ new'Field -> old'Self{allow_mult = P'.Just new'Field}) (P'.wireGet 8)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> BucketProps) BucketProps where
+ getVal m' f' = f' m'
+
+instance P'.GPB BucketProps
+
+instance P'.ReflectDescriptor BucketProps where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [8, 16])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.BucketProps\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"BucketProps\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"BucketProps.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.BucketProps.n_val\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"BucketProps\"], baseName' = FName \"n_val\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 8}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 13}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.BucketProps.allow_mult\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"BucketProps\"], baseName' = FName \"allow_mult\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 16}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 8}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/Content.hs b/src/Network/Riak/Protocol/Content.hs
new file mode 100644
index 0000000..850493e
--- /dev/null
+++ b/src/Network/Riak/Protocol/Content.hs
@@ -0,0 +1,100 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.Content (Content(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+import qualified Network.Riak.Protocol.Link as Protocol (Link)
+import qualified Network.Riak.Protocol.Pair as Protocol (Pair)
+
+data Content = Content{value :: P'.ByteString, content_type :: P'.Maybe P'.ByteString, charset :: P'.Maybe P'.ByteString,
+ content_encoding :: P'.Maybe P'.ByteString, vtag :: P'.Maybe P'.ByteString, links :: P'.Seq Protocol.Link,
+ last_mod :: P'.Maybe P'.Word32, last_mod_usecs :: P'.Maybe P'.Word32, usermeta :: P'.Seq Protocol.Pair}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable Content where
+ mergeEmpty
+ = Content P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty
+ P'.mergeEmpty
+ mergeAppend (Content x'1 x'2 x'3 x'4 x'5 x'6 x'7 x'8 x'9) (Content y'1 y'2 y'3 y'4 y'5 y'6 y'7 y'8 y'9)
+ = Content (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2) (P'.mergeAppend x'3 y'3) (P'.mergeAppend x'4 y'4)
+ (P'.mergeAppend x'5 y'5)
+ (P'.mergeAppend x'6 y'6)
+ (P'.mergeAppend x'7 y'7)
+ (P'.mergeAppend x'8 y'8)
+ (P'.mergeAppend x'9 y'9)
+
+instance P'.Default Content where
+ defaultValue
+ = Content P'.defaultValue P'.defaultValue P'.defaultValue P'.defaultValue P'.defaultValue P'.defaultValue P'.defaultValue
+ P'.defaultValue
+ P'.defaultValue
+
+instance P'.Wire Content where
+ wireSize ft' self'@(Content x'1 x'2 x'3 x'4 x'5 x'6 x'7 x'8 x'9)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size
+ = (P'.wireSizeReq 1 12 x'1 + P'.wireSizeOpt 1 12 x'2 + P'.wireSizeOpt 1 12 x'3 + P'.wireSizeOpt 1 12 x'4 +
+ P'.wireSizeOpt 1 12 x'5
+ + P'.wireSizeRep 1 11 x'6
+ + P'.wireSizeOpt 1 13 x'7
+ + P'.wireSizeOpt 1 13 x'8
+ + P'.wireSizeRep 1 11 x'9)
+ wirePut ft' self'@(Content x'1 x'2 x'3 x'4 x'5 x'6 x'7 x'8 x'9)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ P'.wirePutOpt 18 12 x'2
+ P'.wirePutOpt 26 12 x'3
+ P'.wirePutOpt 34 12 x'4
+ P'.wirePutOpt 42 12 x'5
+ P'.wirePutRep 50 11 x'6
+ P'.wirePutOpt 56 13 x'7
+ P'.wirePutOpt 64 13 x'8
+ P'.wirePutRep 74 11 x'9
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{value = new'Field}) (P'.wireGet 12)
+ 18 -> P'.fmap (\ new'Field -> old'Self{content_type = P'.Just new'Field}) (P'.wireGet 12)
+ 26 -> P'.fmap (\ new'Field -> old'Self{charset = P'.Just new'Field}) (P'.wireGet 12)
+ 34 -> P'.fmap (\ new'Field -> old'Self{content_encoding = P'.Just new'Field}) (P'.wireGet 12)
+ 42 -> P'.fmap (\ new'Field -> old'Self{vtag = P'.Just new'Field}) (P'.wireGet 12)
+ 50 -> P'.fmap (\ new'Field -> old'Self{links = P'.append (links old'Self) new'Field}) (P'.wireGet 11)
+ 56 -> P'.fmap (\ new'Field -> old'Self{last_mod = P'.Just new'Field}) (P'.wireGet 13)
+ 64 -> P'.fmap (\ new'Field -> old'Self{last_mod_usecs = P'.Just new'Field}) (P'.wireGet 13)
+ 74 -> P'.fmap (\ new'Field -> old'Self{usermeta = P'.append (usermeta old'Self) new'Field}) (P'.wireGet 11)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> Content) Content where
+ getVal m' f' = f' m'
+
+instance P'.GPB Content
+
+instance P'.ReflectDescriptor Content where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10]) (P'.fromDistinctAscList [10, 18, 26, 34, 42, 50, 56, 64, 74])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.Content\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"Content\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"Content.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Content.value\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Content\"], baseName' = FName \"value\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Content.content_type\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Content\"], baseName' = FName \"content_type\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Content.charset\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Content\"], baseName' = FName \"charset\"}, fieldNumber = FieldId {getFieldId = 3}, wireTag = WireTag {getWireTag = 26}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Content.content_encoding\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Content\"], baseName' = FName \"content_encoding\"}, fieldNumber = FieldId {getFieldId = 4}, wireTag = WireTag {getWireTag = 34}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Content.vtag\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Content\"], baseName' = FName \"vtag\"}, fieldNumber = FieldId {getFieldId = 5}, wireTag = WireTag {getWireTag = 42}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Content.links\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Content\"], baseName' = FName \"links\"}, fieldNumber = FieldId {getFieldId = 6}, wireTag = WireTag {getWireTag = 50}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = True, mightPack = False, typeCode = FieldType {getFieldType = 11}, typeName = Just (ProtoName {protobufName = FIName \".Protocol.Link\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"Link\"}), hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Content.last_mod\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Content\"], baseName' = FName \"last_mod\"}, fieldNumber = FieldId {getFieldId = 7}, wireTag = WireTag {getWireTag = 56}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 13}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Content.last_mod_usecs\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Content\"], baseName' = FName \"last_mod_usecs\"}, fieldNumber = FieldId {getFieldId = 8}, wireTag = WireTag {getWireTag = 64}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 13}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Content.usermeta\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Content\"], baseName' = FName \"usermeta\"}, fieldNumber = FieldId {getFieldId = 9}, wireTag = WireTag {getWireTag = 74}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = True, mightPack = False, typeCode = FieldType {getFieldType = 11}, typeName = Just (ProtoName {protobufName = FIName \".Protocol.Pair\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"Pair\"}), hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/DeleteRequest.hs b/src/Network/Riak/Protocol/DeleteRequest.hs
new file mode 100644
index 0000000..22715cb
--- /dev/null
+++ b/src/Network/Riak/Protocol/DeleteRequest.hs
@@ -0,0 +1,68 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.DeleteRequest (DeleteRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data DeleteRequest = DeleteRequest{bucket :: P'.ByteString, key :: P'.ByteString, rw :: P'.Maybe P'.Word32}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable DeleteRequest where
+ mergeEmpty = DeleteRequest P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (DeleteRequest x'1 x'2 x'3) (DeleteRequest y'1 y'2 y'3)
+ = DeleteRequest (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2) (P'.mergeAppend x'3 y'3)
+
+instance P'.Default DeleteRequest where
+ defaultValue = DeleteRequest P'.defaultValue P'.defaultValue P'.defaultValue
+
+instance P'.Wire DeleteRequest where
+ wireSize ft' self'@(DeleteRequest x'1 x'2 x'3)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1 + P'.wireSizeReq 1 12 x'2 + P'.wireSizeOpt 1 13 x'3)
+ wirePut ft' self'@(DeleteRequest x'1 x'2 x'3)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ P'.wirePutReq 18 12 x'2
+ P'.wirePutOpt 24 13 x'3
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{bucket = new'Field}) (P'.wireGet 12)
+ 18 -> P'.fmap (\ new'Field -> old'Self{key = new'Field}) (P'.wireGet 12)
+ 24 -> P'.fmap (\ new'Field -> old'Self{rw = P'.Just new'Field}) (P'.wireGet 13)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> DeleteRequest) DeleteRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB DeleteRequest
+
+instance P'.ReflectDescriptor DeleteRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10, 18]) (P'.fromDistinctAscList [10, 18, 24])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.DeleteRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"DeleteRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"DeleteRequest.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.DeleteRequest.bucket\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"DeleteRequest\"], baseName' = FName \"bucket\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.DeleteRequest.key\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"DeleteRequest\"], baseName' = FName \"key\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.DeleteRequest.rw\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"DeleteRequest\"], baseName' = FName \"rw\"}, fieldNumber = FieldId {getFieldId = 3}, wireTag = WireTag {getWireTag = 24}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 13}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/ErrorResponse.hs b/src/Network/Riak/Protocol/ErrorResponse.hs
new file mode 100644
index 0000000..22a1bed
--- /dev/null
+++ b/src/Network/Riak/Protocol/ErrorResponse.hs
@@ -0,0 +1,65 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.ErrorResponse (ErrorResponse(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data ErrorResponse = ErrorResponse{errmsg :: P'.ByteString, errcode :: P'.Word32}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable ErrorResponse where
+ mergeEmpty = ErrorResponse P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (ErrorResponse x'1 x'2) (ErrorResponse y'1 y'2) = ErrorResponse (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2)
+
+instance P'.Default ErrorResponse where
+ defaultValue = ErrorResponse P'.defaultValue P'.defaultValue
+
+instance P'.Wire ErrorResponse where
+ wireSize ft' self'@(ErrorResponse x'1 x'2)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1 + P'.wireSizeReq 1 13 x'2)
+ wirePut ft' self'@(ErrorResponse x'1 x'2)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ P'.wirePutReq 16 13 x'2
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{errmsg = new'Field}) (P'.wireGet 12)
+ 16 -> P'.fmap (\ new'Field -> old'Self{errcode = new'Field}) (P'.wireGet 13)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> ErrorResponse) ErrorResponse where
+ getVal m' f' = f' m'
+
+instance P'.GPB ErrorResponse
+
+instance P'.ReflectDescriptor ErrorResponse where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10, 16]) (P'.fromDistinctAscList [10, 16])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.ErrorResponse\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"ErrorResponse\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"ErrorResponse.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.ErrorResponse.errmsg\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"ErrorResponse\"], baseName' = FName \"errmsg\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.ErrorResponse.errcode\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"ErrorResponse\"], baseName' = FName \"errcode\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 16}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 13}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/GetBucketRequest.hs b/src/Network/Riak/Protocol/GetBucketRequest.hs
new file mode 100644
index 0000000..09f5137
--- /dev/null
+++ b/src/Network/Riak/Protocol/GetBucketRequest.hs
@@ -0,0 +1,63 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.GetBucketRequest (GetBucketRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data GetBucketRequest = GetBucketRequest{bucket :: P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable GetBucketRequest where
+ mergeEmpty = GetBucketRequest P'.mergeEmpty
+ mergeAppend (GetBucketRequest x'1) (GetBucketRequest y'1) = GetBucketRequest (P'.mergeAppend x'1 y'1)
+
+instance P'.Default GetBucketRequest where
+ defaultValue = GetBucketRequest P'.defaultValue
+
+instance P'.Wire GetBucketRequest where
+ wireSize ft' self'@(GetBucketRequest x'1)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1)
+ wirePut ft' self'@(GetBucketRequest x'1)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{bucket = new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> GetBucketRequest) GetBucketRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB GetBucketRequest
+
+instance P'.ReflectDescriptor GetBucketRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10]) (P'.fromDistinctAscList [10])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.GetBucketRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"GetBucketRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"GetBucketRequest.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.GetBucketRequest.bucket\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"GetBucketRequest\"], baseName' = FName \"bucket\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/GetBucketResponse.hs b/src/Network/Riak/Protocol/GetBucketResponse.hs
new file mode 100644
index 0000000..3062ec8
--- /dev/null
+++ b/src/Network/Riak/Protocol/GetBucketResponse.hs
@@ -0,0 +1,64 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.GetBucketResponse (GetBucketResponse(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+import qualified Network.Riak.Protocol.BucketProps as Protocol (BucketProps)
+
+data GetBucketResponse = GetBucketResponse{props :: Protocol.BucketProps}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable GetBucketResponse where
+ mergeEmpty = GetBucketResponse P'.mergeEmpty
+ mergeAppend (GetBucketResponse x'1) (GetBucketResponse y'1) = GetBucketResponse (P'.mergeAppend x'1 y'1)
+
+instance P'.Default GetBucketResponse where
+ defaultValue = GetBucketResponse P'.defaultValue
+
+instance P'.Wire GetBucketResponse where
+ wireSize ft' self'@(GetBucketResponse x'1)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 11 x'1)
+ wirePut ft' self'@(GetBucketResponse x'1)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 11 x'1
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{props = P'.mergeAppend (props old'Self) (new'Field)}) (P'.wireGet 11)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> GetBucketResponse) GetBucketResponse where
+ getVal m' f' = f' m'
+
+instance P'.GPB GetBucketResponse
+
+instance P'.ReflectDescriptor GetBucketResponse where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10]) (P'.fromDistinctAscList [10])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.GetBucketResponse\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"GetBucketResponse\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"GetBucketResponse.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.GetBucketResponse.props\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"GetBucketResponse\"], baseName' = FName \"props\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 11}, typeName = Just (ProtoName {protobufName = FIName \".Protocol.BucketProps\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"BucketProps\"}), hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/GetClientIDRequest.hs b/src/Network/Riak/Protocol/GetClientIDRequest.hs
new file mode 100644
index 0000000..a8fd62f
--- /dev/null
+++ b/src/Network/Riak/Protocol/GetClientIDRequest.hs
@@ -0,0 +1,62 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.GetClientIDRequest (GetClientIDRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data GetClientIDRequest = GetClientIDRequest{}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable GetClientIDRequest where
+ mergeEmpty = GetClientIDRequest
+ mergeAppend (GetClientIDRequest) (GetClientIDRequest) = GetClientIDRequest
+
+instance P'.Default GetClientIDRequest where
+ defaultValue = GetClientIDRequest
+
+instance P'.Wire GetClientIDRequest where
+ wireSize ft' self'@(GetClientIDRequest)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = 0
+ wirePut ft' self'@(GetClientIDRequest)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.return ()
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> GetClientIDRequest) GetClientIDRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB GetClientIDRequest
+
+instance P'.ReflectDescriptor GetClientIDRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.GetClientIDRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"GetClientIDRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"GetClientIDRequest.hs\"], isGroup = False, fields = fromList [], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/GetClientIDResponse.hs b/src/Network/Riak/Protocol/GetClientIDResponse.hs
new file mode 100644
index 0000000..d7534a9
--- /dev/null
+++ b/src/Network/Riak/Protocol/GetClientIDResponse.hs
@@ -0,0 +1,63 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.GetClientIDResponse (GetClientIDResponse(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data GetClientIDResponse = GetClientIDResponse{client_id :: P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable GetClientIDResponse where
+ mergeEmpty = GetClientIDResponse P'.mergeEmpty
+ mergeAppend (GetClientIDResponse x'1) (GetClientIDResponse y'1) = GetClientIDResponse (P'.mergeAppend x'1 y'1)
+
+instance P'.Default GetClientIDResponse where
+ defaultValue = GetClientIDResponse P'.defaultValue
+
+instance P'.Wire GetClientIDResponse where
+ wireSize ft' self'@(GetClientIDResponse x'1)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1)
+ wirePut ft' self'@(GetClientIDResponse x'1)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{client_id = new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> GetClientIDResponse) GetClientIDResponse where
+ getVal m' f' = f' m'
+
+instance P'.GPB GetClientIDResponse
+
+instance P'.ReflectDescriptor GetClientIDResponse where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10]) (P'.fromDistinctAscList [10])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.GetClientIDResponse\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"GetClientIDResponse\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"GetClientIDResponse.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.GetClientIDResponse.client_id\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"GetClientIDResponse\"], baseName' = FName \"client_id\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/GetRequest.hs b/src/Network/Riak/Protocol/GetRequest.hs
new file mode 100644
index 0000000..e6c1091
--- /dev/null
+++ b/src/Network/Riak/Protocol/GetRequest.hs
@@ -0,0 +1,68 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.GetRequest (GetRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data GetRequest = GetRequest{bucket :: P'.ByteString, key :: P'.ByteString, r :: P'.Maybe P'.Word32}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable GetRequest where
+ mergeEmpty = GetRequest P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (GetRequest x'1 x'2 x'3) (GetRequest y'1 y'2 y'3)
+ = GetRequest (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2) (P'.mergeAppend x'3 y'3)
+
+instance P'.Default GetRequest where
+ defaultValue = GetRequest P'.defaultValue P'.defaultValue P'.defaultValue
+
+instance P'.Wire GetRequest where
+ wireSize ft' self'@(GetRequest x'1 x'2 x'3)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1 + P'.wireSizeReq 1 12 x'2 + P'.wireSizeOpt 1 13 x'3)
+ wirePut ft' self'@(GetRequest x'1 x'2 x'3)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ P'.wirePutReq 18 12 x'2
+ P'.wirePutOpt 24 13 x'3
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{bucket = new'Field}) (P'.wireGet 12)
+ 18 -> P'.fmap (\ new'Field -> old'Self{key = new'Field}) (P'.wireGet 12)
+ 24 -> P'.fmap (\ new'Field -> old'Self{r = P'.Just new'Field}) (P'.wireGet 13)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> GetRequest) GetRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB GetRequest
+
+instance P'.ReflectDescriptor GetRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10, 18]) (P'.fromDistinctAscList [10, 18, 24])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.GetRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"GetRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"GetRequest.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.GetRequest.bucket\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"GetRequest\"], baseName' = FName \"bucket\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.GetRequest.key\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"GetRequest\"], baseName' = FName \"key\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.GetRequest.r\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"GetRequest\"], baseName' = FName \"r\"}, fieldNumber = FieldId {getFieldId = 3}, wireTag = WireTag {getWireTag = 24}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 13}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/GetResponse.hs b/src/Network/Riak/Protocol/GetResponse.hs
new file mode 100644
index 0000000..e3e23b7
--- /dev/null
+++ b/src/Network/Riak/Protocol/GetResponse.hs
@@ -0,0 +1,66 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.GetResponse (GetResponse(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+import qualified Network.Riak.Protocol.Content as Protocol (Content)
+
+data GetResponse = GetResponse{content :: P'.Seq Protocol.Content, vclock :: P'.Maybe P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable GetResponse where
+ mergeEmpty = GetResponse P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (GetResponse x'1 x'2) (GetResponse y'1 y'2) = GetResponse (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2)
+
+instance P'.Default GetResponse where
+ defaultValue = GetResponse P'.defaultValue P'.defaultValue
+
+instance P'.Wire GetResponse where
+ wireSize ft' self'@(GetResponse x'1 x'2)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeRep 1 11 x'1 + P'.wireSizeOpt 1 12 x'2)
+ wirePut ft' self'@(GetResponse x'1 x'2)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutRep 10 11 x'1
+ P'.wirePutOpt 18 12 x'2
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{content = P'.append (content old'Self) new'Field}) (P'.wireGet 11)
+ 18 -> P'.fmap (\ new'Field -> old'Self{vclock = P'.Just new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> GetResponse) GetResponse where
+ getVal m' f' = f' m'
+
+instance P'.GPB GetResponse
+
+instance P'.ReflectDescriptor GetResponse where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [10, 18])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.GetResponse\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"GetResponse\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"GetResponse.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.GetResponse.content\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"GetResponse\"], baseName' = FName \"content\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = True, mightPack = False, typeCode = FieldType {getFieldType = 11}, typeName = Just (ProtoName {protobufName = FIName \".Protocol.Content\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"Content\"}), hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.GetResponse.vclock\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"GetResponse\"], baseName' = FName \"vclock\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/GetServerInfoRequest.hs b/src/Network/Riak/Protocol/GetServerInfoRequest.hs
new file mode 100644
index 0000000..a9dde52
--- /dev/null
+++ b/src/Network/Riak/Protocol/GetServerInfoRequest.hs
@@ -0,0 +1,62 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.GetServerInfoRequest (GetServerInfoRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data GetServerInfoRequest = GetServerInfoRequest{}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable GetServerInfoRequest where
+ mergeEmpty = GetServerInfoRequest
+ mergeAppend (GetServerInfoRequest) (GetServerInfoRequest) = GetServerInfoRequest
+
+instance P'.Default GetServerInfoRequest where
+ defaultValue = GetServerInfoRequest
+
+instance P'.Wire GetServerInfoRequest where
+ wireSize ft' self'@(GetServerInfoRequest)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = 0
+ wirePut ft' self'@(GetServerInfoRequest)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.return ()
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> GetServerInfoRequest) GetServerInfoRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB GetServerInfoRequest
+
+instance P'.ReflectDescriptor GetServerInfoRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.GetServerInfoRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"GetServerInfoRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"GetServerInfoRequest.hs\"], isGroup = False, fields = fromList [], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/Link.hs b/src/Network/Riak/Protocol/Link.hs
new file mode 100644
index 0000000..5d2cce9
--- /dev/null
+++ b/src/Network/Riak/Protocol/Link.hs
@@ -0,0 +1,68 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.Link (Link(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data Link = Link{bucket :: P'.Maybe P'.ByteString, key :: P'.Maybe P'.ByteString, tag :: P'.Maybe P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable Link where
+ mergeEmpty = Link P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (Link x'1 x'2 x'3) (Link y'1 y'2 y'3)
+ = Link (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2) (P'.mergeAppend x'3 y'3)
+
+instance P'.Default Link where
+ defaultValue = Link P'.defaultValue P'.defaultValue P'.defaultValue
+
+instance P'.Wire Link where
+ wireSize ft' self'@(Link x'1 x'2 x'3)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeOpt 1 12 x'1 + P'.wireSizeOpt 1 12 x'2 + P'.wireSizeOpt 1 12 x'3)
+ wirePut ft' self'@(Link x'1 x'2 x'3)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutOpt 10 12 x'1
+ P'.wirePutOpt 18 12 x'2
+ P'.wirePutOpt 26 12 x'3
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{bucket = P'.Just new'Field}) (P'.wireGet 12)
+ 18 -> P'.fmap (\ new'Field -> old'Self{key = P'.Just new'Field}) (P'.wireGet 12)
+ 26 -> P'.fmap (\ new'Field -> old'Self{tag = P'.Just new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> Link) Link where
+ getVal m' f' = f' m'
+
+instance P'.GPB Link
+
+instance P'.ReflectDescriptor Link where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [10, 18, 26])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.Link\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"Link\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"Link.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Link.bucket\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Link\"], baseName' = FName \"bucket\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Link.key\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Link\"], baseName' = FName \"key\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Link.tag\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Link\"], baseName' = FName \"tag\"}, fieldNumber = FieldId {getFieldId = 3}, wireTag = WireTag {getWireTag = 26}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/ListBucketsRequest.hs b/src/Network/Riak/Protocol/ListBucketsRequest.hs
new file mode 100644
index 0000000..a5b3bfb
--- /dev/null
+++ b/src/Network/Riak/Protocol/ListBucketsRequest.hs
@@ -0,0 +1,62 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.ListBucketsRequest (ListBucketsRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data ListBucketsRequest = ListBucketsRequest{}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable ListBucketsRequest where
+ mergeEmpty = ListBucketsRequest
+ mergeAppend (ListBucketsRequest) (ListBucketsRequest) = ListBucketsRequest
+
+instance P'.Default ListBucketsRequest where
+ defaultValue = ListBucketsRequest
+
+instance P'.Wire ListBucketsRequest where
+ wireSize ft' self'@(ListBucketsRequest)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = 0
+ wirePut ft' self'@(ListBucketsRequest)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.return ()
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> ListBucketsRequest) ListBucketsRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB ListBucketsRequest
+
+instance P'.ReflectDescriptor ListBucketsRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.ListBucketsRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"ListBucketsRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"ListBucketsRequest.hs\"], isGroup = False, fields = fromList [], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/ListBucketsResponse.hs b/src/Network/Riak/Protocol/ListBucketsResponse.hs
new file mode 100644
index 0000000..b853740
--- /dev/null
+++ b/src/Network/Riak/Protocol/ListBucketsResponse.hs
@@ -0,0 +1,63 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.ListBucketsResponse (ListBucketsResponse(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data ListBucketsResponse = ListBucketsResponse{buckets :: P'.Seq P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable ListBucketsResponse where
+ mergeEmpty = ListBucketsResponse P'.mergeEmpty
+ mergeAppend (ListBucketsResponse x'1) (ListBucketsResponse y'1) = ListBucketsResponse (P'.mergeAppend x'1 y'1)
+
+instance P'.Default ListBucketsResponse where
+ defaultValue = ListBucketsResponse P'.defaultValue
+
+instance P'.Wire ListBucketsResponse where
+ wireSize ft' self'@(ListBucketsResponse x'1)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeRep 1 12 x'1)
+ wirePut ft' self'@(ListBucketsResponse x'1)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutRep 10 12 x'1
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{buckets = P'.append (buckets old'Self) new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> ListBucketsResponse) ListBucketsResponse where
+ getVal m' f' = f' m'
+
+instance P'.GPB ListBucketsResponse
+
+instance P'.ReflectDescriptor ListBucketsResponse where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [10])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.ListBucketsResponse\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"ListBucketsResponse\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"ListBucketsResponse.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.ListBucketsResponse.buckets\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"ListBucketsResponse\"], baseName' = FName \"buckets\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = True, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/ListKeysRequest.hs b/src/Network/Riak/Protocol/ListKeysRequest.hs
new file mode 100644
index 0000000..57ac115
--- /dev/null
+++ b/src/Network/Riak/Protocol/ListKeysRequest.hs
@@ -0,0 +1,63 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.ListKeysRequest (ListKeysRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data ListKeysRequest = ListKeysRequest{bucket :: P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable ListKeysRequest where
+ mergeEmpty = ListKeysRequest P'.mergeEmpty
+ mergeAppend (ListKeysRequest x'1) (ListKeysRequest y'1) = ListKeysRequest (P'.mergeAppend x'1 y'1)
+
+instance P'.Default ListKeysRequest where
+ defaultValue = ListKeysRequest P'.defaultValue
+
+instance P'.Wire ListKeysRequest where
+ wireSize ft' self'@(ListKeysRequest x'1)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1)
+ wirePut ft' self'@(ListKeysRequest x'1)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{bucket = new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> ListKeysRequest) ListKeysRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB ListKeysRequest
+
+instance P'.ReflectDescriptor ListKeysRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10]) (P'.fromDistinctAscList [10])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.ListKeysRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"ListKeysRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"ListKeysRequest.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.ListKeysRequest.bucket\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"ListKeysRequest\"], baseName' = FName \"bucket\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/ListKeysResponse.hs b/src/Network/Riak/Protocol/ListKeysResponse.hs
new file mode 100644
index 0000000..1b51f00
--- /dev/null
+++ b/src/Network/Riak/Protocol/ListKeysResponse.hs
@@ -0,0 +1,66 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.ListKeysResponse (ListKeysResponse(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data ListKeysResponse = ListKeysResponse{keys :: P'.Seq P'.ByteString, done :: P'.Maybe P'.Bool}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable ListKeysResponse where
+ mergeEmpty = ListKeysResponse P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (ListKeysResponse x'1 x'2) (ListKeysResponse y'1 y'2)
+ = ListKeysResponse (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2)
+
+instance P'.Default ListKeysResponse where
+ defaultValue = ListKeysResponse P'.defaultValue P'.defaultValue
+
+instance P'.Wire ListKeysResponse where
+ wireSize ft' self'@(ListKeysResponse x'1 x'2)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeRep 1 12 x'1 + P'.wireSizeOpt 1 8 x'2)
+ wirePut ft' self'@(ListKeysResponse x'1 x'2)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutRep 10 12 x'1
+ P'.wirePutOpt 16 8 x'2
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{keys = P'.append (keys old'Self) new'Field}) (P'.wireGet 12)
+ 16 -> P'.fmap (\ new'Field -> old'Self{done = P'.Just new'Field}) (P'.wireGet 8)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> ListKeysResponse) ListKeysResponse where
+ getVal m' f' = f' m'
+
+instance P'.GPB ListKeysResponse
+
+instance P'.ReflectDescriptor ListKeysResponse where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [10, 16])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.ListKeysResponse\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"ListKeysResponse\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"ListKeysResponse.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.ListKeysResponse.keys\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"ListKeysResponse\"], baseName' = FName \"keys\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = True, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.ListKeysResponse.done\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"ListKeysResponse\"], baseName' = FName \"done\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 16}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 8}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/MapReduce.hs b/src/Network/Riak/Protocol/MapReduce.hs
new file mode 100644
index 0000000..09dbb23
--- /dev/null
+++ b/src/Network/Riak/Protocol/MapReduce.hs
@@ -0,0 +1,68 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.MapReduce (MapReduce(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data MapReduce = MapReduce{phase :: P'.Maybe P'.Word32, response :: P'.Maybe P'.ByteString, done :: P'.Maybe P'.Bool}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable MapReduce where
+ mergeEmpty = MapReduce P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (MapReduce x'1 x'2 x'3) (MapReduce y'1 y'2 y'3)
+ = MapReduce (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2) (P'.mergeAppend x'3 y'3)
+
+instance P'.Default MapReduce where
+ defaultValue = MapReduce P'.defaultValue P'.defaultValue P'.defaultValue
+
+instance P'.Wire MapReduce where
+ wireSize ft' self'@(MapReduce x'1 x'2 x'3)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeOpt 1 13 x'1 + P'.wireSizeOpt 1 12 x'2 + P'.wireSizeOpt 1 8 x'3)
+ wirePut ft' self'@(MapReduce x'1 x'2 x'3)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutOpt 8 13 x'1
+ P'.wirePutOpt 18 12 x'2
+ P'.wirePutOpt 24 8 x'3
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 8 -> P'.fmap (\ new'Field -> old'Self{phase = P'.Just new'Field}) (P'.wireGet 13)
+ 18 -> P'.fmap (\ new'Field -> old'Self{response = P'.Just new'Field}) (P'.wireGet 12)
+ 24 -> P'.fmap (\ new'Field -> old'Self{done = P'.Just new'Field}) (P'.wireGet 8)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> MapReduce) MapReduce where
+ getVal m' f' = f' m'
+
+instance P'.GPB MapReduce
+
+instance P'.ReflectDescriptor MapReduce where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [8, 18, 24])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.MapReduce\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"MapReduce\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"MapReduce.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.MapReduce.phase\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"MapReduce\"], baseName' = FName \"phase\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 8}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 13}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.MapReduce.response\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"MapReduce\"], baseName' = FName \"response\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.MapReduce.done\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"MapReduce\"], baseName' = FName \"done\"}, fieldNumber = FieldId {getFieldId = 3}, wireTag = WireTag {getWireTag = 24}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 8}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/MapReduceRequest.hs b/src/Network/Riak/Protocol/MapReduceRequest.hs
new file mode 100644
index 0000000..6cbf7a7
--- /dev/null
+++ b/src/Network/Riak/Protocol/MapReduceRequest.hs
@@ -0,0 +1,66 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.MapReduceRequest (MapReduceRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data MapReduceRequest = MapReduceRequest{request :: P'.ByteString, content_type :: P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable MapReduceRequest where
+ mergeEmpty = MapReduceRequest P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (MapReduceRequest x'1 x'2) (MapReduceRequest y'1 y'2)
+ = MapReduceRequest (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2)
+
+instance P'.Default MapReduceRequest where
+ defaultValue = MapReduceRequest P'.defaultValue P'.defaultValue
+
+instance P'.Wire MapReduceRequest where
+ wireSize ft' self'@(MapReduceRequest x'1 x'2)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1 + P'.wireSizeReq 1 12 x'2)
+ wirePut ft' self'@(MapReduceRequest x'1 x'2)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ P'.wirePutReq 18 12 x'2
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{request = new'Field}) (P'.wireGet 12)
+ 18 -> P'.fmap (\ new'Field -> old'Self{content_type = new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> MapReduceRequest) MapReduceRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB MapReduceRequest
+
+instance P'.ReflectDescriptor MapReduceRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10, 18]) (P'.fromDistinctAscList [10, 18])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.MapReduceRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"MapReduceRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"MapReduceRequest.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.MapReduceRequest.request\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"MapReduceRequest\"], baseName' = FName \"request\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.MapReduceRequest.content_type\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"MapReduceRequest\"], baseName' = FName \"content_type\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/Pair.hs b/src/Network/Riak/Protocol/Pair.hs
new file mode 100644
index 0000000..aa1e150
--- /dev/null
+++ b/src/Network/Riak/Protocol/Pair.hs
@@ -0,0 +1,65 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.Pair (Pair(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data Pair = Pair{key :: P'.ByteString, value :: P'.Maybe P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable Pair where
+ mergeEmpty = Pair P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (Pair x'1 x'2) (Pair y'1 y'2) = Pair (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2)
+
+instance P'.Default Pair where
+ defaultValue = Pair P'.defaultValue P'.defaultValue
+
+instance P'.Wire Pair where
+ wireSize ft' self'@(Pair x'1 x'2)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1 + P'.wireSizeOpt 1 12 x'2)
+ wirePut ft' self'@(Pair x'1 x'2)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ P'.wirePutOpt 18 12 x'2
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{key = new'Field}) (P'.wireGet 12)
+ 18 -> P'.fmap (\ new'Field -> old'Self{value = P'.Just new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> Pair) Pair where
+ getVal m' f' = f' m'
+
+instance P'.GPB Pair
+
+instance P'.ReflectDescriptor Pair where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10]) (P'.fromDistinctAscList [10, 18])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.Pair\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"Pair\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"Pair.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Pair.key\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Pair\"], baseName' = FName \"key\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.Pair.value\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"Pair\"], baseName' = FName \"value\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/PingRequest.hs b/src/Network/Riak/Protocol/PingRequest.hs
new file mode 100644
index 0000000..74df52b
--- /dev/null
+++ b/src/Network/Riak/Protocol/PingRequest.hs
@@ -0,0 +1,62 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.PingRequest (PingRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data PingRequest = PingRequest{}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable PingRequest where
+ mergeEmpty = PingRequest
+ mergeAppend (PingRequest) (PingRequest) = PingRequest
+
+instance P'.Default PingRequest where
+ defaultValue = PingRequest
+
+instance P'.Wire PingRequest where
+ wireSize ft' self'@(PingRequest)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = 0
+ wirePut ft' self'@(PingRequest)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.return ()
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> PingRequest) PingRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB PingRequest
+
+instance P'.ReflectDescriptor PingRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.PingRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"PingRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"PingRequest.hs\"], isGroup = False, fields = fromList [], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/PutRequest.hs b/src/Network/Riak/Protocol/PutRequest.hs
new file mode 100644
index 0000000..d320832
--- /dev/null
+++ b/src/Network/Riak/Protocol/PutRequest.hs
@@ -0,0 +1,87 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.PutRequest (PutRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+import qualified Network.Riak.Protocol.Content as Protocol (Content)
+
+data PutRequest = PutRequest{bucket :: P'.ByteString, key :: P'.ByteString, vclock :: P'.Maybe P'.ByteString,
+ content :: Protocol.Content, w :: P'.Maybe P'.Word32, dw :: P'.Maybe P'.Word32,
+ return_body :: P'.Maybe P'.Bool}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable PutRequest where
+ mergeEmpty = PutRequest P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (PutRequest x'1 x'2 x'3 x'4 x'5 x'6 x'7) (PutRequest y'1 y'2 y'3 y'4 y'5 y'6 y'7)
+ = PutRequest (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2) (P'.mergeAppend x'3 y'3) (P'.mergeAppend x'4 y'4)
+ (P'.mergeAppend x'5 y'5)
+ (P'.mergeAppend x'6 y'6)
+ (P'.mergeAppend x'7 y'7)
+
+instance P'.Default PutRequest where
+ defaultValue
+ = PutRequest P'.defaultValue P'.defaultValue P'.defaultValue P'.defaultValue P'.defaultValue P'.defaultValue P'.defaultValue
+
+instance P'.Wire PutRequest where
+ wireSize ft' self'@(PutRequest x'1 x'2 x'3 x'4 x'5 x'6 x'7)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size
+ = (P'.wireSizeReq 1 12 x'1 + P'.wireSizeReq 1 12 x'2 + P'.wireSizeOpt 1 12 x'3 + P'.wireSizeReq 1 11 x'4 +
+ P'.wireSizeOpt 1 13 x'5
+ + P'.wireSizeOpt 1 13 x'6
+ + P'.wireSizeOpt 1 8 x'7)
+ wirePut ft' self'@(PutRequest x'1 x'2 x'3 x'4 x'5 x'6 x'7)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ P'.wirePutReq 18 12 x'2
+ P'.wirePutOpt 26 12 x'3
+ P'.wirePutReq 34 11 x'4
+ P'.wirePutOpt 40 13 x'5
+ P'.wirePutOpt 48 13 x'6
+ P'.wirePutOpt 56 8 x'7
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{bucket = new'Field}) (P'.wireGet 12)
+ 18 -> P'.fmap (\ new'Field -> old'Self{key = new'Field}) (P'.wireGet 12)
+ 26 -> P'.fmap (\ new'Field -> old'Self{vclock = P'.Just new'Field}) (P'.wireGet 12)
+ 34 -> P'.fmap (\ new'Field -> old'Self{content = P'.mergeAppend (content old'Self) (new'Field)}) (P'.wireGet 11)
+ 40 -> P'.fmap (\ new'Field -> old'Self{w = P'.Just new'Field}) (P'.wireGet 13)
+ 48 -> P'.fmap (\ new'Field -> old'Self{dw = P'.Just new'Field}) (P'.wireGet 13)
+ 56 -> P'.fmap (\ new'Field -> old'Self{return_body = P'.Just new'Field}) (P'.wireGet 8)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> PutRequest) PutRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB PutRequest
+
+instance P'.ReflectDescriptor PutRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10, 18, 34]) (P'.fromDistinctAscList [10, 18, 26, 34, 40, 48, 56])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.PutRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"PutRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"PutRequest.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.PutRequest.bucket\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"PutRequest\"], baseName' = FName \"bucket\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.PutRequest.key\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"PutRequest\"], baseName' = FName \"key\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.PutRequest.vclock\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"PutRequest\"], baseName' = FName \"vclock\"}, fieldNumber = FieldId {getFieldId = 3}, wireTag = WireTag {getWireTag = 26}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.PutRequest.content\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"PutRequest\"], baseName' = FName \"content\"}, fieldNumber = FieldId {getFieldId = 4}, wireTag = WireTag {getWireTag = 34}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 11}, typeName = Just (ProtoName {protobufName = FIName \".Protocol.Content\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"Content\"}), hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.PutRequest.w\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"PutRequest\"], baseName' = FName \"w\"}, fieldNumber = FieldId {getFieldId = 5}, wireTag = WireTag {getWireTag = 40}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 13}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.PutRequest.dw\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"PutRequest\"], baseName' = FName \"dw\"}, fieldNumber = FieldId {getFieldId = 6}, wireTag = WireTag {getWireTag = 48}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 13}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.PutRequest.return_body\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"PutRequest\"], baseName' = FName \"return_body\"}, fieldNumber = FieldId {getFieldId = 7}, wireTag = WireTag {getWireTag = 56}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 8}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/PutResponse.hs b/src/Network/Riak/Protocol/PutResponse.hs
new file mode 100644
index 0000000..220e6cf
--- /dev/null
+++ b/src/Network/Riak/Protocol/PutResponse.hs
@@ -0,0 +1,66 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.PutResponse (PutResponse(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+import qualified Network.Riak.Protocol.Content as Protocol (Content)
+
+data PutResponse = PutResponse{content :: P'.Seq Protocol.Content, vclock :: P'.Maybe P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable PutResponse where
+ mergeEmpty = PutResponse P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (PutResponse x'1 x'2) (PutResponse y'1 y'2) = PutResponse (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2)
+
+instance P'.Default PutResponse where
+ defaultValue = PutResponse P'.defaultValue P'.defaultValue
+
+instance P'.Wire PutResponse where
+ wireSize ft' self'@(PutResponse x'1 x'2)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeRep 1 11 x'1 + P'.wireSizeOpt 1 12 x'2)
+ wirePut ft' self'@(PutResponse x'1 x'2)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutRep 10 11 x'1
+ P'.wirePutOpt 18 12 x'2
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{content = P'.append (content old'Self) new'Field}) (P'.wireGet 11)
+ 18 -> P'.fmap (\ new'Field -> old'Self{vclock = P'.Just new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> PutResponse) PutResponse where
+ getVal m' f' = f' m'
+
+instance P'.GPB PutResponse
+
+instance P'.ReflectDescriptor PutResponse where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [10, 18])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.PutResponse\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"PutResponse\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"PutResponse.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.PutResponse.content\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"PutResponse\"], baseName' = FName \"content\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = True, mightPack = False, typeCode = FieldType {getFieldType = 11}, typeName = Just (ProtoName {protobufName = FIName \".Protocol.Content\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"Content\"}), hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.PutResponse.vclock\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"PutResponse\"], baseName' = FName \"vclock\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/ServerInfo.hs b/src/Network/Riak/Protocol/ServerInfo.hs
new file mode 100644
index 0000000..2d59a78
--- /dev/null
+++ b/src/Network/Riak/Protocol/ServerInfo.hs
@@ -0,0 +1,65 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.ServerInfo (ServerInfo(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data ServerInfo = ServerInfo{node :: P'.Maybe P'.ByteString, server_version :: P'.Maybe P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable ServerInfo where
+ mergeEmpty = ServerInfo P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (ServerInfo x'1 x'2) (ServerInfo y'1 y'2) = ServerInfo (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2)
+
+instance P'.Default ServerInfo where
+ defaultValue = ServerInfo P'.defaultValue P'.defaultValue
+
+instance P'.Wire ServerInfo where
+ wireSize ft' self'@(ServerInfo x'1 x'2)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeOpt 1 12 x'1 + P'.wireSizeOpt 1 12 x'2)
+ wirePut ft' self'@(ServerInfo x'1 x'2)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutOpt 10 12 x'1
+ P'.wirePutOpt 18 12 x'2
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{node = P'.Just new'Field}) (P'.wireGet 12)
+ 18 -> P'.fmap (\ new'Field -> old'Self{server_version = P'.Just new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> ServerInfo) ServerInfo where
+ getVal m' f' = f' m'
+
+instance P'.GPB ServerInfo
+
+instance P'.ReflectDescriptor ServerInfo where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList []) (P'.fromDistinctAscList [10, 18])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.ServerInfo\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"ServerInfo\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"ServerInfo.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.ServerInfo.node\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"ServerInfo\"], baseName' = FName \"node\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.ServerInfo.server_version\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"ServerInfo\"], baseName' = FName \"server_version\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = False, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/SetBucketRequest.hs b/src/Network/Riak/Protocol/SetBucketRequest.hs
new file mode 100644
index 0000000..9f51d05
--- /dev/null
+++ b/src/Network/Riak/Protocol/SetBucketRequest.hs
@@ -0,0 +1,67 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.SetBucketRequest (SetBucketRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+import qualified Network.Riak.Protocol.BucketProps as Protocol (BucketProps)
+
+data SetBucketRequest = SetBucketRequest{bucket :: P'.ByteString, props :: Protocol.BucketProps}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable SetBucketRequest where
+ mergeEmpty = SetBucketRequest P'.mergeEmpty P'.mergeEmpty
+ mergeAppend (SetBucketRequest x'1 x'2) (SetBucketRequest y'1 y'2)
+ = SetBucketRequest (P'.mergeAppend x'1 y'1) (P'.mergeAppend x'2 y'2)
+
+instance P'.Default SetBucketRequest where
+ defaultValue = SetBucketRequest P'.defaultValue P'.defaultValue
+
+instance P'.Wire SetBucketRequest where
+ wireSize ft' self'@(SetBucketRequest x'1 x'2)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1 + P'.wireSizeReq 1 11 x'2)
+ wirePut ft' self'@(SetBucketRequest x'1 x'2)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ P'.wirePutReq 18 11 x'2
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{bucket = new'Field}) (P'.wireGet 12)
+ 18 -> P'.fmap (\ new'Field -> old'Self{props = P'.mergeAppend (props old'Self) (new'Field)}) (P'.wireGet 11)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> SetBucketRequest) SetBucketRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB SetBucketRequest
+
+instance P'.ReflectDescriptor SetBucketRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10, 18]) (P'.fromDistinctAscList [10, 18])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.SetBucketRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"SetBucketRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"SetBucketRequest.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.SetBucketRequest.bucket\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"SetBucketRequest\"], baseName' = FName \"bucket\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing},FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.SetBucketRequest.props\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"SetBucketRequest\"], baseName' = FName \"props\"}, fieldNumber = FieldId {getFieldId = 2}, wireTag = WireTag {getWireTag = 18}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 11}, typeName = Just (ProtoName {protobufName = FIName \".Protocol.BucketProps\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"BucketProps\"}), hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/Network/Riak/Protocol/SetClientIDRequest.hs b/src/Network/Riak/Protocol/SetClientIDRequest.hs
new file mode 100644
index 0000000..013c2c4
--- /dev/null
+++ b/src/Network/Riak/Protocol/SetClientIDRequest.hs
@@ -0,0 +1,63 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE FlexibleInstances #-}
+{-# LANGUAGE MultiParamTypeClasses #-}
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+module Network.Riak.Protocol.SetClientIDRequest (SetClientIDRequest(..)) where
+import Prelude ((+))
+import qualified Prelude as P'
+import qualified Text.ProtocolBuffers.Header as P'
+
+data SetClientIDRequest = SetClientIDRequest{client_id :: P'.ByteString}
+ deriving (P'.Show, P'.Eq, P'.Ord, P'.Typeable)
+
+instance P'.Mergeable SetClientIDRequest where
+ mergeEmpty = SetClientIDRequest P'.mergeEmpty
+ mergeAppend (SetClientIDRequest x'1) (SetClientIDRequest y'1) = SetClientIDRequest (P'.mergeAppend x'1 y'1)
+
+instance P'.Default SetClientIDRequest where
+ defaultValue = SetClientIDRequest P'.defaultValue
+
+instance P'.Wire SetClientIDRequest where
+ wireSize ft' self'@(SetClientIDRequest x'1)
+ = case ft' of
+ 10 -> calc'Size
+ 11 -> P'.prependMessageSize calc'Size
+ _ -> P'.wireSizeErr ft' self'
+ where
+ calc'Size = (P'.wireSizeReq 1 12 x'1)
+ wirePut ft' self'@(SetClientIDRequest x'1)
+ = case ft' of
+ 10 -> put'Fields
+ 11 -> do
+ P'.putSize (P'.wireSize 10 self')
+ put'Fields
+ _ -> P'.wirePutErr ft' self'
+ where
+ put'Fields
+ = do
+ P'.wirePutReq 10 12 x'1
+ wireGet ft'
+ = case ft' of
+ 10 -> P'.getBareMessageWith update'Self
+ 11 -> P'.getMessageWith update'Self
+ _ -> P'.wireGetErr ft'
+ where
+ update'Self wire'Tag old'Self
+ = case wire'Tag of
+ 10 -> P'.fmap (\ new'Field -> old'Self{client_id = new'Field}) (P'.wireGet 12)
+ _ -> let (field'Number, wire'Type) = P'.splitWireTag wire'Tag in P'.unknown field'Number wire'Type old'Self
+
+instance P'.MessageAPI msg' (msg' -> SetClientIDRequest) SetClientIDRequest where
+ getVal m' f' = f' m'
+
+instance P'.GPB SetClientIDRequest
+
+instance P'.ReflectDescriptor SetClientIDRequest where
+ getMessageInfo _ = P'.GetMessageInfo (P'.fromDistinctAscList [10]) (P'.fromDistinctAscList [10])
+ reflectDescriptorInfo _
+ = P'.read
+ "DescriptorInfo {descName = ProtoName {protobufName = FIName \".Protocol.SetClientIDRequest\", haskellPrefix = [MName \"Network\",MName \"Riak\"], parentModule = [MName \"Protocol\"], baseName = MName \"SetClientIDRequest\"}, descFilePath = [\"Network\",\"Riak\",\"Protocol\",\"SetClientIDRequest.hs\"], isGroup = False, fields = fromList [FieldInfo {fieldName = ProtoFName {protobufName' = FIName \".Protocol.SetClientIDRequest.client_id\", haskellPrefix' = [MName \"Network\",MName \"Riak\"], parentModule' = [MName \"Protocol\",MName \"SetClientIDRequest\"], baseName' = FName \"client_id\"}, fieldNumber = FieldId {getFieldId = 1}, wireTag = WireTag {getWireTag = 10}, packedTag = Nothing, wireTagLength = 1, isPacked = False, isRequired = True, canRepeat = False, mightPack = False, typeCode = FieldType {getFieldType = 12}, typeName = Nothing, hsRawDefault = Nothing, hsDefault = Nothing}], keys = fromList [], extRanges = [], knownKeys = fromList [], storeUnknown = False}" \ No newline at end of file
diff --git a/src/riakclient.proto b/src/riakclient.proto
new file mode 100644
index 0000000..e8150d6
--- /dev/null
+++ b/src/riakclient.proto
@@ -0,0 +1,246 @@
+/* -------------------------------------------------------------------
+**
+** riakclient.proto: Protocol buffers for riak
+**
+** Copyright (c) 2007-2010 Basho Technologies, Inc. All Rights Reserved.
+**
+** This file is provided to you under the Apache License,
+** Version 2.0 (the "License"); you may not use this file
+** except in compliance with the License. You may obtain
+** a copy of the License at
+**
+** http://www.apache.org/licenses/LICENSE-2.0
+**
+** Unless required by applicable law or agreed to in writing,
+** software distributed under the License is distributed on an
+** "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+** KIND, either express or implied. See the License for the
+** specific language governing permissions and limitations
+** under the License.
+**
+** -------------------------------------------------------------------
+*/
+/*
+** Revision: 1.1
+**
+** Lowest Common Denominator Protocol Buffers Client
+** - no ENUM (protobuffs_erlang does not support)
+**
+** Protocol
+**
+** The protocol encodes requests and responses as protocol buffer messages.
+** Each request message results in one or more response messages.
+** As message type and length are not encoded by PB they are sent
+** on the wire as
+**
+** <length:32> <msg_code:8> <pbmsg>
+**
+** length is the length of msg_code (1 byte) plus the message length
+** in bytes encoded in network order (big endian)
+**
+** msg_code indicates what is encoded as pbmsg
+**
+** pbmsg is the encoded protocol buffer message
+**
+** On connect, the client can make requests and will receive responses.
+** For each request message there is a corresponding response message,
+** or the server will respond with an error message if something has
+** gone wrong.
+**
+** The client should be prepared to handle messages without any pbmsg
+** (i.e. length==1) for requests like ping or a put without return_body set.
+**
+** RpbGetClientIdReq -> RpbGetClientIdResp
+** RpbSetClientIdReq -> RpbSetClientIdResp
+** RpbGetServerInfoReq -> RpbGetServerInfoResp
+** RpbPingReq -> RpbPingResp
+** RpbGetReq -> RpbErrorResp | RbpGetResp
+** RpbPutReq -> RpbErrorResp | RpbPutResp
+** RpbDelReq -> RpbErrorResp | RpbDelResp
+** RpbListBucketsReq -> RpbErrorResp | RpbListBucketsResp
+** RpbListKeysReq -> RpbErrorResp | RpbListKeysResp{1,}
+** RpbGetBucketReq -> RpbErrorResp | RpbGetBucketResp
+**
+**
+** Message Codes
+** 0 - RpbErrorResp
+** 1 - RpbPingReq - 0 length
+** 2 - RpbPingResp (pong) - 0 length
+** 3 - RpbGetClientIdReq
+** 4 - RpbGetClientIdResp
+** 5 - RpbSetClientIdReq
+** 6 - RpbSetClientIdResp
+** 7 - RpbGetServerInfoReq
+** 8 - RpbGetServerInfoResp
+** 9 - RpbGetReq
+** 10 - RpbGetResp
+** 11 - RpbPutReq
+** 12 - RpbPutResp - 0 length
+** 13 - RpbDelReq
+** 14 - RpbDelResp
+** 15 - RpbListBucketsReq
+** 16 - RpbListBucketsResp
+** 17 - RpbListKeysReq
+** 18 - RpbListKeysResp{1,}
+** 19 - RpbGetBucketReq
+** 20 - RpbGetBucketResp
+** 21 - RpbSetBucketReq
+** 22 - RpbSetBucketResp
+** 23 - RpbMapRedReq
+** 24 - RpbMapRedResp{1,}
+**
+*/
+
+// Error response - may be generated for any Req
+message RpbErrorResp {
+ required bytes errmsg = 1;
+ required uint32 errcode = 2;
+}
+
+// Get ClientId Request - no message defined, just send RpbGetClientIdReq message code
+message RpbGetClientIdResp {
+ required bytes client_id = 1; // Client id in use for this connection
+}
+
+message RpbSetClientIdReq {
+ required bytes client_id = 1; // Client id to use for this connection
+}
+// Set ClientId Request - no message defined, just send RpbSetClientIdReq message code
+
+// Get server info request - no message defined, just send RpbGetServerInfoReq message code
+
+message RpbGetServerInfoResp {
+ optional bytes node = 1;
+ optional bytes server_version = 2;
+}
+
+
+// Get Request - retrieve bucket/key
+message RpbGetReq {
+ required bytes bucket = 1;
+ required bytes key = 2;
+ optional uint32 r = 3;
+}
+
+// Get Response - if the record was not found there will be no content/vclock
+message RpbGetResp {
+ repeated RpbContent content = 1;
+ optional bytes vclock = 2; // the opaque vector clock for the object
+}
+
+
+// Put request - if options.return_body is set then the updated metadata/data for
+// the key will be returned.
+message RpbPutReq {
+ required bytes bucket = 1;
+ required bytes key = 2;
+ optional bytes vclock = 3;
+ required RpbContent content = 4;
+ optional uint32 w = 5;
+ optional uint32 dw = 6;
+ optional bool return_body = 7;
+}
+
+// Put response - same as get response
+message RpbPutResp {
+ repeated RpbContent content = 1;
+ optional bytes vclock = 2; // the opaque vector clock for the object
+}
+
+
+// Delete request
+message RpbDelReq {
+ required bytes bucket = 1;
+ required bytes key = 2;
+ optional uint32 rw = 3;
+}
+
+// Delete response - not defined, will return a RpbDelResp on success or RpbErrorResp on failure
+
+// List buckets request - no message defined, just send RpbListBucketsReq
+
+// List buckets response
+message RpbListBucketsResp {
+ repeated bytes buckets = 1;
+}
+
+
+// List keys in bucket request
+message RpbListKeysReq {
+ required bytes bucket = 1;
+}
+
+// List keys in bucket response - one or more of these packets will be sent
+// the last one will have done set true (and may not have any keys in it)
+message RpbListKeysResp {
+ repeated bytes keys = 1;
+ optional bool done = 2;
+}
+
+// Get bucket properties request
+message RpbGetBucketReq {
+ required bytes bucket = 1;
+}
+
+// Get bucket properties response
+message RpbGetBucketResp {
+ required RpbBucketProps props = 1;
+}
+
+// Set bucket properties request
+message RpbSetBucketReq {
+ required bytes bucket = 1;
+ required RpbBucketProps props = 2;
+}
+
+
+// Set bucket properties response - no message defined, just send RpbSetBucketResp
+
+
+// Map/Reduce request
+message RpbMapRedReq {
+ required bytes request = 1;
+ required bytes content_type = 2;
+}
+
+// Map/Reduce response
+// one or more of these packets will be sent the last one will have done set
+// true (and may not have phase/data in it)
+message RpbMapRedResp {
+ optional uint32 phase = 1;
+ optional bytes response = 2;
+ optional bool done = 3;
+}
+
+// Content message included in get/put responses
+// Holds the value and associated metadata
+message RpbContent {
+ required bytes value = 1;
+ optional bytes content_type = 2; // the media type/format
+ optional bytes charset = 3;
+ optional bytes content_encoding = 4;
+ optional bytes vtag = 5;
+ repeated RpbLink links = 6; // links to other resources
+ optional uint32 last_mod = 7;
+ optional uint32 last_mod_usecs = 8;
+ repeated RpbPair usermeta = 9; // user metadata stored with the object
+}
+
+// Key/value pair - used for user metadata
+message RpbPair {
+ required bytes key = 1;
+ optional bytes value = 2;
+}
+
+// Link metadata
+message RpbLink {
+ optional bytes bucket = 1;
+ optional bytes key = 2;
+ optional bytes tag = 3;
+}
+
+// Bucket properties
+message RpbBucketProps {
+ optional uint32 n_val = 1;
+ optional bool allow_mult = 2;
+}
diff --git a/src/riakextra.proto b/src/riakextra.proto
new file mode 100644
index 0000000..ff11e99
--- /dev/null
+++ b/src/riakextra.proto
@@ -0,0 +1,4 @@
+message RpbPingReq { }
+message RpbGetClientIdReq { }
+message RpbGetServerInfoReq { }
+message RpbListBucketsReq { }