pipeline

Documentation

Overview

Package pipeline holds the cirql result-set model and the sequential stage runner. A ResultSet is the list of values flowing between stages; Normalize turns an arbitrary decoded JSON value into the initial result set per the source-normalization rules (spec §5.3).

Index

• type ResultSet
  • func Normalize(v value.Value) ResultSet
  • func RunStages(stages []Stage, in ResultSet) (ResultSet, error)
• type Stage

Types

type ResultSet

type ResultSet = []value.Value

ResultSet is the data flowing between pipeline stages.

func Normalize

func Normalize(v value.Value) ResultSet

Normalize turns a decoded JSON value into the initial result set: a list maps element-by-element (non-object elements wrapped as {"value": elem}); any other value becomes a single-element set (also wrapped when not an object).

func RunStages

func RunStages(stages []Stage, in ResultSet) (ResultSet, error)

RunStages threads in through every stage left to right, stopping at the first stage error.

type Stage

type Stage interface {
	Execute(in ResultSet) (ResultSet, error)
}

Stage is one executable step of a pipeline.