Archivist b5d9f1d93e | 6 년 전 | |
---|---|---|
spec | 6 년 전 | |
src | 6 년 전 | |
.editorconfig | 6 년 전 | |
.gitignore | 6 년 전 | |
.travis.yml | 6 년 전 | |
LICENSE | 6 년 전 | |
README.md | 6 년 전 | |
shard.yml | 6 년 전 |
Add this to your application's shard.yml
:
dependencies:
crystal-scatter:
git: https://git.nekoit.xyz/Archivist/crystal-scatter
version: ~> 0.1.0-rc1
require "crystal-scatter"
Create a MetaRing and add services to it, using the weights as a mark of the load the service can handle (example: number of threads each CPU of the servers can handle).
client_ip = "185.124.235.1"
ring = Crystal::Scatter::MetaRing.new(3)
ring.add [
Crystal::Scatter::Daemon (8 , [0,0,0,0,0,0], "https://api01.myservice.com"),
Crystal::Scatter::Daemon (16, [0,0,0,0,1,0], "https://api02.myservice.com"),
Crystal::Scatter::Daemon (12, [1,0,0,0,0,0], "https://api03.myservice.com"),
Crystal::Scatter::Daemon (12, [1,0,0,0,1,0], "https://api04.myservice.com"),
Crystal::Scatter::Daemon (12, [2,0,0,0,0,0], "https://api05.myservice.com")
]
ring.get_slices_for(client_ip)
# => [
# "https://api01.myservice.com",
# "https://api03.myservice.com",
# "https://api05.myservice.com"
# ]
The output will provide you information to contact the service in a balanced way.
git checkout -b my-new-feature
)git commit -am 'Add some feature'
)git push origin my-new-feature
)