Up

module Config

: sig
#
type t = {
# spool_dir
: string;
# tmp_dir
: string option;
# ports
: int list;
# max_concurrent_send_jobs
: int;
# max_concurrent_receive_jobs_per_port
: int;
# rpc_port
: int;
# malformed_emails
: [
| `Reject
| `Wrap
]		;
# max_message_size
: Core.Std.Byte_units.t;
}
#
val max_message_size : t -> Core.Std.Byte_units.t
#
val malformed_emails : t -> [
| `Reject
| `Wrap
]
#
val rpc_port : t -> int
#
val max_concurrent_receive_jobs_per_port : t -> int
#
val max_concurrent_send_jobs : t -> int
#
val ports : t -> int list
#
val tmp_dir : t -> string option
#
val spool_dir : t -> string
#
module Fields : sig
#
val names : string list
#
val max_message_size : (t, Core.Std.Byte_units.t) Fieldslib.Field.t
#
val malformed_emails : (t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t
#
val rpc_port : (t, int) Fieldslib.Field.t
#
val max_concurrent_receive_jobs_per_port : (t, int) Fieldslib.Field.t
#
val max_concurrent_send_jobs : (t, int) Fieldslib.Field.t
#
val ports : (t, int list) Fieldslib.Field.t
#
val tmp_dir : (t, string option) Fieldslib.Field.t
#
val spool_dir : (t, string) Fieldslib.Field.t
#
val fold : init:'acc__ -> spool_dir:('acc__ -> (t, string) Fieldslib.Field.t -> 'acc__) -> tmp_dir:('acc__ -> (t, string option) Fieldslib.Field.t -> 'acc__) -> ports:('acc__ -> (t, int list) Fieldslib.Field.t -> 'acc__) -> max_concurrent_send_jobs:('acc__ -> (t, int) Fieldslib.Field.t -> 'acc__) -> max_concurrent_receive_jobs_per_port:('acc__ -> (t, int) Fieldslib.Field.t -> 'acc__) -> rpc_port:('acc__ -> (t, int) Fieldslib.Field.t -> 'acc__) -> malformed_emails:('acc__ -> (t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t -> 'acc__) -> max_message_size:('acc__ -> (t, Core.Std.Byte_units.t) Fieldslib.Field.t -> 'acc__) -> 'acc__
#
val make_creator : spool_dir:((t, string) Fieldslib.Field.t -> 'compile_acc__ -> ('input__ -> string) * 'compile_acc__) -> tmp_dir:((t, string option) Fieldslib.Field.t -> 'compile_acc__ -> ('input__ -> string option) * 'compile_acc__) -> ports:((t, int list) Fieldslib.Field.t -> 'compile_acc__ -> ('input__ -> int list) * 'compile_acc__) -> max_concurrent_send_jobs:((t, int) Fieldslib.Field.t -> 'compile_acc__ -> ('input__ -> int) * 'compile_acc__) -> max_concurrent_receive_jobs_per_port:((t, int) Fieldslib.Field.t -> 'compile_acc__ -> ('input__ -> int) * 'compile_acc__) -> rpc_port:((t, int) Fieldslib.Field.t -> 'compile_acc__ -> ('input__ -> int) * 'compile_acc__) -> malformed_emails:((t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t -> 'compile_acc__ -> ('input__ -> [
| `Reject
| `Wrap
]) * 'compile_acc__) -> max_message_size:((t, Core.Std.Byte_units.t) Fieldslib.Field.t -> 'compile_acc__ -> ('input__ -> Core.Std.Byte_units.t) * 'compile_acc__) -> 'compile_acc__ -> ('input__ -> t) * 'compile_acc__
#
val create : spool_dir:string -> tmp_dir:string option -> ports:int list -> max_concurrent_send_jobs:int -> max_concurrent_receive_jobs_per_port:int -> rpc_port:int -> malformed_emails:[
| `Reject
| `Wrap
] -> max_message_size:Core.Std.Byte_units.t -> t
#
val map : spool_dir:((t, string) Fieldslib.Field.t -> string) -> tmp_dir:((t, string option) Fieldslib.Field.t -> string option) -> ports:((t, int list) Fieldslib.Field.t -> int list) -> max_concurrent_send_jobs:((t, int) Fieldslib.Field.t -> int) -> max_concurrent_receive_jobs_per_port:((t, int) Fieldslib.Field.t -> int) -> rpc_port:((t, int) Fieldslib.Field.t -> int) -> malformed_emails:((t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t -> [
| `Reject
| `Wrap
]) -> max_message_size:((t, Core.Std.Byte_units.t) Fieldslib.Field.t -> Core.Std.Byte_units.t) -> t
#
val iter : spool_dir:((t, string) Fieldslib.Field.t -> unit) -> tmp_dir:((t, string option) Fieldslib.Field.t -> unit) -> ports:((t, int list) Fieldslib.Field.t -> unit) -> max_concurrent_send_jobs:((t, int) Fieldslib.Field.t -> unit) -> max_concurrent_receive_jobs_per_port:((t, int) Fieldslib.Field.t -> unit) -> rpc_port:((t, int) Fieldslib.Field.t -> unit) -> malformed_emails:((t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t -> unit) -> max_message_size:((t, Core.Std.Byte_units.t) Fieldslib.Field.t -> unit) -> unit
#
val for_all : spool_dir:((t, string) Fieldslib.Field.t -> bool) -> tmp_dir:((t, string option) Fieldslib.Field.t -> bool) -> ports:((t, int list) Fieldslib.Field.t -> bool) -> max_concurrent_send_jobs:((t, int) Fieldslib.Field.t -> bool) -> max_concurrent_receive_jobs_per_port:((t, int) Fieldslib.Field.t -> bool) -> rpc_port:((t, int) Fieldslib.Field.t -> bool) -> malformed_emails:((t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t -> bool) -> max_message_size:((t, Core.Std.Byte_units.t) Fieldslib.Field.t -> bool) -> bool
#
val exists : spool_dir:((t, string) Fieldslib.Field.t -> bool) -> tmp_dir:((t, string option) Fieldslib.Field.t -> bool) -> ports:((t, int list) Fieldslib.Field.t -> bool) -> max_concurrent_send_jobs:((t, int) Fieldslib.Field.t -> bool) -> max_concurrent_receive_jobs_per_port:((t, int) Fieldslib.Field.t -> bool) -> rpc_port:((t, int) Fieldslib.Field.t -> bool) -> malformed_emails:((t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t -> bool) -> max_message_size:((t, Core.Std.Byte_units.t) Fieldslib.Field.t -> bool) -> bool
#
val to_list : spool_dir:((t, string) Fieldslib.Field.t -> 'elem__) -> tmp_dir:((t, string option) Fieldslib.Field.t -> 'elem__) -> ports:((t, int list) Fieldslib.Field.t -> 'elem__) -> max_concurrent_send_jobs:((t, int) Fieldslib.Field.t -> 'elem__) -> max_concurrent_receive_jobs_per_port:((t, int) Fieldslib.Field.t -> 'elem__) -> rpc_port:((t, int) Fieldslib.Field.t -> 'elem__) -> malformed_emails:((t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t -> 'elem__) -> max_message_size:((t, Core.Std.Byte_units.t) Fieldslib.Field.t -> 'elem__) -> 'elem__ list
#
val map_poly : ([<
| `Read
| `Set_and_create
], t, 'x0) Fieldslib.Field.user -> 'x0 list
#
module Direct : sig
#
val iter : t -> spool_dir:((t, string) Fieldslib.Field.t -> t -> string -> unit) -> tmp_dir:((t, string option) Fieldslib.Field.t -> t -> string option -> unit) -> ports:((t, int list) Fieldslib.Field.t -> t -> int list -> unit) -> max_concurrent_send_jobs:((t, int) Fieldslib.Field.t -> t -> int -> unit) -> max_concurrent_receive_jobs_per_port:((t, int) Fieldslib.Field.t -> t -> int -> unit) -> rpc_port:((t, int) Fieldslib.Field.t -> t -> int -> unit) -> malformed_emails:((t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t -> t -> [
| `Reject
| `Wrap
] -> unit) -> max_message_size:((t, Core.Std.Byte_units.t) Fieldslib.Field.t -> t -> Core.Std.Byte_units.t -> unit) -> unit
#
val fold : t -> init:'acc__ -> spool_dir:('acc__ -> (t, string) Fieldslib.Field.t -> t -> string -> 'acc__) -> tmp_dir:('acc__ -> (t, string option) Fieldslib.Field.t -> t -> string option -> 'acc__) -> ports:('acc__ -> (t, int list) Fieldslib.Field.t -> t -> int list -> 'acc__) -> max_concurrent_send_jobs:('acc__ -> (t, int) Fieldslib.Field.t -> t -> int -> 'acc__) -> max_concurrent_receive_jobs_per_port:('acc__ -> (t, int) Fieldslib.Field.t -> t -> int -> 'acc__) -> rpc_port:('acc__ -> (t, int) Fieldslib.Field.t -> t -> int -> 'acc__) -> malformed_emails:('acc__ -> (t, [
| `Reject
| `Wrap
]) Fieldslib.Field.t -> t -> [
| `Reject
| `Wrap
] -> 'acc__) -> max_message_size:('acc__ -> (t, Core.Std.Byte_units.t) Fieldslib.Field.t -> t -> Core.Std.Byte_units.t -> 'acc__) -> 'acc__
end
end
#
val load_exn : string -> t Async.Std.Deferred.t
#
val tmp_dir : t -> string
#
val empty : t
#
val t_of_sexp : Sexplib.Sexp.t -> t
#
val sexp_of_t : t -> Sexplib.Sexp.t
end