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
53
54
55
56
57
58
59
60
61
62
63
64
|
/**
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with this
* work for additional information regarding copyright ownership. The ASF
* licenses this file to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
* License for the specific language governing permissions and limitations under
* the License.
*/
#ifndef ZOOKEEPER_QUORUM_SERVER_H
#define ZOOKEEPER_QUORUM_SERVER_H
#include <stdint.h>
#include <string>
#include <vector>
#include <utility>
class ZooKeeperQuorumServer {
public:
~ZooKeeperQuorumServer();
typedef std::vector<std::pair<std::string, std::string> > tConfigPairs;
static std::vector<ZooKeeperQuorumServer*> getCluster(uint32_t numServers);
static std::vector<ZooKeeperQuorumServer*> getCluster(uint32_t numServers,
tConfigPairs configs, /* Additional config options as a list of key/value pairs. */
std::string env /* Additional environment variables when starting zkServer.sh. */);
std::string getHostPort();
uint32_t getClientPort();
void start();
void stop();
bool isLeader();
bool isFollower();
std::string getServerString();
private:
ZooKeeperQuorumServer();
ZooKeeperQuorumServer(uint32_t id, uint32_t numServers, std::string config = "",
std::string env = "");
ZooKeeperQuorumServer(const ZooKeeperQuorumServer& that);
const ZooKeeperQuorumServer& operator=(const ZooKeeperQuorumServer& that);
void createConfigFile(std::string config = "");
std::string getConfigFileName();
void createDataDirectory();
std::string getDataDirectory();
static std::string getServerString(uint32_t id);
std::string getMode();
static const uint32_t SERVER_PORT_BASE = 2000;
static const uint32_t ELECTION_PORT_BASE = 3000;
static const uint32_t CLIENT_PORT_BASE = 4000;
uint32_t id_;
std::string env_;
uint32_t numServers_;
std::string root_;
};
#endif // ZOOKEEPER_QUORUM_SERVER_H
|
