marshal

package
v3.0.0 Latest Latest
Warning

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

Go to latest
Published: Apr 8, 2024 License: AGPL-3.0 Imports: 20 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 EncodeResult

func EncodeResult(data parser.Value, warnings []string, statistics stats.Result, s *jsoniter.Stream, encodeFlags httpreq.EncodingFlags) error

func EncodeTailResult

func EncodeTailResult(data legacy.TailResponse, s *jsoniter.Stream, encodeFlags httpreq.EncodingFlags) error

func NewDroppedStream

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

NewDroppedStream constructs a DroppedStream from a legacy.DroppedEntry

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 logqlmodel.Streams) (loghttp.Streams, error)

NewStreams constructs a Streams from a logql.Streams

func NewVector

func NewVector(v promql.Vector) loghttp.Vector

NewVector constructs a Vector from a promql.Vector

func NewWebsocketJSONWriter

func NewWebsocketJSONWriter(ws WebsocketWriter) io.Writer

func WriteDetectedFieldsResponseJSON

func WriteDetectedFieldsResponseJSON(r *logproto.DetectedFieldsResponse, w io.Writer) error

WriteDetectedFieldsResponseJSON marshals a logproto.DetectedFieldsResponse to JSON and then writes it to the provided io.Writer.

func WriteDetectedLabelsResponseJSON

func WriteDetectedLabelsResponseJSON(r *logproto.DetectedLabelsResponse, w io.Writer) error

WriteDetectedLabelsResponseJSON marshals a logproto.DetectedLabelsResponse to JSON and then writes it to the provided io.Writer.

func WriteIndexShardsResponseJSON

func WriteIndexShardsResponseJSON(r *logproto.ShardsResponse, w io.Writer) error

WriteIndexShardsResponseJSON marshals a indexgatewaypb.ShardsResponse to JSON and then writes it to the provided io.Writer.

func WriteIndexStatsResponseJSON

func WriteIndexStatsResponseJSON(r *indexStats.Stats, w io.Writer) error

WriteIndexStatsResponseJSON marshals a gatewaypb.Stats to JSON and then writes it to the provided io.Writer.

func WriteLabelResponseJSON

func WriteLabelResponseJSON(data []string, w io.Writer) error

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

func WriteQueryPatternsResponseJSON

func WriteQueryPatternsResponseJSON(r *logproto.QueryPatternsResponse, w io.Writer) error

WriteQueryPatternsResponseJSON marshals a logproto.QueryPatternsResponse to JSON and then writes it to the provided io.Writer.

func WriteQueryResponseJSON

func WriteQueryResponseJSON(data parser.Value, warnings []string, statistics stats.Result, w io.Writer, encodeFlags httpreq.EncodingFlags) error

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

func WriteResponseJSON

func WriteResponseJSON(r *http.Request, v any, w http.ResponseWriter) error

func WriteSeriesResponseJSON

func WriteSeriesResponseJSON(series []logproto.SeriesIdentifier, 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, w io.Writer, encodeFlags httpreq.EncodingFlags) error

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

func WriteVolumeResponseJSON

func WriteVolumeResponseJSON(r *logproto.VolumeResponse, w io.Writer) error

WriteVolumeResponseJSON marshals a logproto.VolumeResponse to JSON and then writes it to the provided io.Writer.

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