Permalink
Browse files

Add native protobuf endpoint

  • Loading branch information...
justinsb committed Jan 6, 2014
1 parent 7531962 commit 1c6e9f7743e105ffea314cdf17bf96899bdc5b64
Showing with 4,614 additions and 181 deletions.
  1. +2 −2 cloudata-blocks/src/main/java/com/cloudata/blockstore/BlockStoreModule.java
  2. +1 −1 cloudata-blocks/src/main/java/com/cloudata/blockstore/backend/cloud/Segment.java
  3. +1 −1 cloudata-files/src/main/java/com/cloudata/files/FileServerModule.java
  4. +1 −1 cloudata-git/src/main/java/com/cloudata/git/GitModule.java
  5. +217 −51 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/{KeyValueProto.java → KeyValueLog.java}
  6. +7 −0 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/KeyValueModule.java
  7. +36 −2 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/KeyValueServer.java
  8. +29 −18 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/KeyValueStateMachine.java
  9. +3 −2 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/KeyValueStore.java
  10. +26 −17 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/operation/AppendOperation.java
  11. +55 −8 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/operation/DeleteOperation.java
  12. +21 −15 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/operation/IncrementOperation.java
  13. +2 −2 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/operation/KeyOperation.java
  14. +55 −9 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/operation/SetOperation.java
  15. +237 −0 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/protobuf/KeyValueProtobufEndpoint.java
  16. +35 −0 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/protobuf/ProtobufServer.java
  17. +5 −1 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/redis/RedisServer.java
  18. +2 −1 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/redis/commands/AppendCommand.java
  19. +1 −1 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/redis/commands/DelCommand.java
  20. +1 −1 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/redis/commands/IncrByCommand.java
  21. +1 −1 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/redis/commands/SetCommand.java
  22. +7 −7 cloudata-keyvalue/src/main/java/com/cloudata/keyvalue/web/KeyValueEndpoint.java
  23. +3 −0 cloudata-keyvalue/src/main/proto/{KeyValueProto.proto → KeyValueLog.proto}
  24. +3 −2 cloudata-keyvalue/src/test/java/com/cloudata/keyvalue/IntegrationTestBase.java
  25. +109 −0 cloudata-keyvalue/src/test/java/com/cloudata/keyvalue/NativeProtocolIntegrationTest.java
  26. +6 −0 cloudata-server-shared/src/main/java/com/cloudata/TestUtils.java
  27. +16 −3 cloudata-server-shared/src/main/java/com/cloudata/btree/BtreeQuery.java
  28. +12 −0 cloudata-server-shared/src/main/java/com/cloudata/btree/ByteBuffers.java
  29. +1 −10 cloudata-server-shared/src/main/java/com/cloudata/btree/Keyspace.java
  30. +17 −2 cloudata-server-shared/src/main/java/com/cloudata/btree/KeyspaceFilter.java
  31. +4 −4 ...ed/src/main/java/com/cloudata/btree/operation/{DeleteOperation.java → SimpleDeleteOperation.java}
  32. +4 −4 ...r-shared/src/main/java/com/cloudata/btree/operation/{SetOperation.java → SimpleSetOperation.java}
  33. +16 −0 cloudata-server-shared/src/main/java/com/cloudata/values/Value.java
  34. +2 −2 cloudata-server-shared/src/test/java/com/cloudata/btree/TestBtree.java
  35. +2 −0 cloudata-shared/src/main/java/com/cloudata/clients/keyvalue/IfNotExists.java
  36. +1 −1 cloudata-shared/src/main/java/com/cloudata/clients/keyvalue/IfVersion.java
  37. +3 −0 cloudata-shared/src/main/java/com/cloudata/clients/keyvalue/KeyValueStore.java
  38. +11 −0 cloudata-shared/src/main/java/com/cloudata/clients/keyvalue/PrefixKeyValueStore.java
  39. +30 −0 cloudata-shared/src/main/java/com/cloudata/clients/keyvalue/cloudata/CloudataKeyValueClient.java
  40. +65 −0 cloudata-shared/src/main/java/com/cloudata/clients/keyvalue/cloudata/CloudataKeyValueService.java
  41. +172 −0 cloudata-shared/src/main/java/com/cloudata/clients/keyvalue/cloudata/CloudataKeyValueStore.java
  42. +4 −1 cloudata-shared/src/main/java/com/cloudata/clients/keyvalue/{ → redis}/RedisKeyValueService.java
  43. +33 −1 cloudata-shared/src/main/java/com/cloudata/clients/keyvalue/{ → redis}/RedisKeyValueStore.java
  44. +52 −0 cloudata-shared/src/main/java/com/cloudata/clients/protobuf/ProtobufRpcChannelFactory.java
  45. +157 −0 cloudata-shared/src/main/java/com/cloudata/clients/protobuf/ProtobufRpcClient.java
  46. +51 −0 cloudata-shared/src/main/java/com/cloudata/clients/protobuf/ProtobufRpcClientProvider.java
  47. +3,030 −0 cloudata-shared/src/main/java/com/cloudata/keyvalue/KeyValueProtocol.java
  48. +43 −0 cloudata-shared/src/main/proto/KeyValueProtocol.proto
  49. +3 −0 cloudata-shared/update-protobuf.sh
  50. +5 −5 cloudata-structured/src/main/java/com/cloudata/structured/StructuredStore.java
  51. +3 −3 cloudata-structured/src/main/java/com/cloudata/structured/operation/StructuredDeleteOperation.java
  52. +2 −2 cloudata-structured/src/main/java/com/cloudata/structured/operation/StructuredSetOperation.java
  53. +9 −0 update-protobuf.sh
