aboutsummaryrefslogtreecommitdiff
path: root/lib/sharder.mli
diff options
context:
space:
mode:
authorAdelyn Breelove <[email protected]>2019-02-04 14:43:17 -0700
committerAdelyn Breelove <[email protected]>2019-02-04 14:43:17 -0700
commitca3c00d8d16f36bc959f5e1ca628aeffc4326492 (patch)
tree628a30c88b84274ac28572f5e85ed78d428471a5 /lib/sharder.mli
parentOof, put CI script change in wrong job (diff)
downloaddisml-ca3c00d8d16f36bc959f5e1ca628aeffc4326492.tar.xz
disml-ca3c00d8d16f36bc959f5e1ca628aeffc4326492.zip
Move large_threshold to shard storage, as it isn't needed elsewhere
Diffstat (limited to 'lib/sharder.mli')
-rw-r--r--lib/sharder.mli3
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/sharder.mli b/lib/sharder.mli
index 53ab280..e00ad14 100644
--- a/lib/sharder.mli
+++ b/lib/sharder.mli
@@ -13,6 +13,7 @@ type t
val start :
?count:int ->
?compress:bool ->
+ ?large_threshold:int ->
unit ->
t Deferred.t
@@ -24,6 +25,7 @@ module Shard : sig
id: int * int; (** A tuple as expected by Discord. First element is the current shard index, second element is the total shard count. *)
hb_interval: Time.Span.t Ivar.t; (** Time span between heartbeats, wrapped in an Ivar. *)
hb_stopper: unit Ivar.t; (** Stops the heartbeat sequencer when filled. *)
+ large_threshold: int; (** Minimum number of members needed for a guild to be considered large. *)
pipe: Frame.t Pipe.Reader.t * Frame.t Pipe.Writer.t; (** Raw frame IO pipe used for websocket communications. *)
ready: unit Ivar.t; (** A simple Ivar indicating if the shard has received READY. *)
seq: int; (** Current sequence number *)
@@ -61,6 +63,7 @@ module Shard : sig
url:string ->
shards:int * int ->
?compress:bool ->
+ ?large_threshold:int ->
unit ->
shard Deferred.t