package async_smtp

  1. Overview
  2. Docs
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module Private.Message_spoolSource

Sourcetype t
Sourcetype spool = t
Sourceval load : string -> t Async.Deferred.Or_error.t
Sourceval create : string -> t Async.Deferred.Or_error.t
Sourcemodule Entry : sig ... end
Sourceval uncheckout_all_entries : t -> ([ `Recovered of string list ] * [ `Errors of Core.Error.t option ]) Async.Deferred.t

Move all checked out entries back to their original queues. This command is useful to run on startup to recover from an unclean shutdown. Returns the list of entries that were recovered along with any errors that occurred.

Sourceval ls : t -> Async_smtp__.Message.Queue.t list -> Entry.t list Core.Or_error.t Async.Deferred.t
Sourceval 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 * Async_smtp_types.Smtp_envelope.Routed.t) list Core.Or_error.t Async.Deferred.t

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

Sourceval send : Async_smtp__.Message.t -> log:Async.Log.t -> client_cache:Async_smtp__.Client_cache.t -> [ `Delivered | `Failed of Core.Error.t ] Core.Or_error.t Async.Deferred.t

send message ~log ~client_cache attempts delivery of message using the supplied client_cache for connections.

The outer Error.t in the result is used for unexpected errors. `Delivered | `Failed of Error.t describes the delivery attempt.

Sourceval freeze : Async_smtp__.Message.t -> log:Async.Log.t -> unit Core.Or_error.t Async.Deferred.t
Sourceval 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.

Sourceval remove : Async_smtp__.Message.t -> log:Async.Log.t -> unit Core.Or_error.t Async.Deferred.t
Sourcemodule On_disk_monitor : sig ... end
OCaml

Innovation. Community. Security.