types

type AfterMatchSkip int

type AggregationFieldInfo struct {
	FuncName    string                   `json:"funcName"`    // 函数名，如 "first_value"
	InputField  string                   `json:"inputField"`  // 输入字段，如 "displayNum"
	Placeholder string                   `json:"placeholder"` // 占位符，如 "__first_value_0__"
	AggType     aggregator.AggregateType `json:"aggType"`     // 聚合类型
	FullCall    string                   `json:"fullCall"`    // 完整函数调用，如 "NTH_VALUE(value, 2)"
}

type AnalyticCall struct {
	FuncName string   // 函数名，如 "acc_max"
	BareCall string   // 完整调用文本（不含 OVER），如 "acc_max(v)"
	Args     []string // 原始参数表达式片段（未求值），如 ["v"]
}

type AnalyticField struct {
	FuncName   string    // 函数名，如 "lag"
	Args       []string  // 原始参数表达式片段（未求值），如 ["temp","1"]
	Expression string    // 完整调用文本（不含 OVER），如 "lag(temp, 1)"
	Alias      string    // 输出列名（多列函数仅作内部句柄，实际列名由结果决定）
	Over       *OverSpec // OVER 子句，nil 表示无
	// MultiColumn 标记多列动态输出函数（changed_cols）：其求值结果为 map[colname]value，
	// 投影时按 prefix+colname 扇出为多个输出列。仅 SELECT。
	MultiColumn bool
	// WrapperExpr 外层算术/表达式回代模板：当字段是"表达式包分析函数"（如 ts - lag(ts)）
	// 时，分析调用子串被替换为占位 __analytic_self__，得 "ts - __analytic_self__"。
	// 求值期先算出分析函数值，代入占位再求整个表达式。空表示纯分析字段。
	WrapperExpr string
	// Calls 表达式内全部 Analytic 调用（按出现顺序）。纯单调用字段长度为 1；
	// 多调用（acc_max(v) - acc_min(v)）长度 ≥ 2，每个调用在 WrapperExpr 里对应
	// types.AnalyticSelfTokenN(i) 占位。FuncName/Args/Expression 仍保留首个调用值供旧路径。
	Calls []AnalyticCall
	// InlineAggDisplay 窗口查询里分析函数参数内联聚合的重写映射：隐藏键→显示名。
	// 如 changed_cols("t",true,avg(temperature)) 在窗口查询里，avg(temperature) 被提取为
	// 隐藏计算字段 __winagg_0__，这里记录 {"__winagg_0__":"avg"}，输出列名取显示名（→ tavg）。
	InlineAggDisplay map[string]string
}

type BufferConfig struct {
	DataChannelSize     int     `json:"dataChannelSize"`     // Data input buffer size
	ResultChannelSize   int     `json:"resultChannelSize"`   // Result output buffer size
	WindowOutputSize    int     `json:"windowOutputSize"`    // Window output buffer size
	EnableDynamicResize bool    `json:"enableDynamicResize"` // Enable dynamic buffer resizing
	MaxBufferSize       int     `json:"maxBufferSize"`       // Maximum buffer size
	UsageThreshold      float64 `json:"usageThreshold"`      // Buffer usage threshold
}

type Config struct {
	// SQL processing related configuration
	WindowConfig WindowConfig                        `json:"windowConfig"`
	GroupFields  []string                            `json:"groupFields"`
	SelectFields map[string]aggregator.AggregateType `json:"selectFields"`
	FieldAlias   map[string]string                   `json:"fieldAlias"`
	// SelectAlias maps a SELECT item's raw expression to its AS alias (e.g.
	// "m.location" -> "loc"). The aggregation path uses it to name output
	// columns for grouped non-aggregate columns, matching the direct path
	// (where the alias is applied during SimpleField compilation).
	SelectAlias        map[string]string           `json:"selectAlias"`
	SimpleFields       []string                    `json:"simpleFields"`
	FieldExpressions   map[string]FieldExpression  `json:"fieldExpressions"`
	PostAggExpressions []PostAggregationExpression `json:"postAggExpressions"` // Post-aggregation expressions
	FieldOrder         []string                    `json:"fieldOrder"`         // Original order of fields in SELECT statement
	Where              string                      `json:"where"`
	Having             string                      `json:"having"`

	// Feature switches
	NeedWindow bool `json:"needWindow"`
	Distinct   bool `json:"distinct"`

	// Mode 选择执行路径（直连/窗口/CEP）。NeedWindow 保留为兼容谓词（==ExecWindow）。
	Mode ExecMode `json:"mode"`
	// MatchRecognize 携带 MATCH_RECOGNIZE 子句；非空时 Mode=ExecCEP。
	MatchRecognize *MatchRecognizeSpec `json:"matchRecognize,omitempty"`

	// Result control
	Limit       int            `json:"limit"`
	Projections []Projection   `json:"projections"`
	OrderBy     []OrderByField `json:"orderBy"` // ORDER BY sort keys, applied per emit batch

	// JoinConfigs describes stream-table JOINs (v0.5: metadata enrichment).
	// Empty means no JOIN. Each entry references a registered table source by
	// name and is resolved at row-processing time.
	JoinConfigs []JoinConfig `json:"joinConfigs"`

	// SourceAlias is the optional FROM alias (e.g. "s" in "FROM stream AS s").
	// When set, stream fields can be qualified as "s.<field>" in SELECT/WHERE.
	SourceAlias string `json:"sourceAlias"`

	// AnalyticFields 分析函数字段（带可选 OVER）。走直连路径，由
	// 流级状态机逐条求值，不进聚合路径。空表示无分析函数。
	AnalyticFields []AnalyticField `json:"analyticFields"`
	// WhereAnalyticCalls WHERE 中出现的分析函数调用；解析期从 WHERE 文本提取并
	// 替换为占位符，求值期在 WHERE 之前算出值注入 dataMap[Placeholder]。
	WhereAnalyticCalls []WhereAnalyticCall `json:"whereAnalyticCalls"`
	// AnalyticMaxPartitions 每个分析函数字段 PARTITION 状态的分区数上限，超出按
	// LRU 淘汰最久未用的分区。≤0 表示用默认值（见 stream.defaultMaxPartitions）。
	// 由 WithAnalyticMaxPartitions 注入。高基数分区键（如设备上万）且内存充裕时可调高。
	AnalyticMaxPartitions int `json:"analyticMaxPartitions"`

	// Logger is the per-instance logger for the stream pipeline. Injected by
	// Streamsql.Execute (from WithLogger, else the process default); nil falls
	// back to logger.GetDefault() at construction. Immutable after construction.
	Logger logger.Logger `json:"-"`

	// Performance configuration
	PerformanceConfig PerformanceConfig `json:"performanceConfig"`
}

