aboutsummaryrefslogtreecommitdiffstats
path: root/storage/src/tests/distributor/distributortestutil.h
diff options
context:
space:
mode:
Diffstat (limited to 'storage/src/tests/distributor/distributortestutil.h')
-rw-r--r--storage/src/tests/distributor/distributortestutil.h11
1 files changed, 8 insertions, 3 deletions
diff --git a/storage/src/tests/distributor/distributortestutil.h b/storage/src/tests/distributor/distributortestutil.h
index 3dc71bcb433..1bdb6e33512 100644
--- a/storage/src/tests/distributor/distributortestutil.h
+++ b/storage/src/tests/distributor/distributortestutil.h
@@ -2,14 +2,14 @@
#pragma once
#include "distributor_message_sender_stub.h"
-#include <tests/common/teststorageapp.h>
-#include <tests/common/testhelper.h>
#include <tests/common/dummystoragelink.h>
+#include <tests/common/testhelper.h>
+#include <tests/common/teststorageapp.h>
#include <vespa/storage/common/hostreporter/hostinfo.h>
#include <vespa/storage/frameworkimpl/component/distributorcomponentregisterimpl.h>
#include <vespa/storage/storageutil/utils.h>
-#include <vespa/storageframework/defaultimplementation/clock/fakeclock.h>
#include <vespa/storageapi/message/state.h>
+#include <vespa/storageframework/defaultimplementation/clock/fakeclock.h>
namespace storage {
@@ -21,6 +21,7 @@ class BucketDBUpdater;
class Distributor;
class DistributorBucketSpace;
class DistributorBucketSpaceRepo;
+class DistributorComponent;
class IdealStateManager;
class ExternalOperationHandler;
class Operation;
@@ -111,6 +112,7 @@ public:
BucketDBUpdater& getBucketDBUpdater();
IdealStateManager& getIdealStateManager();
ExternalOperationHandler& getExternalOperationHandler();
+ storage::distributor::DistributorComponent& distributor_component();
Distributor& getDistributor() {
return *_distributor;
@@ -175,6 +177,9 @@ public:
BucketDatabase::Entry getBucket(const document::BucketId& bId) const;
std::vector<document::BucketSpace> getBucketSpaces() const;
+
+ DistributorMessageSenderStub& sender() noexcept { return _sender; }
+ const DistributorMessageSenderStub& sender() const noexcept { return _sender; }
protected:
vdstestlib::DirConfig _config;
std::unique_ptr<TestDistributorApp> _node;