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 nodes that reached this merge
	SourceNodes []SourceNode `json:"sourceNodes,omitempty" mapstructure:"sourceNodes"`

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

type Merge struct{}

type SourceNode struct {
	NodeID     string  `json:"nodeId,omitempty" mapstructure:"nodeId"`
	ReceivedAt *string `json:"receivedAt,omitempty" mapstructure:"receivedAt"`
}

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"`
}