stage

Documentation

Overview

Package stage implements the cirql transform stages and Build, which maps a parsed stage node to its executor. Source stages (file/http/query) report ErrStageUnsupported until the sources sub-project provides them; the stdin source is the identity stage (its input is the pipeline's input).

Index

• func Build(s ast.Stage, now Clock) (pipeline.Stage, error)
• type Clock
• type Error

Functions

func Build

func Build(s ast.Stage, now Clock) (pipeline.Stage, error)

Build maps a parsed stage to its executor. A source stage other than stdin reports ErrStageUnsupported.

Types

type Clock

type Clock = func() int64

Clock supplies epoch-seconds for the now() builtin; nil yields a zero clock.

type Error

type Error = errs.Const

Error is the sentinel-error type for the stage package — an alias of errs.Const from github.com/gomatic/go-error, which owns the mechanism (Error, With). The alias keeps every existing `stage.Error` reference and errors.Is match compiling and behaving identically.

const ErrStageUnsupported Error = "cirql: source stage not supported in core"

ErrStageUnsupported is returned when building a source stage (file/http/query) that cirql-core does not execute; the sources sub-project provides these.