blob: 715d8f60e41d89a8a4323cbbf5c9e8288dddce9f (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#pragma once
#include "ifetchercallback.h"
#include "ihandle.h"
#include <vespa/config/common/timingvalues.h>
#include <vespa/vespalib/util/runnable.h>
#include <vector>
namespace config {
class IConfigContext;
class ConfigSubscriber;
/**
* A config poller runs a polling sequence on a set of configs that it has
* subscribed to.
*/
class ConfigPoller : public vespalib::Runnable {
public:
ConfigPoller(std::shared_ptr<IConfigContext> context);
~ConfigPoller() override;
void run() override;
template <typename ConfigType>
void subscribe(const std::string & configId, IFetcherCallback<ConfigType> * callback, vespalib::duration subscribeTimeout = DEFAULT_SUBSCRIBE_TIMEOUT);
void poll();
void close();
int64_t getGeneration() const { return _generation; }
private:
int64_t _generation;
std::unique_ptr<ConfigSubscriber> _subscriber;
std::vector<IHandle::UP> _handleList;
std::vector<ICallback *> _callbackList;
};
} // namespace config
|
