Versions in this module Expand all Collapse all v2 v2.5.2 Apr 27, 2022 Changes in this version + func NewDroppedStream(s *legacy.DroppedEntry) (loghttp.DroppedStream, error) + func NewEntry(e logproto.Entry) loghttp.Entry + func NewLabelSet(s string) (loghttp.LabelSet, error) + func NewMatrix(m promql.Matrix) loghttp.Matrix + func NewMetric(l labels.Labels) model.Metric + func NewResultValue(v parser.Value) (loghttp.ResultValue, error) + func NewSample(s promql.Sample) model.Sample + func NewSampleStream(s promql.Series) model.SampleStream + func NewScalar(s promql.Scalar) loghttp.Scalar + func NewStream(s logproto.Stream) (loghttp.Stream, error) + func NewStreams(s logqlmodel.Streams) (loghttp.Streams, error) + func NewTailResponse(r legacy.TailResponse) (loghttp.TailResponse, error) + func NewVector(v promql.Vector) loghttp.Vector + func WriteLabelResponseJSON(l logproto.LabelResponse, w io.Writer) error + func WriteQueryResponseJSON(v logqlmodel.Result, w io.Writer) error + func WriteSeriesResponseJSON(r logproto.SeriesResponse, w io.Writer) error + func WriteTailResponseJSON(r legacy.TailResponse, c WebsocketWriter) error + type WebsocketWriter interface + WriteMessage func(int, []byte) error