-
Notifications
You must be signed in to change notification settings - Fork 453
/
types.go
218 lines (165 loc) · 6.75 KB
/
types.go
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
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
// Copyright (c) 2016 Uber Technologies, Inc.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
package topology
import (
"time"
"github.com/m3db/m3/src/dbnode/sharding"
"github.com/m3db/m3cluster/client"
"github.com/m3db/m3cluster/services"
"github.com/m3db/m3x/ident"
"github.com/m3db/m3x/instrument"
)
// Host is a container of a host in a topology
type Host interface {
// ID is the identifier of the host
ID() string
// Address returns the address of the host
Address() string
// String returns a string representation of the host
String() string
}
// HostShardSet is a container for a host and corresponding shard set
type HostShardSet interface {
// Host returns the host
Host() Host
// ShardSet returns the shard set owned by the host
ShardSet() sharding.ShardSet
}
// Initializer can init new instances of Topology
type Initializer interface {
// Init will return a new topology
Init() (Topology, error)
}
// Topology is a container of a topology map and disseminates topology map changes
type Topology interface {
// Get the topology map
Get() Map
// Watch for the topology map
Watch() (MapWatch, error)
// Close will close the topology map
Close()
}
// DynamicTopology is a topology that dynamically changes and as such
// adds functionality for a clustered database to call back and mark
// a shard as available once it completes bootstrapping
type DynamicTopology interface {
Topology
// MarkShardsAvailable marks a shard with the state of initializing as available
MarkShardsAvailable(instanceID string, shardIDs ...uint32) error
}
// MapWatch is a watch on a topology map
type MapWatch interface {
// C is the notification channel for when a value becomes available
C() <-chan struct{}
// Get the current topology map
Get() Map
// Close the watch on the topology map
Close()
}
// Map describes a topology
type Map interface {
// Hosts returns all hosts in the map
Hosts() []Host
// HostShardSets returns all HostShardSets in the map
HostShardSets() []HostShardSet
// LookupHostShardSet returns a HostShardSet for a host in the map
LookupHostShardSet(hostID string) (HostShardSet, bool)
// HostsLen returns the length of all hosts in the map
HostsLen() int
// ShardSet returns the shard set for the topology
ShardSet() sharding.ShardSet
// Route will route a given ID to a shard and a set of hosts
Route(id ident.ID) (uint32, []Host, error)
// RouteForEach will route a given ID to a shard then execute a
// function for each host in the set of routed hosts
RouteForEach(id ident.ID, forEachFn RouteForEachFn) error
// RouteShard will route a given shard to a set of hosts
RouteShard(shard uint32) ([]Host, error)
// RouteShardForEach will route a given shard and execute
// a function for each host in the set of routed hosts
RouteShardForEach(shard uint32, forEachFn RouteForEachFn) error
// Replicas returns the number of replicas in the topology
Replicas() int
// MajorityReplicas returns the number of replicas to establish majority in the topology
MajorityReplicas() int
}
// RouteForEachFn is a function to execute for each routed to host
type RouteForEachFn func(idx int, host Host)
// StaticConfiguration is used for standing up M3DB with a static topology
type StaticConfiguration struct {
Shards int `yaml:"shards"`
Replicas int `yaml:"replicas"`
Hosts []HostShardConfig `yaml:"hosts"`
}
// HostShardConfig stores host information for fanout
type HostShardConfig struct {
HostID string `yaml:"hostID"`
ListenAddress string `yaml:"listenAddress"`
}
// StaticOptions is a set of options for static topology
type StaticOptions interface {
// Validate validates the options
Validate() error
// SetShardSet sets the ShardSet
SetShardSet(value sharding.ShardSet) StaticOptions
// ShardSet returns the ShardSet
ShardSet() sharding.ShardSet
// SetReplicas sets the replicas
SetReplicas(value int) StaticOptions
// Replicas returns the replicas
Replicas() int
// SetHostShardSets sets the hostShardSets
SetHostShardSets(value []HostShardSet) StaticOptions
// HostShardSets returns the hostShardSets
HostShardSets() []HostShardSet
}
// DynamicOptions is a set of options for dynamic topology
type DynamicOptions interface {
// Validate validates the options
Validate() error
// SetConfigServiceClient sets the client of ConfigService
SetConfigServiceClient(c client.Client) DynamicOptions
// ConfigServiceClient returns the client of ConfigService
ConfigServiceClient() client.Client
// SetServiceID sets the ServiceID for service discovery
SetServiceID(s services.ServiceID) DynamicOptions
// ServiceID returns the ServiceID for service discovery
ServiceID() services.ServiceID
// SetServicesOverrideOptions sets the override options for service discovery.
SetServicesOverrideOptions(opts services.OverrideOptions) DynamicOptions
// ServicesOverrideOptions returns the override options for service discovery.
ServicesOverrideOptions() services.OverrideOptions
// SetQueryOptions sets the ConfigService query options
SetQueryOptions(value services.QueryOptions) DynamicOptions
// QueryOptions returns the ConfigService query options
QueryOptions() services.QueryOptions
// SetInstrumentOptions sets the instrumentation options
SetInstrumentOptions(value instrument.Options) DynamicOptions
// InstrumentOptions returns the instrumentation options
InstrumentOptions() instrument.Options
// SetInitTimeout sets the waiting time for dynamic topology to be initialized
SetInitTimeout(value time.Duration) DynamicOptions
// InitTimeout returns the waiting time for dynamic topology to be initialized
InitTimeout() time.Duration
// SetHashGen sets the HashGen function
SetHashGen(h sharding.HashGen) DynamicOptions
// HashGen returns HashGen function
HashGen() sharding.HashGen
}