marshal

package
v0.0.0-...-360277a Latest Latest
Warning

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

Go to latest
Published: Apr 25, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package marshal converts internal objects to loghttp model objects. This package is designed to work with models in pkg/loghttp.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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 parser.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 NewScalar

func NewScalar(s promql.Scalar) loghttp.Scalar

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.

func WriteQueryResponseJSON

func WriteQueryResponseJSON(v logql.Result, w io.Writer) error

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

func WriteSeriesResponseJSON

func WriteSeriesResponseJSON(r logproto.SeriesResponse, w io.Writer) error

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

func WriteTailResponseJSON

func WriteTailResponseJSON(r legacy.TailResponse, c WebsocketWriter) error

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

Types

type WebsocketWriter

type WebsocketWriter interface {
	WriteMessage(int, []byte) error
}

WebsocketWriter knows how to write message to a websocket connection.

Directories

Path Synopsis
Package marshal converts internal objects to loghttp model objects.
Package marshal converts internal objects to loghttp model objects.

Jump to

Keyboard shortcuts

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