absinthe v1.5.0 Absinthe.Pipeline View Source
Execute a pipeline of phases.
A pipeline is merely a list of phases. This module contains functions for building, modifying, and executing pipelines of phases.
Link to this section Summary
Functions
Return the part of a pipeline before a specific phase.
Return the part of a pipeline after (and including) a specific phase.
Return the pipeline with the phase/list of phases inserted after the supplied phase.
Return the pipeline with the phase/list of phases inserted before the supplied phase.
Return the pipeline with the phases matching the regex removed.
Replace a phase in a pipeline with another, supporting reusing the same options.
Return the part of a pipeline up to and including a specific phase.
Return the pipeline with the supplied phase removed.
Link to this section Types
phase_config_t()
View Sourcephase_config_t() :: Absinthe.Phase.t() | {Absinthe.Phase.t(), Keyword.t()}
Link to this section Functions
Return the part of a pipeline before a specific phase.
Examples
iex> Pipeline.before([A, B, C], B)
[A]for_document(schema, options \\ [])
View Sourcefor_document(Absinthe.Schema.t(), Keyword.t()) :: t()
for_schema(schema, options \\ [])
View Sourcefor_schema(nil | Absinthe.Schema.t(), Keyword.t()) :: t()
Return the part of a pipeline after (and including) a specific phase.
Examples
iex> Pipeline.from([A, B, C], B)
[B, C]insert_after(pipeline, phase, additional)
View Sourceinsert_after(t(), Absinthe.Phase.t(), phase_config_t() | [phase_config_t()]) :: t()
Return the pipeline with the phase/list of phases inserted after the supplied phase.
Examples
Add one phase after another:
iex> Pipeline.insert_after([A, C, D], A, B)
[A, B, C, D]Add list of phases after another:
iex> Pipeline.insert_after([A, D, E], A, [B, C])
[A, B, C, D, E]insert_before(pipeline, phase, additional)
View Sourceinsert_before(t(), Absinthe.Phase.t(), phase_config_t() | [phase_config_t()]) :: t()
Return the pipeline with the phase/list of phases inserted before the supplied phase.
Examples
Add one phase before another:
iex> Pipeline.insert_before([A, C, D], C, B)
[A, B, C, D]Add list of phase before another:
iex> Pipeline.insert_before([A, D, E], D, [B, C])
[A, B, C, D, E]Return the pipeline with the phases matching the regex removed.
Examples
iex> Pipeline.reject([A, B, C], ~r/A|B/)
[C]replace(pipeline, phase, replacement)
View Sourcereplace(t(), Absinthe.Phase.t(), phase_config_t()) :: t()
Replace a phase in a pipeline with another, supporting reusing the same options.
Examples
Replace a simple phase (without options):
iex> Pipeline.replace([A, B, C], B, X)
[A, X, C]Replace a phase with options, retaining them:
iex> Pipeline.replace([A, {B, [name: "Thing"]}, C], B, X)
[A, {X, [name: "Thing"]}, C]Replace a phase with options, overriding them:
iex> Pipeline.replace([A, {B, [name: "Thing"]}, C], B, {X, [name: "Nope"]})
[A, {X, [name: "Nope"]}, C]run(input, pipeline)
View Sourcerun(data_t(), t()) :: {:ok, data_t(), [Absinthe.Phase.t()]} | {:error, String.t(), [Absinthe.Phase.t()]}
run_phase(pipeline, input, done \\ [])
View Sourcerun_phase(t(), data_t(), [Absinthe.Phase.t()]) :: {:ok, data_t(), [Absinthe.Phase.t()]} | {:error, String.t(), [Absinthe.Phase.t()]}
Return the part of a pipeline up to and including a specific phase.
Examples
iex> Pipeline.upto([A, B, C], B)
[A, B]Return the pipeline with the supplied phase removed.
Examples
iex> Pipeline.without([A, B, C], B)
[A, C]