package current

You can search for identifiers within the package.

in-package search v0.2.0

current
- CHANGES
- README
- Library current
  - Current
    
    Level
    
    Config
    
    actions
    
    Metadata
    
    Primitive
    
    Syntax
    
    Monitor
    
    Analysis
    
    Var
    
    String
    
    Unit
    
    Switch
    
    Pool
    
    Job
    
    Map
    
    Engine
    
    Step
    
    Process
    
    Db
    
    Log_matcher
- Library current.cache
  - Current_cache
    
    S
    
    WITH_DIGEST
    
    WITH_MARSHAL
    
    OPERATION
    
    Key
    
    BUILDER
    
    Key
    
    Value
    
    PUBLISHER
    
    Key
    
    Value
    
    Outcome
    
    GENERIC
    
    Key
    
    Value
    
    Outcome
    
    Schedule
    
    Make
    
    Output
    
    Generic
    
    Db
- Library current.fs
  - Current_fs
- Library current.term
  - Current_term
    
    S
    
    T
    
    ORDERED
    
    ANALYSIS
    
    TERM
    
    Syntax
    
    EXECUTOR
    
    Output
    
    Blockable
    
    Make
    
    Syntax
    
    Analysis
    
    Executor
- Sources
  - current
    
    config.ml
    
    current.ml
    
    current__.ml
    
    db.ml
    
    disk_store.ml
    
    job.ml
    
    level.ml
    
    log.ml
    
    log_matcher.ml
    
    pool.ml
    
    process.ml
    
    switch.ml
  - current.cache
    
    current_cache.ml
    
    current_cache__.ml
    
    db.ml
    
    log.ml
    
    s.ml
  - current.fs
    
    current_fs.ml
  - current.term
    
    analysis.ml
    
    current_term.ml
    
    current_term__.ml
    
    dot.ml
    
    dyn.ml
    
    id.ml
    
    node.ml
    
    output.ml
    
    s.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module `Current`Source

