From 5a1aae149fafa2848c2cd89a3c75992653380201 Mon Sep 17 00:00:00 2001 From: Mishio595 Date: Mon, 29 Oct 2018 06:25:22 -0600 Subject: Moving to LWT branch --- lib/client/sharder/shard_manager.ml | 31 ------------------------------- 1 file changed, 31 deletions(-) delete mode 100644 lib/client/sharder/shard_manager.ml (limited to 'lib/client/sharder/shard_manager.ml') 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 -- cgit v1.2.3