marshal

func NewDroppedStream ¶

func NewDroppedStream(s *legacy.DroppedEntry) (loghttp.DroppedStream, error)

NewDroppedStream constructs a DroppedStream from a legacy.DroppedEntry

func NewEntry ¶

func NewEntry(e logproto.Entry) loghttp.Entry

NewEntry constructs an Entry from a logproto.Entry

func NewLabelSet ¶

func NewLabelSet(s string) (loghttp.LabelSet, error)

NewLabelSet constructs a Labelset from a promql metric list as a string

func NewMatrix ¶

func NewMatrix(m promql.Matrix) loghttp.Matrix

NewMatrix constructs a Matrix from a promql.Matrix

func NewMetric ¶

func NewMetric(l labels.Labels) model.Metric

NewMetric constructs a labels.Labels from a model.Metric

func NewResultValue ¶

func NewResultValue(v promql.Value) (loghttp.ResultValue, error)

NewResultValue constructs a ResultValue from a promql.Value

func NewSample ¶

func NewSample(s promql.Sample) model.Sample

NewSample constructs a model.Sample from a promql.Sample

func NewSampleStream ¶

func NewSampleStream(s promql.Series) model.SampleStream

NewSampleStream constructs a model.SampleStream from a promql.Series

func NewStream ¶

func NewStream(s *logproto.Stream) (loghttp.Stream, error)

NewStream constructs a Stream from a logproto.Stream

func NewStreams ¶

func NewStreams(s logql.Streams) (loghttp.Streams, error)

NewStreams constructs a Streams from a logql.Streams

func NewTailResponse ¶

func NewTailResponse(r legacy.TailResponse) (loghttp.TailResponse, error)

NewTailResponse constructs a TailResponse from a legacy.TailResponse

func NewVector ¶

func NewVector(v promql.Vector) loghttp.Vector

NewVector constructs a Vector from a promql.Vector

func WriteLabelResponseJSON ¶

func WriteLabelResponseJSON(l logproto.LabelResponse, w io.Writer) error

WriteLabelResponseJSON marshals a logproto.LabelResponse to v1 loghttp JSON and then writes it to the provided io.Writer

Note that it simply directly marshals the value passed in.  This is because the label currently marshals
cleanly to the v1 http protocol.  If this ever changes, it will be caught by testing.

func WriteQueryResponseJSON ¶

func WriteQueryResponseJSON(v promql.Value, w io.Writer) error

WriteQueryResponseJSON marshals the promql.Value to v1 loghttp JSON and then writes it to the provided io.Writer

func WriteTailResponseJSON ¶

func WriteTailResponseJSON(r legacy.TailResponse, c *websocket.Conn) error

WriteTailResponseJSON marshals the legacy.TailResponse to v1 loghttp JSON and then writes it to the provided connection