From 450f62a3d695a58bc66f13f77cba0f267c71dba6 Mon Sep 17 00:00:00 2001 From: Mishio595 Date: Sun, 4 Nov 2018 20:20:27 -0700 Subject: Major changes and refactoring --- lib/client/sharder/shardManager.ml | 32 -------------------------------- 1 file changed, 32 deletions(-) delete mode 100644 lib/client/sharder/shardManager.ml (limited to 'lib/client/sharder/shardManager.ml') diff --git a/lib/client/sharder/shardManager.ml b/lib/client/sharder/shardManager.ml deleted file mode 100644 index c5919f3..0000000 --- a/lib/client/sharder/shardManager.ml +++ /dev/null @@ -1,32 +0,0 @@ -open Lwt.Infix - -module ShardSet = Set.Make(struct - type t = Shard.t - let compare (s1:t) (s2:t) = Pervasives.compare s1.id s2.id -end) - -type t = { - shards: ShardSet.t; - gateway_url: Uri.t; - token: string; -} - -let create_shard ?(options=[]) manager = - let id = (ShardSet.cardinal manager.shards) + 1 in - Shard.connect ~_options:options ~uri:manager.gateway_url ~id ~total:(ShardSet.cardinal manager.shards) ~token:manager.token () - >|= fun shard -> - ShardSet.add shard manager.shards - -let update_shard manager shard = - match ShardSet.mem shard manager.shards with - | true -> ShardSet.add shard manager.shards - | false -> manager.shards - -let heartbeat _manager shard = - Shard.heartbeat shard - -let identify _manager shard = - Shard.identify shard - -let resume _manager shard = - Shard.resume shard \ No newline at end of file -- cgit v1.2.3