logsql

package
v0.30.0-victorialogs Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 27, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FieldsForHits added in v1.97.7

func FieldsForHits(columns []logstorage.BlockColumn, rowIdx int) string

func HitsSeries added in v1.97.7

func HitsSeries(m map[string]*hitsSeries) string

func JSONRow

func JSONRow(columns []logstorage.BlockColumn, rowIdx int) string

func JSONRows

func JSONRows(rows [][]logstorage.Field) string

func ProcessFieldNamesRequest added in v1.97.7

func ProcessFieldNamesRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessFieldNamesRequest handles /select/logsql/field_names request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-field-names

func ProcessFieldValuesRequest added in v1.97.7

func ProcessFieldValuesRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessFieldValuesRequest handles /select/logsql/field_values request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-field-values

func ProcessHitsRequest added in v1.97.7

func ProcessHitsRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessHitsRequest handles /select/logsql/hits request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-hits-stats

func ProcessLiveTailRequest added in v1.97.7

func ProcessLiveTailRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessLiveTailRequest processes live tailing request to /select/logsq/tail

See https://docs.victoriametrics.com/victorialogs/querying/#live-tailing

func ProcessQueryRequest

func ProcessQueryRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessQueryRequest handles /select/logsql/query request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-logs

func ProcessStatsQueryRangeRequest added in v1.97.8

func ProcessStatsQueryRangeRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessStatsQueryRangeRequest handles /select/logsql/stats_query_range request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-log-range-stats

func ProcessStatsQueryRequest added in v1.97.8

func ProcessStatsQueryRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessStatsQueryRequest handles /select/logsql/stats_query request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-log-stats

func ProcessStreamFieldNamesRequest added in v1.97.7

func ProcessStreamFieldNamesRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessStreamFieldNamesRequest processes /select/logsql/stream_field_names request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-stream-field-names

func ProcessStreamFieldValuesRequest added in v1.97.7

func ProcessStreamFieldValuesRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessStreamFieldValuesRequest processes /select/logsql/stream_field_values request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-stream-field-values

func ProcessStreamIDsRequest added in v1.97.7

func ProcessStreamIDsRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessStreamIDsRequest processes /select/logsql/stream_ids request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-stream_ids

func ProcessStreamsRequest added in v1.97.7

func ProcessStreamsRequest(ctx context.Context, w http.ResponseWriter, r *http.Request)

ProcessStreamsRequest processes /select/logsql/streams request.

See https://docs.victoriametrics.com/victorialogs/querying/#querying-streams

func StatsQueryRangeResponse added in v1.97.8

func StatsQueryRangeResponse(rows []*statsSeries) string

func StatsQueryResponse added in v1.97.8

func StatsQueryResponse(rows []statsRow) string

func StreamFieldsForHits added in v1.97.7

func StreamFieldsForHits(qw422016 *qt422016.Writer, columns []logstorage.BlockColumn, rowIdx int)

func StreamHitsSeries added in v1.97.7

func StreamHitsSeries(qw422016 *qt422016.Writer, m map[string]*hitsSeries)

func StreamJSONRow

func StreamJSONRow(qw422016 *qt422016.Writer, columns []logstorage.BlockColumn, rowIdx int)

func StreamJSONRows

func StreamJSONRows(qw422016 *qt422016.Writer, rows [][]logstorage.Field)

func StreamStatsQueryRangeResponse added in v1.97.8

func StreamStatsQueryRangeResponse(qw422016 *qt422016.Writer, rows []*statsSeries)

func StreamStatsQueryResponse added in v1.97.8

func StreamStatsQueryResponse(qw422016 *qt422016.Writer, rows []statsRow)

func StreamValuesWithHitsJSON added in v1.97.7

func StreamValuesWithHitsJSON(qw422016 *qt422016.Writer, values []logstorage.ValueWithHits)

func ValuesWithHitsJSON added in v1.97.7

func ValuesWithHitsJSON(values []logstorage.ValueWithHits) string

func WriteFieldsForHits added in v1.97.7

func WriteFieldsForHits(qq422016 qtio422016.Writer, columns []logstorage.BlockColumn, rowIdx int)

func WriteHitsSeries added in v1.97.7

func WriteHitsSeries(qq422016 qtio422016.Writer, m map[string]*hitsSeries)

func WriteJSONRow

func WriteJSONRow(qq422016 qtio422016.Writer, columns []logstorage.BlockColumn, rowIdx int)

func WriteJSONRows

func WriteJSONRows(qq422016 qtio422016.Writer, rows [][]logstorage.Field)

func WriteStatsQueryRangeResponse added in v1.97.8

func WriteStatsQueryRangeResponse(qq422016 qtio422016.Writer, rows []*statsSeries)

func WriteStatsQueryResponse added in v1.97.8

func WriteStatsQueryResponse(qq422016 qtio422016.Writer, rows []statsRow)

func WriteValuesWithHitsJSON added in v1.97.7

func WriteValuesWithHitsJSON(qq422016 qtio422016.Writer, values []logstorage.ValueWithHits)

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL