package
0.0.0-20231018235809-90deddd72f8f
Repository: https://github.com/grailbio/reflow.git
Documentation: pkg.go.dev

# Functions

Background returns the Context associated with the given / parent context.Context.
ImageQualifiers analyzes the given image for the presence of backdoor qualifiers, strips the image of them, and returns a boolean for each known qualifier if present.
NewEval creates and initializes a new evaluator using the provided evaluation configuration and root flow.
NewRepair returns a new repair configured with the provided EvalConfig.
WithBackground returns a new context.Context with an affiliated Context, accessible via Background.

# Constants

Cached is the mutation that sets the flow's flag.
Coerce is a flow value coercion.
Collect filters and rewrites values.
Data evaluates to a literal (inline) piece of data.
Done indicates that the node has completed evaluation.
Exec runs a command in a docker container on the inputs represented by the Flow's dependencies.
State denotes a Flow node's state during evaluation.
Extern exports values to URLs.
Groupby applies a regular expression to group an input value.
Init indicates that the flow is initialized but not evaluated.
Intern imports datasets from URLs.
No description provided by the author
K is a flow continuation.
Kctx is a flow continuation with access to the evaluator context.
Lookup indicates that the evaluator is currently performing a cache lookup of the flow node.
Map applies a function (which returns a Flow) to each element in the input.
Max is the number of flow states.
Merge merges a set of flows.
MustIntern sets the flow's MustIntern flag to true.
NeedLookup indicates that the evaluator should perform a cache lookup on the flow node.
NeedSubmit indicates the task is ready to be submitted to the scheduler.
NoStatus indicates that a flow node's status should not be updated.
Propagate is the mutation that propagates a flow's dependency assertions to the flow's result Fileset.
Pullup merges a set of results into one value.
Ready indicates that the node is ready for evaluation and should be scheduled by the evaluator.
Refresh is the mutation that refreshes the status of the flow node.
Requirements modifies the flow's requirements.
Running indicates that the node is currently being evaluated by the evaluator.
TODO indicates that the evaluator should consider the node for evaluation once its dependencies are completed.
Val returns a value.

# Variables

Digester is the Digester used throughout reflow.
Universe is the global namespace for digest computation.

# Structs

Config stores flow configuration information.
Context is a context.Context that is used for background operations within reflow.
Edge represents a dependency from a flow node to another.
Eval is an evaluator for Flows.
EvalConfig provides runtime configuration for evaluation instances.
ExecArg indexes arguments to dependencies.
Flow defines an AST for data flows.
FlowVisitor implements a convenient visitor for flow graphs.
Node is a flow node in the dot graph.
Repair performs cache-repair for flows.
Value is an argument to (*Eval).Mutate to indicate a set-value mutation.

# Interfaces

KContext is the context provided to a continuation (Kctx).
Snapshotter provides an interface for snapshotting source URL data into unloaded filesets.
WaitGroup defines a subset of sync.WaitGroup's interface for use with Context.

# Type aliases

Mutation is a type of mutation.
Op is an enum representing operations that may be performed in a Flow.
SetReserved sets the flow's Reserved resources.
State is an enum representing the state of a Flow node during evaluation.
Status amends the task's status string.