cel

package

v0.109.18 Latest Latest Go to latest Published: Sep 30, 2026 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hatchet-dev/hatchet

Links

Documentation ¶

Index ¶

Constants
func Int(i int) string
func Str(s string) string
type BoolExprEvaluator
- func NewBoolExprEvaluator() (*BoolExprEvaluator, error)
- func (e *BoolExprEvaluator) Compile(expr string) (celgo.Program, error)
- func (e *BoolExprEvaluator) EvalBoolExpr(ctx context.Context, expr string, vars map[string]interface{}) (bool, error)
type CELParser
- func NewCELParser() *CELParser
type Input
- func NewInput(opts ...InputOpts) Input
type InputOpts
type StepRunOut
type StepRunOutType

Constants ¶

View Source

const (
	// MaxEvalCost bounds the runtime cost of a single evaluation. Expressions are
	// tenant-supplied and evaluated in the shared API and engine processes, so a
	// nested comprehension over literal or attacker-sized lists must fail instead
	// of consuming unbounded CPU and memory. Ordinary expressions cost a few units
	// per operation; string traversal costs about 0.1 per byte, which leaves room
	// for multi-megabyte payloads.
	MaxEvalCost uint64 = 1_000_000

	// MaxEvalDuration bounds wall-clock time per evaluation as a backstop for work
	// the cost model underestimates.
	MaxEvalDuration = 5 * time.Second
)

Variables ¶

This section is empty.

Functions ¶

func Int ¶

func Int(i int) string

func Str ¶

func Str(s string) string

Types ¶

type BoolExprEvaluator ¶ added in v0.104.0

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

func NewBoolExprEvaluator ¶ added in v0.104.0

func NewBoolExprEvaluator() (*BoolExprEvaluator, error)

func (*BoolExprEvaluator) Compile ¶ added in v0.104.0

func (e *BoolExprEvaluator) Compile(expr string) (celgo.Program, error)

func (*BoolExprEvaluator) EvalBoolExpr ¶ added in v0.104.0

func (e *BoolExprEvaluator) EvalBoolExpr(ctx context.Context, expr string, vars map[string]interface{}) (bool, error)

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 sqlcv1.StepExpressionKind) error

func (*CELParser) CheckStepRunOutAgainstKnownV1 ¶

func (p *CELParser) CheckStepRunOutAgainstKnownV1(out *StepRunOut, knownType sqlcv1.StepExpressionKind) error

func (*CELParser) EvaluateEventExpression ¶

func (p *CELParser) EvaluateEventExpression(expr string, input Input) (bool, error)

func (*CELParser) EvaluateIncomingWebhookExpression ¶ added in v0.70.0

func (p *CELParser) EvaluateIncomingWebhookExpression(expr string, input Input) (string, error)

func (*CELParser) ParseAndEvalIdempotencyKey ¶ added in v0.106.0

func (p *CELParser) ParseAndEvalIdempotencyKey(idempotencyKeyExpr string, in Input) (string, 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) ParseIdempotencyKey ¶ added in v0.106.0

func (p *CELParser) ParseIdempotencyKey(idempotencyKeyExpr string) (cel.Program, 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)

func (*CELParser) ValidateWorkflowStringAsInt ¶ added in v0.105.22

func (p *CELParser) ValidateWorkflowStringAsInt(workflowExp string) error

ValidateWorkflowStringAsInt compiles like ParseWorkflowString but additionally rejects expressions whose static output type can never be an integer (string or bool). Most real expressions read the dyn input maps and infer dyn, which passes here; the evaluation-time int check at task insert is the backstop.

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 WithEventID ¶

func WithEventID(eventID uuid.UUID) InputOpts

func WithEventKey ¶

func WithEventKey(key string) InputOpts

func WithHeaders ¶ added in v0.70.7

func WithHeaders(headers map[string]string) InputOpts

func WithInput ¶

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

func WithParents ¶

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

func WithPayload ¶

func WithPayload(payload map[string]interface{}) InputOpts

func WithWorkflowRunID ¶

func WithWorkflowRunID(workflowRunID uuid.UUID) InputOpts

type StepRunOut ¶

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

type StepRunOutType ¶

type StepRunOutType string

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL