diff options
author | Tor Egge <Tor.Egge@oath.com> | 2017-10-03 11:37:51 +0000 |
---|---|---|
committer | Tor Egge <Tor.Egge@oath.com> | 2017-10-03 11:40:31 +0000 |
commit | 32f8d5bb20479e0895f97cebe9f575d7b09de8c5 (patch) | |
tree | 9d4d7808a5da6315df2088c03f419d7ece0c250f /persistence/src/tests/proxy/mockprovider.h | |
parent | 6e134d121f14dd940f84b25b5bc27ad22d80af2f (diff) |
Remove unused support for SPI over RPC.
Diffstat (limited to 'persistence/src/tests/proxy/mockprovider.h')
-rw-r--r-- | persistence/src/tests/proxy/mockprovider.h | 163 |
1 files changed, 0 insertions, 163 deletions
diff --git a/persistence/src/tests/proxy/mockprovider.h b/persistence/src/tests/proxy/mockprovider.h deleted file mode 100644 index fda0b4aa922..00000000000 --- a/persistence/src/tests/proxy/mockprovider.h +++ /dev/null @@ -1,163 +0,0 @@ -// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -#pragma once - -#include <vespa/persistence/spi/persistenceprovider.h> -#include <vespa/document/fieldvalue/document.h> - -namespace storage { -namespace spi { - -struct MockProvider : PersistenceProvider { - enum Function { NONE, INITIALIZE, GET_PARTITION_STATES, LIST_BUCKETS, - SET_CLUSTER_STATE, - SET_ACTIVE_STATE, GET_BUCKET_INFO, PUT, REMOVE_BY_ID, - REMOVE_IF_FOUND, REPLACE_WITH_REMOVE, UPDATE, FLUSH, GET, - CREATE_ITERATOR, ITERATE, DESTROY_ITERATOR, CREATE_BUCKET, - DELETE_BUCKET, GET_MODIFIED_BUCKETS, SPLIT, JOIN, MOVE, MAINTAIN, - REMOVE_ENTRY }; - - mutable Function last_called; - - MockProvider() : last_called(NONE) {} - - Result initialize() override { - last_called = INITIALIZE; - return Result(); - } - - PartitionStateListResult getPartitionStates() const override { - last_called = GET_PARTITION_STATES; - return PartitionStateListResult(PartitionStateList(1u)); - } - - BucketIdListResult listBuckets(PartitionId id) const override { - last_called = LIST_BUCKETS; - BucketIdListResult::List result; - result.push_back(document::BucketId(id)); - return BucketIdListResult(result); - } - - Result setClusterState(const ClusterState &) override { - last_called = SET_CLUSTER_STATE; - return Result(); - } - - Result setActiveState(const Bucket &, BucketInfo::ActiveState) override { - last_called = SET_ACTIVE_STATE; - return Result(); - } - - BucketInfoResult getBucketInfo(const Bucket &bucket) const override { - last_called = GET_BUCKET_INFO; - return BucketInfoResult(BucketInfo(BucketChecksum(1), 2, 3, - bucket.getBucketId().getRawId(), - bucket.getPartition(), - BucketInfo::READY, - BucketInfo::ACTIVE)); - } - - Result put(const Bucket &, Timestamp, const DocumentSP&, Context&) override { - last_called = PUT; - return Result(); - } - - RemoveResult remove(const Bucket &, Timestamp, const DocumentId &, Context&) override { - last_called = REMOVE_BY_ID; - return RemoveResult(true); - } - - RemoveResult removeIfFound(const Bucket &, Timestamp, const DocumentId &, Context&) override { - last_called = REMOVE_IF_FOUND; - return RemoveResult(true); - } - - virtual RemoveResult replaceWithRemove(const Bucket &, Timestamp, - const DocumentId &, Context&) { - last_called = REPLACE_WITH_REMOVE; - return RemoveResult(true); - } - - UpdateResult update(const Bucket &, Timestamp timestamp, const DocumentUpdateSP&, Context&) override { - last_called = UPDATE; - return UpdateResult(Timestamp(timestamp - 10)); - } - - Result flush(const Bucket&, Context&) override { - last_called = FLUSH; - return Result(); - } - - GetResult get(const Bucket &, const document::FieldSet&, const DocumentId&, Context&) const override { - last_called = GET; - return GetResult(Document::UP(new Document), - Timestamp(6u)); - } - - CreateIteratorResult createIterator(const Bucket& bucket, - const document::FieldSet&, - const Selection&, - IncludedVersions, - Context&) override - { - last_called = CREATE_ITERATOR; - return CreateIteratorResult(IteratorId(bucket.getPartition())); - } - - IterateResult iterate(IteratorId, uint64_t, Context&) const override { - last_called = ITERATE; - IterateResult::List result; - result.push_back(DocEntry::UP(new DocEntry(Timestamp(1), 0))); - return IterateResult(std::move(result), true); - } - - Result destroyIterator(IteratorId, Context&) override { - last_called = DESTROY_ITERATOR; - return Result(); - } - - Result createBucket(const Bucket&, Context&) override { - last_called = CREATE_BUCKET; - return Result(); - } - Result deleteBucket(const Bucket&, Context&) override { - last_called = DELETE_BUCKET; - return Result(); - } - - BucketIdListResult getModifiedBuckets() const override { - last_called = GET_MODIFIED_BUCKETS; - BucketIdListResult::List list; - list.push_back(document::BucketId(2)); - list.push_back(document::BucketId(3)); - return BucketIdListResult(list); - } - - Result split(const Bucket &, const Bucket &, const Bucket &, Context&) override { - last_called = SPLIT; - return Result(); - } - - Result join(const Bucket &, const Bucket &, const Bucket &, Context&) override { - last_called = JOIN; - return Result(); - } - - Result move(const Bucket &, PartitionId, Context&) override { - last_called = MOVE; - return Result(); - } - - - Result maintain(const Bucket &, MaintenanceLevel) override { - last_called = MAINTAIN; - return Result(); - } - - Result removeEntry(const Bucket &, Timestamp, Context&) override { - last_called = REMOVE_ENTRY; - return Result(); - } -}; - -} // namespace spi -} // namespace storage |