type ExecMode int

type ExpansionConfig struct {
	GrowthFactor     float64       `json:"growthFactor"`     // Growth factor
	MinIncrement     int           `json:"minIncrement"`     // Minimum expansion increment
	TriggerThreshold float64       `json:"triggerThreshold"` // Expansion trigger threshold
	ExpansionTimeout time.Duration `json:"expansionTimeout"` // Expansion timeout duration
}

type FieldExpression struct {
	Field      string   `json:"field"`      // original field name
	Expression string   `json:"expression"` // complete expression
	Fields     []string `json:"fields"`     // all fields referenced in expression
}

type JoinConfig struct {
	Table    string       // registered table source name
	Alias    string       // table alias; matched columns are namespaced under it. Defaults to Table.
	JoinType string       // "INNER" (default) or "LEFT"
	OnPairs  []JoinOnPair // equality predicates linking stream and table fields
}

type JoinOnPair struct {
	StreamField string
	TableField  string
}

type MatchDefine struct {
	Symbol string
	Cond   string
}

type MatchRecognizeSpec struct {
	PartitionBy  []string
	OrderBy      []OrderByField
	Measures     []Measure
	RowsPerMatch RowsPerMatch
	Skip         AfterMatchSkip
	SkipSymbol   string // SKIP TO FIRST/LAST/<symbol> 的目标符号
	Pattern      *PatternNode
	Subsets      []MatchSubset
	Within       time.Duration // 0 表示用默认上限（CEP 强制有界）
	Defines      []MatchDefine
}

type MatchSubset struct {
	Name    string
	Symbols []string
}

type Measure struct {
	Expr  string
	Alias string
}

type MonitoringConfig struct {
	EnableMonitoring    bool              `json:"enableMonitoring"`    // Enable performance monitoring
	StatsUpdateInterval time.Duration     `json:"statsUpdateInterval"` // Statistics update interval
	EnableDetailedStats bool              `json:"enableDetailedStats"` // Enable detailed statistics
	WarningThresholds   WarningThresholds `json:"warningThresholds"`   // Performance warning thresholds
}

type OrderByField struct {
	Expression string        `json:"expression"` // result column name (v0.5: must match an output field)
	Direction  SortDirection `json:"direction"`  // SortAsc (default) or SortDesc
}

type OverSpec struct {
	PartitionBy []string // 分区字段，状态按分区独立维护
	When        string   // WHEN 条件表达式；满足才更新状态，否则复用旧值
}

type OverflowConfig struct {
	Strategy        string          `json:"strategy"`        // Overflow strategy: "drop", "block", "expand"
	BlockTimeout    time.Duration   `json:"blockTimeout"`    // Block timeout duration
	AllowDataLoss   bool            `json:"allowDataLoss"`   // Allow data loss
	ExpansionConfig ExpansionConfig `json:"expansionConfig"` // Expansion configuration
}

type PatternKind int

type PatternNode struct {
	Kind     PatternKind
	Symbol   string         // Literal：模式变量名
	Children []*PatternNode // Sequence/Alternation/Group/Permute/Repetition 的子节点
	Quant    *Quantifier    // Repetition 的量词
}

