model

type AggregatedQueryResponse ¶ added in v0.1.3

type AggregatedQueryResponse struct {
	ResultType    ResultType      `json:"resultType"`
	Result        ResultValue     `json:"result"`
	Stats         AggregatedStats `json:"stats"`
	UnixTimestamp int64           `json:"unixTimestamp"`
}

AggregatedQueryResponse represents the aggregated json response to one or more storage queries

func (q *AggregatedQueryResponse) UnmarshalJSON(data []byte) error

type AggregatedStats ¶ added in v0.1.3

type AggregatedStats struct {
	NumQueries   int                    `json:"numQueries"`
	TotalEntries int                    `json:"totalEntries"`
	Duplicates   int                    `json:"duplicates"`
	LimitReached bool                   `json:"limitReached"`
	QueriesStats []interface{}          `json:"queriesStats"`
	DataSources  []constants.DataSource `json:"dataSources"`
}

AggregatedStats represents the stats of one or more storage queries

type Entry ¶ added in v0.1.1

type Entry struct {
	Timestamp time.Time
	Line      string
}

Entry represents a Loki log entry. It includes a log message and the time it occurred at.

func (e *Entry) MarshalJSON() ([]byte, error)

func (e *Entry) UnmarshalJSON(data []byte) error

type FlowLineMapping ¶

type FlowLineMapping = func(string) string

type LabelValuesResponse ¶ added in v0.1.2

type LabelValuesResponse struct {
	Status string   `json:"status"`
	Data   []string `json:"data"`
}

LabelValuesResponse represents the http json response to a Loki query for label values

type Matrix ¶ added in v0.1.1

type Matrix []model.SampleStream

Matrix is a slice of SampleStreams

func (Matrix) Type() ResultType

type QueryResponse ¶ added in v0.1.1

type QueryResponse struct {
	Status string            `json:"status"`
	Data   QueryResponseData `json:"data"`
}

QueryResponse represents the http json response to a storage query (LogQL or PromQL)

type QueryResponseData ¶ added in v0.1.1

type QueryResponseData struct {
	ResultType ResultType  `json:"resultType"`
	Result     ResultValue `json:"result"`
	Stats      interface{} `json:"-"`
}

QueryResponseData represents the http json response data for a storage query

func (q *QueryResponseData) UnmarshalJSON(data []byte) error

type ResultType ¶ added in v0.1.1

type ResultType string

ResultType holds the type of the result

type ResultValue ¶ added in v0.1.1

type ResultValue interface {
	Type() ResultType
}

ResultValue interface mimics the promql.Value interface

type Scalar ¶ added in v0.1.1

type Scalar model.Scalar

Scalar is a single timestamp/float with no labels

func (s Scalar) MarshalJSON() ([]byte, error)

func (Scalar) Type() ResultType

func (s *Scalar) UnmarshalJSON(b []byte) error

type Stream ¶ added in v0.1.1

type Stream struct {
	Labels  map[string]string `json:"stream"`
	Entries []Entry           `json:"values"`
}

Stream represents a Loki log stream. It includes a set of log entries and their labels.

type Streams ¶ added in v0.1.1

type Streams []Stream

Streams is a slice of Stream

func (Streams) Type() ResultType

type Vector ¶ added in v0.1.1

type Vector []model.Sample

Vector is a slice of Samples

func (Vector) Type() ResultType