diff options
| author | Mishio595 <[email protected]> | 2018-11-04 20:20:27 -0700 |
|---|---|---|
| committer | Mishio595 <[email protected]> | 2018-11-04 20:20:27 -0700 |
| commit | 450f62a3d695a58bc66f13f77cba0f267c71dba6 (patch) | |
| tree | fa7d03d987ccaa0d130f79df152ad0c8b2104de9 /lib/client/sharder/shardManager.ml | |
| parent | idek (diff) | |
| download | disml-450f62a3d695a58bc66f13f77cba0f267c71dba6.tar.xz disml-450f62a3d695a58bc66f13f77cba0f267c71dba6.zip | |
Major changes and refactoring
Diffstat (limited to 'lib/client/sharder/shardManager.ml')
| -rw-r--r-- | lib/client/sharder/shardManager.ml | 32 |
1 files changed, 0 insertions, 32 deletions
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 |