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
  • func (e Error) Error() string

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 string

Error is the sentinel error type for the stage package.

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.

func (Error) Error

func (e Error) Error() string

Error renders the sentinel message.