merge

type ExecutionMetadata struct {
	// GroupKey is a logical key used to correlate queue items into a single execution
	GroupKey string `json:"groupKey,omitempty" mapstructure:"groupKey"`

	// EventIDs collects upstream event ids that reached this merge
	EventIDs []string `json:"eventIDs,omitempty" mapstructure:"eventIDs"`

	// Sources collects distinct upstream source node ids that reached this merge
	Sources []string `json:"sources,omitempty" mapstructure:"sources"`

	// StopEarly indicates the merge was short-circuited based on a stop condition
	StopEarly bool `json:"stopEarly,omitempty" mapstructure:"stopEarly"`
}

type Merge struct{}

type Spec struct {
	// EnableTimeout toggles the execution timeout feature
	EnableTimeout bool `json:"enableTimeout" mapstructure:"enableTimeout"`

	ExecutionTimeout struct {
		Value int    `json:"value"`
		Unit  string `json:"unit"`
	} `json:"executionTimeout"`

	// EnableStopIf toggles the conditional stop feature
	EnableStopIf bool `json:"enableStopIf" mapstructure:"enableStopIf"`

	// Optional expression to short-circuit waiting for all inputs.
	// The expression is evaluated against the incoming event input using
	// the Expr language with the input bound to the variable '$'.
	// If it evaluates to true, the merge finishes immediately.
	StopIfExpression string `json:"stopIfExpression" mapstructure:"stopIfExpression"`
}