Module Ketrew_engine (.ml)

module Ketrew_engine: sig .. end

The engine of the actual Workflow Engine.

type t

The contents of the application engine.

val with_engine : configuration:Ketrew_configuration.engine ->
       (engine:t ->
        (unit,
         [> `Database of Trakeva.Error.t
          | `Database_unavailable of Ketrew_target.id
          | `Dyn_plugin of [> `Dynlink_error of Dynlink.error | `Findlib of exn ]
          | `Failure of string ]
         as 'merge_error)
        Ketrew_unix_io.Deferred_result.t) ->
       (unit, 'merge_error) Ketrew_unix_io.Deferred_result.t

Create a engine.t, run the function passed as argument, and properly dispose of it.

val load : configuration:Ketrew_configuration.engine ->
       (t,
        [> `Database of Trakeva.Error.t
         | `Dyn_plugin of [> `Dynlink_error of Dynlink.error | `Findlib of exn ]
         | `Failure of string ])
       Ketrew_unix_io.Deferred_result.t

val unload : t ->
       (unit,
        [> `Database of Trakeva.Error.t | `Database_unavailable of Ketrew_target.id ])
       Ketrew_unix_io.Deferred_result.t

val configuration : t -> Ketrew_configuration.engine

Retrieve the configuration.

val add_targets : t ->
       Ketrew_target.t list ->
       (unit,
        [> `Database of Trakeva.Error.t
         | `Database_unavailable of Ketrew_target.id
         | `Missing_data of Ketrew_target.id
         | `Target of [> `Deserilization of string ] ])
       Ketrew_unix_io.Deferred_result.t

Add a list of targets to the engine.

val get_target : t ->
       Ketrew_pervasives.Unique_id.t ->
       (Ketrew_target.t,
        [> `Database of Trakeva.Error.t
         | `Missing_data of string
         | `Target of [> `Deserilization of string ] ])
       Ketrew_unix_io.Deferred_result.t

Get a target from its id.

val all_targets : t ->
       (Ketrew_target.t list,
        [> `Database of Trakeva.Error.t
         | `IO of
             [> `Read_file_exn of string * exn | `Write_file_exn of string * exn ]
         | `Missing_data of Ketrew_target.id
         | `System of [> `File_info of string ] * [> `Exn of exn ]
         | `Target of [> `Deserilization of string ] ])
       Ketrew_unix_io.Deferred_result.t

Get the list of targets currently handled.

val get_list_of_target_ids : t ->
       [ `All
       | `Created_after of Ketrew_pervasives.Time.t
       | `Not_finished_before of Ketrew_pervasives.Time.t ] ->
       (Ketrew_target.id list,
        [> `Database of Trakeva.Error.t
         | `Missing_data of string
         | `Target of [> `Deserilization of string ] ])
       Ketrew_unix_io.Deferred_result.t

Get only the Ids of the targets for a given “query”:

`All for all the targets visible to the engine.
`Not_finished_before _ for the targets that were not finished at a given date.

module Run_automaton: sig .. end

val get_status : t ->
       Ketrew_target.id ->
       (Ketrew_target.State.t,
        [> `Database of Trakeva.Error.t
         | `IO of
             [> `Read_file_exn of string * exn | `Write_file_exn of string * exn ]
         | `Missing_data of string
         | `System of [> `File_info of string ] * [> `Exn of exn ]
         | `Target of [> `Deserilization of string ] ])
       Ketrew_unix_io.Deferred_result.t

Get the state description of a given target (by “id”).

val kill : t ->
       id:Ketrew_pervasives.String.t ->
       (unit,
        [> `Database of [> `Act of Trakeva.Action.t | `Load of string ] * string
         | `Database_unavailable of string ])
       Ketrew_unix_io.Deferred_result.t

Kill a target

val restart_target : t ->
       Ketrew_target.id ->
       (Ketrew_target.id,
        [> `Database of Trakeva.Error.t
         | `Database_unavailable of Ketrew_target.id
         | `Missing_data of Ketrew_target.id
         | `Target of [> `Deserilization of string ] ])
       Ketrew_unix_io.Deferred_result.t

Make new activated targets out of a given target and its “transitive reverse dependencies”

module Measure: sig .. end

module Measurements: sig .. end