Spooled_message

#

module Id : Core.Std.Identifiable

#

module Status : sig

#

type t = [

| `Waiting

| `Sending

| `Frozen

| `Delivered

]

#

val bin_t : t Core.Std.Bin_prot.Type_class.t

#

val bin_read_t : t Core.Std.Bin_prot.Read.reader

#

val __bin_read_t__ : (int -> t) Core.Std.Bin_prot.Read.reader

#

val bin_reader_t : t Core.Std.Bin_prot.Type_class.reader

#

val bin_size_t : t Core.Std.Bin_prot.Size.sizer

#

val bin_write_t : t Core.Std.Bin_prot.Write.writer

#

val bin_writer_t : t Core.Std.Bin_prot.Type_class.writer

#

val t_of_sexp : Sexplib.Sexp.t -> t

#

val __t_of_sexp__ : Sexplib.Sexp.t -> t

#

val sexp_of_t : t -> Sexplib.Sexp.t

end

#

type t

#

val spool_date : t -> Core.Std.Time.t

#

val last_relay_attempt : t -> (Core.Std.Time.t * Core.Std.Error.t) option

#

val parent_id : t -> Types.Envelope.Id.t

#

val id : t -> Id.t

#

val time_on_spool : t -> Core.Std.Time.Span.t

#

val status : t -> Status.t

#

val next_hop_choices : t -> Core.Std.Host_and_port.t list

#

val size_of_file : t -> Core.Std.Byte_units.t Core.Std.Or_error.t Async.Std.Deferred.t

#

val create : Spool_directory.t -> Types.Envelope_with_next_hop.t -> original_msg:Types.Envelope.t -> t Core.Std.Or_error.t Async.Std.Deferred.t

#

val load : string -> t Core.Std.Or_error.t Async.Std.Deferred.t

#

val load_with_envelope : string -> (t * Types.Envelope.t) Core.Std.Or_error.t Async.Std.Deferred.t

#

val send : t -> [

| `Done

| `Retry_at of Core.Std.Time.t

| `Give_up

] Core.Std.Or_error.t Async.Std.Deferred.t

#

val next_action : t -> [

| `Send_at of Core.Std.Time.t

| `Send_now