fb1187bdb6a726651383bbd8ab2352a8a2be7dd6 - cassandra-accord

commit	fb1187bdb6a726651383bbd8ab2352a8a2be7dd6	[log] [tgz]
author	Blake Eggleston <bdeggleston@gmail.com>	Wed Dec 01 13:43:02 2021 -0800
committer	Blake Eggleston <blake@ultrablake.com>	Mon Apr 11 09:17:26 2022 -0700
tree	7f30dcf153d6a5c1a77c3eeb06d2b7ae3175fc29
parent	b71481c74479303e66589f1d61662eae0f4df247 [diff]

Initial Cassandra integration

Patch by Blake Eggleston; Reviewed by Benedict Elliott Smith for CASSANDRA-17412

accord-core/build.gradle[diff]
accord-core/src/main/java/accord/api/ConfigurationService.java[diff]
accord-core/src/main/java/accord/api/Key.java[diff]
accord-core/src/main/java/accord/api/KeyRange.java[diff]
accord-core/src/main/java/accord/api/MessageSink.java[diff]
accord-core/src/main/java/accord/api/Read.java[diff]
accord-core/src/main/java/accord/api/Write.java[diff]
accord-core/src/main/java/accord/coordinate/AcceptPhase.java[diff]
accord-core/src/main/java/accord/coordinate/Agree.java[diff]
accord-core/src/main/java/accord/coordinate/Coordinate.java[diff]
accord-core/src/main/java/accord/coordinate/Execute.java[diff]
accord-core/src/main/java/accord/coordinate/Recover.java[diff]
accord-core/src/main/java/accord/local/CommandStore.java[diff]
accord-core/src/main/java/accord/local/CommandStores.java[diff]
accord-core/src/main/java/accord/local/Node.java[diff]
accord-core/src/main/java/accord/messages/Accept.java[diff]
accord-core/src/main/java/accord/messages/Apply.java[diff]
accord-core/src/main/java/accord/messages/BeginRecovery.java[diff]
accord-core/src/main/java/accord/messages/Commit.java[diff]
accord-core/src/main/java/accord/messages/Message.java[diff]
accord-core/src/main/java/accord/messages/MessageType.java[Added - diff]
accord-core/src/main/java/accord/messages/PreAccept.java[diff]
accord-core/src/main/java/accord/messages/ReadData.java[diff]
accord-core/src/main/java/accord/messages/ReplyContext.java[Added - diff]
accord-core/src/main/java/accord/messages/Request.java[diff]
accord-core/src/main/java/accord/messages/TxnRequest.java[diff]
accord-core/src/main/java/accord/messages/WaitOnCommit.java[diff]
accord-core/src/main/java/accord/txn/Keys.java[diff]
accord-core/src/main/java/accord/txn/Txn.java[diff]
accord-core/src/main/java/accord/txn/Writes.java[diff]
accord-core/src/main/java/org/apache/cassandra/concurrent/ExecutionFailure.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/concurrent/ExecutorPlus.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/concurrent/ImmediateExecutor.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/Clock.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/Intercept.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/Shared.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/AbstractFuture.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/AsyncFuture.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/AsyncPromise.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/Awaitable.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/Condition.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/Future.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/ImmediateFuture.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/Inline.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/IntrusiveStack.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/ListenerList.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/Promise.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/UncheckedInterruptedException.java[Added - diff]
accord-core/src/main/java/org/apache/cassandra/utils/concurrent/WaitQueue.java[Added - diff]
accord-core/src/test/java/accord/KeysTest.java[diff]
accord-core/src/test/java/accord/burn/BurnTestConfigurationService.java[diff]
accord-core/src/test/java/accord/burn/TopologyUpdate.java[diff]
accord-core/src/test/java/accord/coordinate/CoordinateTest.java[diff]
accord-core/src/test/java/accord/coordinate/RecoverTest.java[diff]
accord-core/src/test/java/accord/coordinate/TopologyChangeTest.java[diff]
accord-core/src/test/java/accord/impl/IntHashKey.java[diff]
accord-core/src/test/java/accord/impl/IntKey.java[diff]
accord-core/src/test/java/accord/impl/basic/Cluster.java[diff]
accord-core/src/test/java/accord/impl/basic/NodeSink.java[diff]
accord-core/src/test/java/accord/impl/basic/Packet.java[diff]
accord-core/src/test/java/accord/impl/list/ListAgent.java[diff]
accord-core/src/test/java/accord/impl/list/ListRead.java[diff]
accord-core/src/test/java/accord/impl/list/ListRequest.java[diff]
accord-core/src/test/java/accord/impl/list/ListResult.java[diff]
accord-core/src/test/java/accord/impl/list/ListStore.java[diff]
accord-core/src/test/java/accord/impl/list/ListWrite.java[diff]
accord-core/src/test/java/accord/impl/mock/EpochSync.java[diff]
accord-core/src/test/java/accord/impl/mock/MockCluster.java[diff]
accord-core/src/test/java/accord/impl/mock/MockConfigurationService.java[diff]
accord-core/src/test/java/accord/impl/mock/MockStore.java[diff]
accord-core/src/test/java/accord/impl/mock/Network.java[diff]
accord-core/src/test/java/accord/impl/mock/RecordingMessageSink.java[diff]
accord-core/src/test/java/accord/impl/mock/SimpleMessageSink.java[diff]
accord-core/src/test/java/accord/local/CommandTest.java[diff]
accord-core/src/test/java/accord/messages/PreAcceptTest.java[diff]
accord-core/src/test/java/accord/topology/TopologyRandomizer.java[diff]
accord-core/src/test/java/accord/utils/KeyRangeTest.java[diff]
accord-core/src/test/java/accord/utils/MessageTask.java[diff]
accord-maelstrom/build.gradle[diff]
accord-maelstrom/src/main/java/accord/maelstrom/Cluster.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/Error.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromAgent.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromKey.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromRead.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromReply.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromReplyContext.java[Added - diff]
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromRequest.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromWrite.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/Main.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/Packet.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/SimpleConfigService.java[diff]
build.gradle[diff]

92 files changed

tree: 7f30dcf153d6a5c1a77c3eeb06d2b7ae3175fc29

accord-core/
accord-maelstrom/
gradle/
.gitignore
build.gradle
gradlew
gradlew.bat
settings.gradle