octosql: github.com/cube2222/octosql/app Index | Files

package app

import "github.com/cube2222/octosql/app"

Index

Package Files

app.go telemetry.go

func GetDeviceID Uses

func GetDeviceID(ctx context.Context) string

func RunTelemetry Uses

func RunTelemetry(ctx context.Context, telemetryInfo TelemetryInfo, datasources []config.DataSourceConfig, plan physical.Node, outputOptions *physical.OutputOptions)

func SendTelemetry Uses

func SendTelemetry(ctx context.Context, telemetry *Telemetry)

func TelemetryTransformer Uses

func TelemetryTransformer(telemetry *Telemetry, datasources []config.DataSourceConfig) *physical.Transformers

type App Uses

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

func NewApp Uses

func NewApp(cfg *config.Config, telemetryInfo TelemetryInfo, dataSourceRepository *physical.DataSourceRepository, outputSinkFn OutputSinkFn, describe bool) *App

func (*App) RunPlan Uses

func (app *App) RunPlan(ctx context.Context, stateStorage storage.Storage, plan logical.Node, outputOptions *logical.OutputOptions) error

type OutputOptions Uses

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

func EvaluateOutputOptions Uses

func EvaluateOutputOptions(ctx context.Context, variables octosql.Variables, options *execution.OutputOptions) (*OutputOptions, error)

type OutputSinkFn Uses

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

type Telemetry Uses

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 Uses

type TelemetryInfo struct {
    OutputFormat string
    Version      string
}

Package app imports 25 packages (graph) and is imported by 2 packages. Updated 2020-08-03. Refresh now. Tools for package owners.