app

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

type OutputOptions struct {
	OrderByExpressions []execution.Expression
	OrderByDirections  []execution.OrderDirection
	Limit              *int
	Offset             *int
}

type OutputSinkFn func(stateStorage storage.Storage, streamID *execution.StreamID, eventTimeField octosql.VariableName, outputOptions *OutputOptions) (execution.IntermediateRecordStore, output.Printer)

type Telemetry struct {
	Version         string `json:"version"`
	DeviceID        string `json:"device_id"`
	OS              string `json:"os"`
	Arch            string `json:"arch"`
	GoVersion       string `json:"go_version"`
	NumCPU          int    `json:"num_cpu"`
	GoMaxProcs      int    `json:"go_max_procs"`
	ExpressionCount int    `json:"expression_count"`
	ExpressionsUsed struct {
		Function       bool `json:"function"`
		NodeExpression bool `json:"node_expression"`
		StarExpression bool `json:"star_expression"`
		Tuple          bool `json:"tuple"`
	} `json:"expressions_used"`
	FormulaCount int `json:"formula_count"`
	FormulasUsed struct {
		In     bool `json:"in"`
		Like   bool `json:"like"`
		Regexp bool `json:"regexp"`
	} `json:"formulas_used"`
	NodeCount int `json:"node_count"`
	NodesUsed struct {
		Distinct            bool `json:"distinct"`
		GroupBy             bool `json:"group_by"`
		Limit               bool `json:"limit"`
		LookupJoin          bool `json:"lookup_join"`
		Offset              bool `json:"offset"`
		OrderBy             bool `json:"order_by"`
		StreamJoin          bool `json:"stream_join"`
		TableValuedFunction bool `json:"table_valued_function"`
	} `json:"nodes_used"`
	TriggersUsed struct {
		Counting  bool `json:"counting"`
		Delay     bool `json:"delay"`
		Watermark bool `json:"watermark"`
	} `json:"triggers_used"`
	FunctionsUsed            map[string]bool `json:"functions_used"`
	TableValuedFunctionsUsed map[string]bool `json:"table_valued_functions_used"`
	DatasourceTypesInConfig  map[string]bool `json:"datasource_types_in_config"`
	DatasourceTypesUsed      map[string]bool `json:"datasource_types_used"`
	OutputFormat             string          `json:"output_format"`
}

type TelemetryInfo struct {
	OutputFormat string
	Version      string
}