Monitor defines an error handling policy.
type t = monitorval ignore_errors : tignore_errors filters good events and silently drops error events
warn_on_error on_error same as ignore_errors but calls on_error function when an error has occured
val warn_on_error : (Core_kernel.Std.Error.t -> unit) -> twarn_on_error on_error same as ignore_errors but calls on_error function when an error has occured
val fail_on_error : tfail_on_error will fail with an error Error.raise error
val stop_on_error : tstop_on_error will silently finish a stream in case of error.
val pack_errors : (Core_kernel.Std.Error.t -> event) -> tpack_errors pack will transform any occured error into event using pack function.
val create : (Core_kernel.Std.Error.t -> step) -> tcreate filter creates a user defined monitor from function filter that is applied to a sequence of events or errors, and returns a sequence of events.