this repo has no description
Write server ids to meta space
+20
-2
+18
-2
lib/servers/manager.ex
+18
-2
lib/servers/manager.ex
···
416
416
end
417
417
418
418
defp build_seed_meta(%Config{initial_shards: shards}, storage_ids) do
419
+
server_pairs = build_server_meta(storage_ids)
420
+
key_pairs = build_key_meta(shards, storage_ids)
421
+
422
+
Enum.sort(server_pairs ++ key_pairs)
423
+
end
424
+
425
+
defp build_server_meta(storage_ids) do
426
+
storage_ids
427
+
|> Enum.map(fn id ->
428
+
{
429
+
servers_prefix() <> Integer.to_string(id),
430
+
"",
431
+
}
432
+
end)
433
+
end
434
+
435
+
defp build_key_meta(shards, storage_ids) do
419
436
teams = Enum.chunk_every(storage_ids, 3, 3, :discard)
420
437
421
438
shards
···
424
441
shard_server_ids = Enum.at(teams, rem(i, length(teams)))
425
442
end_key = Enum.at(shards, i + 1, "\xFF")
426
443
[{
427
-
"\xFF/key_servers/" <> shard_key,
444
+
key_servers_prefix() <> shard_key,
428
445
MetaStore.encode_server_ids(shard_server_ids),
429
446
}] ++ Enum.map(shard_server_ids, fn id ->
430
447
{
···
434
451
end)
435
452
end)
436
453
|> Enum.concat()
437
-
|> Enum.sort()
438
454
end
439
455
end
+2
lib/utils.ex
+2
lib/utils.ex
···
15
15
defmacro all_keys_prefix, do: ""
16
16
defmacro all_keys_end, do: meta_end()
17
17
18
+
defmacro servers_prefix, do: "\xFF/servers/"
19
+
defmacro servers_end, do: "\xFF/servers0"
18
20
defmacro key_servers_prefix, do: "\xFF/key_servers/"
19
21
defmacro key_servers_end, do: "\xFF/key_servers0"
20
22
defmacro server_keys_prefix, do: "\xFF/sk/"