blob: 51a6998febc7a441e83035e32f77424d265e9bd5 (
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
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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#pragma once
#include <string>
#include <vector>
#include "hopspec.h"
#include "routespec.h"
namespace mbus {
/**
* Along with the {@link RoutingSpec}, {@link RouteSpec} and {@link HopSpec}, this holds the routing specifications for
* all protocols. The only way a client can configure or alter the settings of a message bus instance is through these
* classes.
*
* This class contains the spec for a single routing table, which corresponds to exactly one protocol.
*
* @author Simon Thoresen Hult
* @version $Id$
*/
class RoutingTableSpec {
private:
string _protocol;
std::vector<HopSpec> _hops;
std::vector<RouteSpec> _routes;
public:
/**
* Creates a new routing table specification for a named protocol.
*
* @param protocol The name of the protocol that this belongs to.
*/
explicit RoutingTableSpec(const string &protocol);
RoutingTableSpec(const RoutingTableSpec&);
RoutingTableSpec(RoutingTableSpec&&) noexcept = default;
~RoutingTableSpec();
RoutingTableSpec &operator=(const RoutingTableSpec&);
RoutingTableSpec &operator=(RoutingTableSpec&&) noexcept = default;
/**
* Returns the name of the protocol that this is the routing table for.
*
* @return The protocol name.
*/
[[nodiscard]] const string &getProtocol() const { return _protocol; }
/**
* Returns the number of hops that are contained in this table.
*
* @return The number of hops.
*/
[[nodiscard]] uint32_t getNumHops() const { return _hops.size(); }
/**
* Returns the hop spec at the given index.
*
* @param i The index of the hop to return.
* @return The hop at the given position.
*/
HopSpec &getHop(uint32_t i) { return _hops[i]; }
/**
* Returns a const reference to the hop spec at the given index.
*
* @param i The index of the hop to return.
* @return The hop at the given position.
*/
[[nodiscard]] const HopSpec &getHop(uint32_t i) const { return _hops[i]; }
/**
* Adds the given hop spec to this.
*
* @param hop The hop to add.
* @return This, to allow chaining.
*/
RoutingTableSpec & addHop(HopSpec && hop) &;
RoutingTableSpec && addHop(HopSpec && hop) &&;
/**
* Sets the hop spec at the given index.
*
* @param i The index at which to set the hop.
* @param hop The hop to set.
* @return This, to allow chaining.
*/
RoutingTableSpec &setHop(uint32_t i, HopSpec &&hop);
/**
* Returns the number of route specs contained in this.
*
* @return The number of routes.
*/
[[nodiscard]] uint32_t getNumRoutes() const { return _routes.size(); }
/**
* Returns the route spec at the given index.
*
* @param i The index of the route to return.
* @return The route at the given index.
*/
RouteSpec &getRoute(uint32_t i) { return _routes[i]; }
/**
* Returns a const reference to the route spec at the given index.
*
* @param i The index of the route to return.
* @return The route at the given index.
*/
[[nodiscard]] const RouteSpec &getRoute(uint32_t i) const { return _routes[i]; }
/**
* Adds a route spec to this.
*
* @param route The route to add.
* @return This, to allow chaining.
*/
RoutingTableSpec && addRoute(RouteSpec &&route) &&;
RoutingTableSpec & addRoute(RouteSpec &&route) &;
/**
* Sets the route spec at the given index.
*
* @param i The index at which to set the route.
* @param route The route to set.
* @return This, to allow chaining.
*/
RoutingTableSpec &setRoute(uint32_t i, RouteSpec && route) { _routes[i] = std::move(route); return *this; }
/**
* Appends the content of this to the given config string.
*
* @param cfg The config to add to.
* @param prefix The prefix to use for each add.
*/
void toConfig(string &cfg, const string &prefix) const;
/**
* Returns a string representation of this.
*
* @return The string.
*/
[[nodiscard]] string toString() const;
/**
* Implements the equality operator.
*
* @param rhs The object to compare to.
* @return True if this equals the other.
*/
bool operator==(const RoutingTableSpec &rhs) const;
/**
* Implements the inequality operator.
*
* @param rhs The object to compare to.
* @return True if this does not equals the other.
*/
bool operator!=(const RoutingTableSpec &rhs) const { return !(*this == rhs); }
};
} // namespace mbus
|
