impact

type Config struct {
	DecisionLogs bool `json:"decision_logs"` // Also emit decision logs for secondary evals
}

type EvalContext interface {
	CompiledQuery() ast.Body
	NDBCache() builtins.NDBCache
	ParsedInput() ast.Value
	Metrics() metrics.Metrics
}

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

type Job interface {
	ID() JobID
	SampleRate() float32
	PublishEquals() bool
	Bundle() *bundle.Bundle
	Duration() time.Duration
	Results() <-chan *Result

	// Result records a single result
	Result(*Result) error

	Start(_ context.Context, cleanup func())
}

type JobID string

type Result struct {
	NodeID     string `json:"node_id"`
	RequestID  uint64 `json:"req_id,omitempty"`
	DecisionID string `json:"decision_id,omitempty"`
	ValueA     *any   `json:"value_a"`
	ValueB     *any   `json:"value_b"`
	Input      *any   `json:"input"`
	Path       string `json:"path"`
	EvalNSA    uint64 `json:"eval_ns_a"`
	EvalNSB    uint64 `json:"eval_ns_b"`
}