@@ -7,8 +7,8 @@
import com.cloudata.blockstore.backend.cloud.CloudVolumeProvider;
import com.cloudata.blockstore.backend.cloud.ThreadPools;
import com.cloudata.clients.keyvalue.KeyValueService;
import com.cloudata.clients.keyvalue.RedisKeyValueService;
import com.cloudata.clients.keyvalue.RedisKeyValueStore;
import com.cloudata.clients.keyvalue.redis.RedisKeyValueService;
import com.cloudata.clients.keyvalue.redis.RedisKeyValueStore;
import com.cloudata.files.blobs.BlobService;
import com.cloudata.files.blobs.LocalBlobService;
import com.google.common.util.concurrent.ListeningExecutorService;
@@ -639,7 +639,7 @@ public SegmentData apply(List<ByteString> blobHashes) {
Modifier modifier;
if (currentKeyValueVersion == null) {
modifier = new IfNotExists();
modifier = IfNotExists.INSTANCE;
} else {
modifier = new IfVersion(currentKeyValueVersion);
}
@@ -5,7 +5,7 @@
import java.util.concurrent.Executors;
import com.cloudata.clients.keyvalue.KeyValueStore;
import com.cloudata.clients.keyvalue.RedisKeyValueStore;
import com.cloudata.clients.keyvalue.redis.RedisKeyValueStore;
import com.cloudata.files.blobs.BlobCache;
import com.cloudata.files.blobs.BlobStore;
import com.cloudata.files.blobs.LocalBlobStore;
@@ -8,7 +8,7 @@
import com.cloudata.auth.AuthenticationManager;
import com.cloudata.clients.keyvalue.KeyValuePath;
import com.cloudata.clients.keyvalue.KeyValueStore;
import com.cloudata.clients.keyvalue.RedisKeyValueStore;
import com.cloudata.clients.keyvalue.redis.RedisKeyValueStore;
import com.cloudata.git.jgit.CloudGitRepositoryStore;
import com.cloudata.git.services.GitRepositoryStore;
import com.cloudata.git.services.JCloudsAuthenticationManager;
Oops, something went wrong.

0 comments on commit 1c6e9f7

Please sign in to comment.