diff options
| author | Adelyn Breelove <[email protected]> | 2019-01-29 13:27:18 -0700 |
|---|---|---|
| committer | Adelyn Breelove <[email protected]> | 2019-01-29 13:27:18 -0700 |
| commit | 193cd616263306c5ac21dc8b93dfd91a335a0c8b (patch) | |
| tree | 0d6d14661f2ae869d8dc87babf2a01d99b73f003 /lib/sharder.mli | |
| parent | Add client options (diff) | |
| download | disml-193cd616263306c5ac21dc8b93dfd91a335a0c8b.tar.xz disml-193cd616263306c5ac21dc8b93dfd91a335a0c8b.zip | |
Compression!!!
Diffstat (limited to 'lib/sharder.mli')
| -rw-r--r-- | lib/sharder.mli | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/lib/sharder.mli b/lib/sharder.mli index 92c4178..5017a86 100644 --- a/lib/sharder.mli +++ b/lib/sharder.mli @@ -20,6 +20,7 @@ module Shard : sig (** Representation of the state of a shard. *)
type shard = {
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. *)
seq: int; (** Current sequence number *)
session: string option; (** Session id, if one exists. *)
pipe: Frame.t Pipe.Reader.t * Frame.t Pipe.Writer.t; (** Raw frame IO pipe used for websocket communications. *)
|