package async_smtp

  1. Overview
  2. Docs
package async_smtp
Legend:
Library
Module
Module type
Parameter
Class
Class type
type t
type spool = t
val load : string -> t Async.Deferred.Or_error.t
val create : string -> t Async.Deferred.Or_error.t
module Entry : sig ... end
val ls : t -> Async_smtp__.Message.Queue.t list -> Entry.t list Core.Or_error.t Async.Deferred.t
val size_of_file : Async_smtp__.Message.t -> Core.Byte_units.t Core.Or_error.t Async.Deferred.t
val enqueue : t -> log:Async.Log.t -> initial_status: [ `Send_now | `Send_at of Core.Time.t | `Sending | `Frozen | `Removed | `Quarantined of Async_smtp__.Quarantine_reason.t | `Delivered ] -> Async_smtp_types.Smtp_envelope.Routed.Batch.t -> flows:string list -> original_msg:Async_smtp_types.Smtp_envelope.t -> Async_smtp__.Message.t list Core.Or_error.t Async.Deferred.t

The Deferred becomes determined once the messages have been synced to disk.

val send : Async_smtp__.Message.t -> log:Async.Log.t -> client_cache:Async_smtp__.Client_cache.t -> unit Core.Or_error.t Async.Deferred.t

It is an error to call send on a message that is currently being sent.

val map_email : Async_smtp__.Message.t -> f:(Async_smtp_types.Email.t -> Async_smtp_types.Email.t) -> unit Core.Or_error.t Async.Deferred.t

Map an email that is saved on disk.

val freeze : Async_smtp__.Message.t -> log:Async.Log.t -> unit Core.Or_error.t Async.Deferred.t
val mark_for_send_now : retry_intervals:Async_smtp_types.Smtp_envelope.Retry_interval.t list -> Async_smtp__.Message.t -> log:Async.Log.t -> unit Core.Or_error.t Async.Deferred.t

Change a message's status to `Send_now. retry_intervals are added in front of the existing ones.

val remove : Async_smtp__.Message.t -> log:Async.Log.t -> unit Core.Or_error.t Async.Deferred.t
module On_disk_monitor : sig ... end