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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#pragma once
#include "frtconfigrequest.h"
#include "protocol.h"
#include <vespa/vespalib/data/slime/slime.h>
#include <vespa/vespalib/util/time.h>
class FRT_Values;
class FRT_RPCRequest;
namespace config {
class ConfigKey;
class Connection;
class Trace;
struct VespaVersion;
class SlimeConfigRequest : public FRTConfigRequest {
public:
using duration = vespalib::duration;
SlimeConfigRequest(Connection * connection,
const ConfigKey & key,
const vespalib::string & configXxhash64,
int64_t currentGeneration,
const vespalib::string & hostName,
duration serverTimeout,
const Trace & trace,
const VespaVersion & vespaVersion,
int64_t protocolVersion,
const CompressionType & compressionType,
const vespalib::string & methodName);
~SlimeConfigRequest();
bool verifyState(const ConfigState & state) const override;
virtual std::unique_ptr<ConfigResponse> createResponse(FRT_RPCRequest * request) const override = 0;
private:
void populateSlimeRequest(const ConfigKey & key,
const vespalib::string & configXxhash64,
int64_t currentGeneration,
const vespalib::string & hostName,
duration serverTimeout,
const Trace & trace,
const VespaVersion & vespaVersion,
int64_t protocolVersion,
const CompressionType & compressionType);
static vespalib::string createJsonFromSlime(const vespalib::Slime & data);
vespalib::Slime _data;
};
}
|
