logsql

func FieldNamesResponse ¶

func FieldNamesResponse(names []string) string

func FieldValuesResponse ¶

func FieldValuesResponse(values []string) 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 LabelsForHits ¶

func LabelsForHits(columns []logstorage.BlockColumn, rowIdx int) 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 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/#http-api

func ProcessStreamLabelNamesRequest ¶

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

ProcessStreamLabelNamesRequest processes /select/logsql/stream_label_names request.

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

func ProcessStreamLabelValuesRequest ¶

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

ProcessStreamLabelValuesRequest processes /select/logsql/stream_label_values request.

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

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 StreamFieldNamesResponse ¶

func StreamFieldNamesResponse(qw422016 *qt422016.Writer, names []string)

func StreamFieldValuesResponse ¶

func StreamFieldValuesResponse(qw422016 *qt422016.Writer, values []string)

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 StreamLabelNamesResponse ¶

func StreamLabelNamesResponse(names []string) string

func StreamLabelValuesResponse ¶

func StreamLabelValuesResponse(values []string) string

func StreamLabelsForHits ¶

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

func StreamStreamLabelNamesResponse ¶

func StreamStreamLabelNamesResponse(qw422016 *qt422016.Writer, names []string)

func StreamStreamLabelValuesResponse ¶

func StreamStreamLabelValuesResponse(qw422016 *qt422016.Writer, values []string)

func StreamStreamsResponse ¶

func StreamStreamsResponse(qw422016 *qt422016.Writer, streams []string)

func StreamsResponse ¶

func StreamsResponse(streams []string) string

func WriteFieldNamesResponse ¶

func WriteFieldNamesResponse(qq422016 qtio422016.Writer, names []string)

func WriteFieldValuesResponse ¶

func WriteFieldValuesResponse(qq422016 qtio422016.Writer, values []string)

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 WriteLabelsForHits ¶

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

func WriteStreamLabelNamesResponse ¶

func WriteStreamLabelNamesResponse(qq422016 qtio422016.Writer, names []string)

func WriteStreamLabelValuesResponse ¶

func WriteStreamLabelValuesResponse(qq422016 qtio422016.Writer, values []string)

func WriteStreamsResponse ¶

func WriteStreamsResponse(qq422016 qtio422016.Writer, streams []string)