acl/lib_acl_cpp/include/acl_cpp/redis/redis_role.hpp at master · acl-dev/acl · GitHub

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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
#pragma once
#include "../acl_cpp_define.hpp"
#include <map>
#include <vector>
#include "../stdlib/string.hpp"
#include "redis_command.hpp"

#if !defined(ACL_CLIENT_ONLY) && !defined(ACL_REDIS_DISABLE)

namespace acl {

class redis_client;
class redis_result;

class ACL_CPP_API redis_role4slave {
public:
	redis_role4slave() : port_(0), off_(0) {}
	~redis_role4slave() {}

	void set_ip(const char* ip) {
		ip_ = ip;
	}
	void set_port(int port) {
		port_ = port;
	}
	void set_status(const char* status) {
		status_ = status;
	}
	void set_offset(long long off) {
		off_ = off;
	}
	const char* get_ip() const {
		return ip_.c_str();
	}
	int get_port() const {
		return port_;
	}
	const char* get_status() const {
		return status_.c_str();
	}
	long long get_offset() const {
		return off_;
	}

private:
	string ip_;
	int port_;
	long long off_;
	string status_;
};

class ACL_CPP_API redis_role4master {
public:
	redis_role4master() : off_(0) {}
	~redis_role4master() {}

	void set_offset(long long off) {
		off_ = off;
	}
	long long get_offset() const {
		return off_;
	}
	void add_slave(const redis_role4slave& slave) {
		slaves_.push_back(slave);
	}
	const std::vector<redis_role4slave>& get_slaves() const {
		return slaves_;
	}

private:
	long long off_;
	std::vector<redis_role4slave> slaves_;
};

class ACL_CPP_API redis_role : virtual public redis_command {
public:
	redis_role();
	redis_role(redis_client* conn);
	virtual ~redis_role() {}

	bool role();
	const redis_role4master& get_role4master() const {
		return role4master_;
	}
	const redis_role4slave& get_role4slave() const {
		return role4slave_;
	}

	const char* get_role_name() const {
		return role_name_.c_str();
	}

private:
	string role_name_;
	std::vector<string> masters_;
	redis_role4master role4master_;
	redis_role4slave role4slave_;

	bool role_sentinel(const redis_result** a, size_t n);
	bool role_master(const redis_result** a, size_t n);
	bool role_slave(const redis_result** a, size_t n);

	bool add_one_slave(const redis_result* a, redis_role4master& out);
};

}

#endif // !defined(ACL_CLIENT_ONLY) && !defined(ACL_REDIS_DISABLE)