Asset loads and returns the asset for the given name.

AssetDigest returns the digest of the file with the given name.

AssetDir returns the file names below a certain directory embedded in the file by go-bindata.

AssetInfo loads and returns the asset info for the given name.

AssetNames returns the names of the assets.

AssetString returns the asset contents as a string (instead of a []byte).

BlobDatumFromBlobStoreBlob creates a model blob from a blobstore result.

Digests returns a map of all known files and their checksums.

MustAsset is like Asset but panics when Asset would return an error.

MustAssetString is like AssetString but panics when Asset would return an error.

NewAwaitStageError : Error (including a timeout) awaiting a stage.

NewBlob creates a new blob body element.

NewBlobDatum creates a new blob datum.

NewEmptyDatum creates a new empty datum.

NewEmptyResult creates a successful result with an empty datum attached.

NewFailedResult creates a failed result from a given datum.

NewGraphAlreadyExistsError : can't create the same graph twice.

NewGraphCompletedError : indicates an invalid operation on an already completed (or terminating) graph.

NewGraphCreationError : failed to create graph, no graph exists afterwards.

NewGraphNotFoundError : anywhere a graph is not found.

NewHTTPReqDatum creates a datum from a HttpReq.

NewInternalErrorResult is a shortcut to create an error result with a given message.

NewInvalidDatumError : request contains an invalid datum.

NewInvalidDelayError - something wasn't right with your delay.

NewInvalidOperationError : bad operation in request.

NewInvalidStageDependenciesError : bad stage deps in request.

NewNeedsClosureError :stage needs a closure.

NewShouldNotHaveClosureError :stage has a closure when it shouldn't.

NewStageNotFoundError : anywhere a stage on an existing graph was not found.

NewStageRefDatum creates a stage ref datum to a specific stage in the current graph.

NewStateDatum creates a graph state datum.

NewSuccessfulResult creates a successful result from a given datum.

NewTooManyStagesError : too many stages in your graph.

NewTooManyTerminationHooksError : too many termination hooks on your graph.

RegisterFlowServiceHandler registers the http handlers for service FlowService to "mux".

RegisterFlowServiceHandlerClient registers the http handlers for service FlowService to "mux".

RegisterFlowServiceHandlerFromEndpoint is same as RegisterFlowServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

RestoreAsset restores an asset under the given directory.

RestoreAssets restores an asset under the given directory recursively.

AddCompletedValueStageRequest creates a new stage with a specific value.

AddDelayStageRequest creates a delay stage.

AddInvokeFunctionStageRequest adds a function invocation.

AddStageRequest adds a new stage with dependenencies to the graph.

AddStageResponse returns the stage ID of the created stage.

BlobDatum holds a reference to a blob the associated blob store.

CompleteStageExternallyRequest marks an existing stage as complete with a specific value.

CompletinonResult holds a value Datum and a result status (successful/failed).

Datum encapusulates all possible values that may be associated with a stage in the flow graph.

A delay has started - this marks the relative start of an event when a delay node is recovered.

EmptyDatum represents a null or empty value.

ErrorDatum represents an error that has occured within a flow graph, the type indicates the cause of the error and the message is informational.

A call to the FaaS completed.

A call to the FaaS has started.

The graph is committed - this typically indicates that the function that created the flow has completed once this event has been posted the graph will finish when all active or pending nodes have completed.

Graph is complete and will no longer change.

Graph created.

Graph termination has started - no more changes can be made to this graph this will be fillowed by a completion event when any termination hooks have run.

HTTPHeader wraps a single header key/value.

HTTPReqDatum describes an outgoing or incoming HTTP Request, it wraps the headers, method and optional body.

HTTPRespDatum wraps an outgoing or incoming HTTP REQUEST, it wraps the headers, status code and optinoal body.

Invoke commands.

Request Wrapper,.

Result wrapper - intentionally deep to allow extra fields at top level.

A stage was added to the graph.

A stage completed - downstream stages may be triggered.

A stage was composed into stage_id - stage_id will compelete with the saem result as composed_stage_id.

StageRefDatum represents a reference to another stage in the graph.

StateDatum wraps a description of the state of the graph in a datum.

AddStageCommand is any command that creates a stage and Warrants an AddStageResponse.

Command is the base interface for all user-facing graph requests.

Event is the base interface for all things that may be persisted to the Journal.

FlowServiceClient is the client API for FlowService service.

FlowServiceServer is the server API for FlowService service.

GraphLifecycleEventSource describes an event that can be mapped to graph lifecycle event.

GraphMessage is any message that belongs exclusively to a graph.

StageMessage is any message that belongs exclusively a stage (and hence a graph) This is intentionally distinct from GraphMessage!.

StreamableGraphEvent describes an event that can be mapped to a graph event.

CompletionOperation describes the type and behaviour of a stage of the graph.

ErrorDatumType defines an internal error code generated within a flow.

HTTPMethod defines a specific HTTP method.

StateDatumType describes the state of a stage or graph.