Up
Module
Spool
Signature
val
prefix : string
val
status : (unit,
Spool.Status.t
)
Async.Std.Rpc.Rpc.t
val
freeze : (
Spool.Spooled_message_id.t
list, unit
Core.Std.Or_error.t
)
Async.Std.Rpc.Rpc.t
val
send : (
Core.Std.Time.Span.t
list *
Spool.Send_info.t
, unit
Core.Std.Or_error.t
)
Async.Std.Rpc.Rpc.t
val
remove : (
Spool.Spooled_message_id.t
list, unit
Core.Std.Or_error.t
)
Async.Std.Rpc.Rpc.t
val
recover : (
Spool.Recover_info.t
, unit
Core.Std.Or_error.t
)
Async.Std.Rpc.Rpc.t
val
send_now : (
Spool.Spooled_message_id.t
list *
Core.Std.Time.Span.t
list, unit
Core.Std.Or_error.t
)
Async.Std.Rpc.Rpc.t
val
events : (unit,
Spool.Event.t
,
Core_kernel.Error.t
)
Async.Std.Rpc.Pipe_rpc.t
val
set_max_concurrent_send_jobs : (int, unit)
Async.Std.Rpc.Rpc.t