Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + const QueryStatusFail + const QueryStatusSuccess + const ResultTypeMatrix + const ResultTypeScalar + const ResultTypeStream + const ResultTypeVector + const VersionLegacy + const VersionV1 + func ParseAndValidateSeriesQuery(r *http.Request) (*logproto.SeriesRequest, error) + func ParseLabelQuery(r *http.Request) (*logproto.LabelRequest, error) + func ParseSeriesQuery(r *http.Request) (*logproto.SeriesRequest, error) + func ParseTailQuery(r *http.Request) (*logproto.TailRequest, error) + type DroppedStream struct + Labels LabelSet + Timestamp time.Time + func (s *DroppedStream) MarshalJSON() ([]byte, error) + func (s *DroppedStream) UnmarshalJSON(data []byte) error + type Entry struct + Line string + Timestamp time.Time + func (e *Entry) UnmarshalJSON(data []byte) error + type EntryEncoder struct + func (EntryEncoder) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream) + func (EntryEncoder) IsEmpty(_ unsafe.Pointer) bool + type InstantQuery struct + Direction logproto.Direction + Limit uint32 + Query string + Shards []string + Ts time.Time + func ParseInstantQuery(r *http.Request) (*InstantQuery, error) + type LabelResponse struct + Data []string + Status string + type LabelSet map[string]string + func (l *LabelSet) UnmarshalJSON(data []byte) error + func (l LabelSet) Map() map[string]string + func (l LabelSet) String() string + type Matrix []model.SampleStream + func (Matrix) Type() ResultType + type PushRequest struct + Streams []*Stream + type QueryResponse struct + Data QueryResponseData + Status string + func (q *QueryResponse) UnmarshalJSON(data []byte) error + type QueryResponseData struct + Result ResultValue + ResultType ResultType + Statistics stats.Result + func (q *QueryResponseData) UnmarshalJSON(data []byte) error + type QueryStatus string + type RangeQuery struct + Direction logproto.Direction + End time.Time + Interval time.Duration + Limit uint32 + Query string + Shards []string + Start time.Time + Step time.Duration + func ParseIndexStatsQuery(r *http.Request) (*RangeQuery, error) + func ParseLabelVolumeQuery(r *http.Request) (*RangeQuery, error) + func ParseRangeQuery(r *http.Request) (*RangeQuery, error) + type ResultType string + type ResultValue interface + Type func() ResultType + type Scalar model.Scalar + func (Scalar) Type() ResultType + func (s *Scalar) UnmarshalJSON(b []byte) error + func (s Scalar) MarshalJSON() ([]byte, error) + type SeriesResponse struct + Data []LabelSet + Status string + type Stream struct + Entries []Entry + Labels LabelSet + func (s *Stream) UnmarshalJSON(data []byte) error + type Streams []Stream + func (Streams) Type() ResultType + func (s Streams) ToProto() []logproto.Stream + func (ss *Streams) UnmarshalJSON(data []byte) error + type TailResponse struct + DroppedStreams []DroppedStream + Streams []Stream + type Vector []model.Sample + func (Vector) Type() ResultType + type Version int + func GetVersion(uri string) Version
Go to main page