cel

Documentation

Index

• func Int(i int) string
• func Str(s string) string
• type CELParser
  • func NewCELParser() *CELParser
  • func (p *CELParser) CheckStepRunOutAgainstKnown(out *StepRunOut, knownType dbsqlc.StepExpressionKind) error
  • func (p *CELParser) ParseAndEvalStepRun(stepRunExpr string, in Input) (*StepRunOut, error)
  • func (p *CELParser) ParseAndEvalWorkflowString(workflowExp string, in Input) (string, error)
  • func (p *CELParser) ParseStepRun(stepRunExpr string) (cel.Program, error)
  • func (p *CELParser) ParseWorkflowString(workflowExp string) (cel.Program, error)
• type Input
  • func NewInput(opts ...InputOpts) Input
• type InputOpts
  • func WithAdditionalMetadata(metadata map[string]interface{}) InputOpts
  • func WithInput(input map[string]interface{}) InputOpts
  • func WithParents(parents map[string]map[string]interface{}) InputOpts
  • func WithWorkflowRunID(workflowRunID string) InputOpts
• type StepRunOut
• type StepRunOutType

Functions

func Int

func Int(i int) string

func Str

func Str(s string) string

Types

type CELParser

type CELParser struct {
	// contains filtered or unexported fields
}

func NewCELParser

func NewCELParser() *CELParser

func (*CELParser) CheckStepRunOutAgainstKnown

func (p *CELParser) CheckStepRunOutAgainstKnown(out *StepRunOut, knownType dbsqlc.StepExpressionKind) error

func (*CELParser) ParseAndEvalStepRun

func (p *CELParser) ParseAndEvalStepRun(stepRunExpr string, in Input) (*StepRunOut, error)

func (*CELParser) ParseAndEvalWorkflowString

func (p *CELParser) ParseAndEvalWorkflowString(workflowExp string, in Input) (string, error)

func (*CELParser) ParseStepRun

func (p *CELParser) ParseStepRun(stepRunExpr string) (cel.Program, error)

func (*CELParser) ParseWorkflowString

func (p *CELParser) ParseWorkflowString(workflowExp string) (cel.Program, error)

type Input

type Input map[string]interface{}

func NewInput

func NewInput(opts ...InputOpts) Input

type InputOpts

type InputOpts func(Input)

func WithAdditionalMetadata

func WithAdditionalMetadata(metadata map[string]interface{}) InputOpts

func WithInput

func WithInput(input map[string]interface{}) InputOpts

func WithParents

func WithParents(parents map[string]map[string]interface{}) InputOpts

func WithWorkflowRunID

func WithWorkflowRunID(workflowRunID string) InputOpts

type StepRunOut

type StepRunOut struct {
	String *string
	Int    *int
	Type   StepRunOutType
}

type StepRunOutType

type StepRunOutType string

const (
	StepRunOutTypeString StepRunOutType = "string"
	StepRunOutTypeInt    StepRunOutType = "int"
)