diff options
| author | Mishio595 <[email protected]> | 2018-10-29 06:25:22 -0600 |
|---|---|---|
| committer | Mishio595 <[email protected]> | 2018-10-29 06:25:22 -0600 |
| commit | 5a1aae149fafa2848c2cd89a3c75992653380201 (patch) | |
| tree | d6c2567ab3854aa6fb51aa4a2d715cf42f76ff52 /lib/client/sharder/shard_manager.ml | |
| parent | More random stuff with sharding (diff) | |
| download | disml-5a1aae149fafa2848c2cd89a3c75992653380201.tar.xz disml-5a1aae149fafa2848c2cd89a3c75992653380201.zip | |
Moving to LWT branch
Diffstat (limited to 'lib/client/sharder/shard_manager.ml')
| -rw-r--r-- | lib/client/sharder/shard_manager.ml | 31 |
1 files changed, 0 insertions, 31 deletions
diff --git a/lib/client/sharder/shard_manager.ml b/lib/client/sharder/shard_manager.ml deleted file mode 100644 index 68b3d13..0000000 --- a/lib/client/sharder/shard_manager.ml +++ /dev/null @@ -1,31 +0,0 @@ -open Lwt.Infix -open Websocket - -module ShardSet = Set.Make(Shard) - -type t = { - shards: Shard.t ShardSet.t; - gateway_url: Uri.t; - token: string; -} - -let create_shard ?(options=[]) manager = - let id = (ShardSet.cardinal manager.shards) + 1 in - Shard.connect ~options ~uri:manager.gateway_url ~id ~total:(ShardSet.cardinal manager.shards) ~token:manager.token () - >|= fun shard -> - ShardSet.add shard manager.shards - -let update_shard shard manager = - match ShardSet.mem shard manager.shards with - | true -> ShardSet.add shard manager.shards - | false -> manager.shards - -let heartbeat shard manager = - Shard.heartbeat shard - -let identify shard manager = - let total = ShardSet.cardinal manager.shards in - Shard.identify total manager.token shard - -let resume shard manager = - Shard.resume manager.token shard
\ No newline at end of file |