Documentation ¶
Index ¶
- func GetDeviceID(ctx context.Context) string
- func RunTelemetry(ctx context.Context, telemetryInfo TelemetryInfo, ...)
- func SendTelemetry(ctx context.Context, telemetry *Telemetry)
- func TelemetryTransformer(telemetry *Telemetry, datasources []config.DataSourceConfig) *physical.Transformers
- type App
- type OutputOptions
- type OutputSinkFn
- type Telemetry
- type TelemetryInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetDeviceID ¶ added in v0.3.0
func RunTelemetry ¶ added in v0.3.0
func RunTelemetry(ctx context.Context, telemetryInfo TelemetryInfo, datasources []config.DataSourceConfig, plan physical.Node, outputOptions *physical.OutputOptions)
func SendTelemetry ¶ added in v0.3.0
func TelemetryTransformer ¶ added in v0.3.0
func TelemetryTransformer(telemetry *Telemetry, datasources []config.DataSourceConfig) *physical.Transformers
Types ¶
type App ¶
type App struct {
// contains filtered or unexported fields
}
func NewApp ¶
func NewApp(cfg *config.Config, telemetryInfo TelemetryInfo, dataSourceRepository *physical.DataSourceRepository, outputSinkFn OutputSinkFn, describe bool) *App
type OutputOptions ¶ added in v0.3.0
type OutputOptions struct { OrderByExpressions []execution.Expression OrderByDirections []execution.OrderDirection Limit *int Offset *int }
func EvaluateOutputOptions ¶ added in v0.3.0
func EvaluateOutputOptions(ctx context.Context, variables octosql.Variables, options *execution.OutputOptions) (*OutputOptions, error)
type OutputSinkFn ¶ added in v0.3.0
type OutputSinkFn func(stateStorage storage.Storage, streamID *execution.StreamID, eventTimeField octosql.VariableName, outputOptions *OutputOptions) (execution.IntermediateRecordStore, output.Printer)
type Telemetry ¶ added in v0.3.0
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 ¶ added in v0.3.0
Click to show internal directories.
Click to hide internal directories.