type PerformanceConfig struct {
	BufferConfig     BufferConfig     `json:"bufferConfig"`     // buffer configuration
	OverflowConfig   OverflowConfig   `json:"overflowConfig"`   // overflow strategy configuration
	WorkerConfig     WorkerConfig     `json:"workerConfig"`     // worker pool configuration
	MonitoringConfig MonitoringConfig `json:"monitoringConfig"` // monitoring configuration
}

type PostAggregationExpression struct {
	OutputField        string                 `json:"outputField"`        // 输出字段名
	OriginalExpr       string                 `json:"originalExpr"`       // 原始表达式
	ExpressionTemplate string                 `json:"expressionTemplate"` // 表达式模板
	RequiredFields     []AggregationFieldInfo `json:"requiredFields"`     // 依赖的聚合字段
}

type Projection struct {
	OutputName string               `json:"outputName"` // output field name
	SourceType ProjectionSourceType `json:"sourceType"` // data source type
	InputName  string               `json:"inputName"`  // input field name
}

type ProjectionSourceType int

type Quantifier struct {
	Min    int
	Max    int
	Greedy bool // true=贪婪（默认），false=懒惰（量词后跟 ?）
}

type Row struct {
	Timestamp time.Time
	Data      any
	Slot      *TimeSlot
}

type RowEvent interface {
	GetTimestamp() time.Time
}

type RowsPerMatch int

type SortDirection string

type TimeCharacteristic string

type TimeSlot struct {
	Start *time.Time
	End   *time.Time
}

type WarningThresholds struct {
	DropRateWarning     float64 `json:"dropRateWarning"`     // Drop rate warning threshold
	DropRateCritical    float64 `json:"dropRateCritical"`    // Drop rate critical threshold
	BufferUsageWarning  float64 `json:"bufferUsageWarning"`  // Buffer usage warning threshold
	BufferUsageCritical float64 `json:"bufferUsageCritical"` // Buffer usage critical threshold
}

type WhereAnalyticCall struct {
	Placeholder string    // 合成键，如 "__analytic_0__"
	FuncName    string    // 函数名
	Args        []string  // 原始参数片段
	Expression  string    // 完整调用文本（不含 OVER）
	Over        *OverSpec // OVER 子句，nil 表示无
}

type WindowConfig struct {
	Type               string             `json:"type"`
	Params             []any              `json:"params"` // Window function parameters array
	TsProp             string             `json:"tsProp"`
	TimeUnit           time.Duration      `json:"timeUnit"`
	TimeCharacteristic TimeCharacteristic `json:"timeCharacteristic"` // Time characteristic: EventTime or ProcessingTime (default: ProcessingTime)
	MaxOutOfOrderness  time.Duration      `json:"maxOutOfOrderness"`  // Maximum allowed out-of-orderness for event time (default: 0)
	WatermarkInterval  time.Duration      `json:"watermarkInterval"`  // Watermark update interval for event time (default: 200ms)
	AllowedLateness    time.Duration      `json:"allowedLateness"`    // Maximum allowed lateness for event time windows (default: 0, meaning no late data accepted after window closes)
	IdleTimeout        time.Duration      `json:"idleTimeout"`        // Idle source timeout: when no data arrives within this duration, the watermark advances to (now - maxOutOfOrderness) so idle event-time windows can close. Default 0 disables it. Trade-off: a finite IdleTimeout (e.g. 60s) reaps idle state and closes windows promptly, but events arriving after an idle gap with an event-time behind the advanced watermark are dropped as late; keep IdleTimeout=0 if stale events on resume must not be lost (then idle event-time windows stay open until new data arrives).
	CountStateTTL      time.Duration      `json:"countStateTtl"`      // Counting-window keyed state TTL: keys inactive longer than this are reaped (lazy, in the Start goroutine). Default 0 = disabled. Set via SQL STATETTL='24h'.
	GroupByKeys        []string           `json:"groupByKeys"`        // Multiple grouping keys for keyed windows
	PerformanceConfig  PerformanceConfig  `json:"performanceConfig"`  // Performance configuration
	Callback           func([]Row)        `json:"-"`                  // Callback function (not serialized)

	// Global-window: TriggerCondition is the TRIGGER WHEN predicate string
	// (e.g. "COUNT(*) >= 1000"). SelectFields/FieldAlias mirror the SELECT
	// aggregation map so the global window maintains running aggregate state per
	// group without buffering raw rows. Populated from the parsed SELECT for
	// windowType=global only.
	TriggerCondition string                              `json:"triggerCondition,omitempty"`
	SelectFields     map[string]aggregator.AggregateType `json:"selectFields,omitempty"`
	FieldAlias       map[string]string                   `json:"fieldAlias,omitempty"`
}

type WorkerConfig struct {
	SinkPoolSize     int `json:"sinkPoolSize"`     // Sink pool size
	SinkWorkerCount  int `json:"sinkWorkerCount"`  // Sink worker count
	MaxRetryRoutines int `json:"maxRetryRoutines"` // Maximum retry routines
}