Sourcetype 'a or_error = ('a, [ `Msg of string ]) result

Sourcemodule Level : sig ... end

Each operation has a level, giving an estimate of the cost or risk of the operation. When testing a pipeline, it can be useful to set a maximum level, or to require confirmation for more risky operations.

Sourcemodule Config : sig ... end

Sourcetype job_id = string

Sourceclass type actions = object ... end

Sourcemodule Metadata : sig ... end

Metadata associated with primitive terms.

Sourcemodule Primitive : sig ... end

An OCurrent pipeline is made up of primitive operations. A primitive is roughly the content of a single box in the diagram.

include Current_term.S.TERM
  with type metadata := Metadata.t
   and type 'a primitive := 'a Primitive.t

Sourcetype 'a t

An 'a t is a term that produces a value of type 'a.

Sourcetype description

Information about operations hidden behind a bind.

Sourceval active : Current_term.Output.active -> 'a t

active x is a term indicating that the result is not determined yet.

Sourceval return : ?label:string -> 'a -> 'a t

return x is a term that immediately succeeds with x.

parameter label
Label the constant in the diagrams.

Sourceval fail : string -> 'a t

fail m is a term that immediately fails with message m.

Source

val state : 
  ?hidden:bool ->
  'a t ->
  ('a, [ `Active of Current_term.Output.active | `Msg of string ]) result t

state t always immediately returns a successful result giving the current state of t.

parameter hidden
If true, don't show a separate node for this on the diagrams.

Sourceval catch : ?hidden:bool -> 'a t -> 'a Current_term.S.or_error t

catch t successfully returns Ok x if t evaluates successfully to x, or successfully returns Error e if t fails with error e. If t is active then catch t will be active too.

parameter hidden
If true, don't show a separate node for this on the diagrams.

Sourceval ignore_value : 'a t -> unit t

ignore_value x is map ignore x.

Sourceval of_output : 'a Current_term.Output.t -> 'a t

of_output x is a returned, failed or active term.

Sequencing terms

Applicative operations

Sourceval map : ?eq:('b -> 'b -> bool) -> ('a -> 'b) -> 'a t -> 'b t

map f x is a term that runs x and then transforms the result using f.

The optional equality function ?eq defaults to physical equality. When f produces an updated result following a change in x, the equality function will be called with the previous and the new value eq b_old b_new: returning true indicates that the change can be ignored and should not propagate further down the pipeline.

Sourceval map_error : (string -> string) -> 'a t -> 'a t

map_error f x is a term that runs x and then transforms the error string (if any) using f.

Sourceval pair : 'a t -> 'b t -> ('a * 'b) t

pair a b is the pair containing the results of evaluating a and b (in parallel).

Source

val list_map : 
  (module Current_term.S.ORDERED with type t = 'a) ->
  ?collapse_key:string ->
  ?label:string ->
  ('a t -> 'b t) ->
  'a list t ->
  'b list t

list_map (module T) f xs adds f to the end of each input term and collects all the results into a single list.

parameter T
Used to display labels for each item, and to avoid recreating pipelines unnecessarily.

parameter collapse_key
If given, each element is wrapped with collapse.

parameter label
Label the list in the diagrams.

Source

val list_iter : 
  (module Current_term.S.ORDERED with type t = 'a) ->
  ?collapse_key:string ->
  ?label:string ->
  ('a t -> unit t) ->
  'a list t ->
  unit t

Like list_map but for the simpler case when the result is unit.

parameter label
Label the list in the diagrams.

Sourceval list_seq : 'a t list -> 'a list t

list_seq x evaluates to a list containing the results of evaluating each element in x, once all elements of x have successfully completed.

Sourceval option_map : ?label:string -> ('a t -> 'b t) -> 'a option t -> 'b option t

option_map f x is a term that evaluates to Some (f y) if x evaluates to Some y, or to None otherwise.

parameter label
Label the optional in the diagrams.

Sourceval option_iter : ?label:string -> ('a t -> unit t) -> 'a option t -> unit t

Like option_map but for the simpler case when the result is unit.

parameter label
Label the list in the diagrams.

Sourceval option_seq : 'a t option -> 'a option t

option_seq None is Current.return None and option_seq (Some x) is Current.map some x. This is useful for handling optional arguments that are currents.

Sourceval all : unit t list -> unit t

all xs is a term that succeeds if every term in xs succeeds.

Sourceval all_labelled : (string * unit t) list -> unit t

all xs is a term that succeeds if every term in xs succeeds. The labels are used if some terms fail, to indicate which ones are failing.

Sourceval gate : on:unit t -> 'a t -> 'a t

gate ~on:ctrl x is the same as x, once ctrl succeeds.

Note: gate does not delay x; it only delays whatever you put after the gate. e.g.

let binary = build src in
let tests_ok = test binary in
binary |> gate ~on:tests_ok |> deploy

Sourceval cutoff : eq:('a -> 'a -> bool) -> 'a t -> 'a t

cutoff ~eq x is the same as x, but changes to x that are equal according to eq do not propagate further down. It should be used when values of type 'a have a precise definition of equality to avoid triggering redundant work.

Diagram control

Sourceval collapse : key:string -> value:string -> input:_ t -> 'a t -> 'a t

collapse ~key ~value ~input t is a term that behaves just like t, but when shown in a diagram it can be expanded or collapsed. When collapsed, it is shown as "input -> +" and the user can expand it to show t instead. The idea is that input is a dependency of t and the "+" represents everything in t after that. key and value are used as the parameters (e.g. in a URL) to control whether this is expanded or not. For example collapse ~key:"repo" ~value:"mirage/mirage-www" ~input:repo (process repo) Note: list_map ~collapse_key provides an easy way to use this.

Source

val collapse_list : 
  key:string ->
  value:string ->
  input:_ t ->
  'a t list ->
  'a t list * unit t

collapse_list ~key ~value ~input t is a term that behaves just like t list, but when shown in a diagram it can be expanded or collapsed.

Sourceval with_context : _ t -> (unit -> 'a t) -> 'a t

with_context ctx f is the term f (), where f is evaluated in context ctx. This means that ctx will be treated as an input to all terms created by f in the diagrams.

Monadic operations

N.B. these operations create terms that cannot be statically analysed until after they are executed.

Source

val bind : 
  ?info:description ->
  ?eq:('b -> 'b -> bool) ->
  ('a -> 'b t) ->
  'a t ->
  'b t

bind f x is a term that first runs x to get y and then behaves as the term f y. Static analysis cannot look inside the f function until x is ready, so using bind makes static analysis less useful. You can use the info argument to provide some information here.

Primitives

Sourceval primitive : info:description -> ('a -> 'b Primitive.t) -> 'a t -> 'b t

primitive ~info f x is a term that evaluates f on each new value of x. This is used to provide the primitive operations, which can then be combined using the other combinators in this module. info is used to label the operation in the diagram.

Sourceval component : ('a, Format.formatter, unit, description) format4 -> 'a

component name is used to annotate binds, so that the system can show a name for the operations hidden inside the bind's function. name is used as the label for the bind in the generated dot diagrams. For convenience, name can also be a format string.

Sourceval observe : 'a t -> 'a Current_term.Output.Blockable.t

observe x evaluates the current state of term x. A `Blocked value occurs when the term failed because an upstream dependency errored.

Sourcemodule Syntax : sig ... end

Sourcemodule Monitor : sig ... end

A monitor is an input pipeline stage that can watch for external events.

Sourcetype 'a term = 'a t

An alias of t to make it easy to refer to later in this file.

Source

module Analysis : 
  Current_term.S.ANALYSIS
    with type 'a term := 'a t
     and type metadata := Metadata.t

Diagram generation, introspection, and statistics.

Sourcemodule Var (T : Current_term.S.T) : sig ... end

Variable pipeline inputs.

Sourceval state_dir : string -> Fpath.t

state_dir name is a directory under which state (build results, logs) can be stored. name identifies the sub-component of OCurrent, each of which gets its own subdirectory.

Sourcemodule String : sig ... end

Sourcemodule Unit : sig ... end

Sourcemodule Switch : sig ... end

Like Lwt_switch, but the cleanup functions are called in sequence, not in parallel.

Sourcemodule Pool : sig ... end

Resource pools, to control how many jobs can use a resource at a time. To use a pool within a job, pass the pool to Job.start or call Job.use_pool.

Sourcemodule Job : sig ... end

Jobs with log files. This is mostly an internal interface - use Current_cache instead.

Sourcemodule Engine : sig ... end

The main event loop.

Sourcemodule Process : sig ... end

Helper functions for spawning sub-processes.

Sourcemodule Db : sig ... end

Access to the sqlite database.

Sourcemodule Log_matcher : sig ... end

Analysing job logs.

package current

Module CurrentSource

Sequencing terms

Applicative operations

Diagram control

Monadic operations

Primitives

Module `Current`Source