dataquery

Documentation

Index

• func DBFromResultsets(ctx context.Context, resultsets []QueryResultSet) (context.Context, func() error, error)
• func InferColumnTypes(rows []QueryResultRow) map[string]string
• type PrometheusQuery
  • func (in *PrometheusQuery) DeepCopy() *PrometheusQuery
  • func (in *PrometheusQuery) DeepCopyInto(out *PrometheusQuery)
• type Query
  • func (in *Query) DeepCopy() *Query
  • func (in *Query) DeepCopyInto(out *Query)
  • func (v *Query) IsEmpty() bool
• type QueryResultRow
  • func ExecuteQuery(ctx context.Context, q Query) ([]QueryResultRow, error)
  • func RunSQL(ctx context.Context, query string) ([]QueryResultRow, error)
• type QueryResultSet
  • func (resultSet QueryResultSet) CreateDBTable(ctx context.Context) error
  • func (rs QueryResultSet) InsertToDB(ctx context.Context) error

Functions

func DBFromResultsets

func DBFromResultsets(ctx context.Context, resultsets []QueryResultSet) (context.Context, func() error, error)

func InferColumnTypes

func InferColumnTypes(rows []QueryResultRow) map[string]string

InferColumnTypes analyzes the first few rows to determine the most appropriate column types

Types

type PrometheusQuery

type PrometheusQuery struct {
	connection.PrometheusConnection `json:",inline" yaml:",inline"`

	// Query is the PromQL query string
	Query string `json:"query" yaml:"query"`
}

+kubebuilder:object:generate=true PrometheusQuery defines a Prometheus query configuration

func (*PrometheusQuery) DeepCopy

func (in *PrometheusQuery) DeepCopy() *PrometheusQuery

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusQuery.

func (*PrometheusQuery) DeepCopyInto

func (in *PrometheusQuery) DeepCopyInto(out *PrometheusQuery)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Query

type Query struct {
	// Prometheus queries metrics from Prometheus
	Prometheus *PrometheusQuery `json:"prometheus,omitempty" yaml:"prometheus,omitempty"`
}

+kubebuilder:object:generate=true

func (*Query) DeepCopy

func (in *Query) DeepCopy() *Query

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Query.

func (*Query) DeepCopyInto

func (in *Query) DeepCopyInto(out *Query)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Query) IsEmpty

func (v *Query) IsEmpty() bool

type QueryResultRow

type QueryResultRow map[string]any

func ExecuteQuery

func ExecuteQuery(ctx context.Context, q Query) ([]QueryResultRow, error)

ExecuteQuery executes a single query and returns results with query name

func RunSQL

func RunSQL(ctx context.Context, query string) ([]QueryResultRow, error)

RunSQL runs a query and returns the results

type QueryResultSet

type QueryResultSet struct {
	Name    string
	Results []QueryResultRow

	// Map column name to column type
	ColumnDefs map[string]models.ColumnType
}

QueryResultSet contains the query name and the results

func (QueryResultSet) CreateDBTable

func (resultSet QueryResultSet) CreateDBTable(ctx context.Context) error

CreateDBTable creates a SQLite table based on the result set schema

func (QueryResultSet) InsertToDB

func (rs QueryResultSet) InsertToDB(ctx context.Context) error

InsertToDB inserts QueryResultRow data into the specified table