loghttp

type Entry ¶

type Entry struct {
	Timestamp time.Time
	Line      string
}

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

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

type EntryEncoder ¶

type EntryEncoder struct{}

func (EntryEncoder) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (EntryEncoder) IsEmpty(ptr unsafe.Pointer) bool

type InstantQuery ¶

type InstantQuery struct {
	Query     string
	Ts        time.Time
	Limit     uint32
	Direction int32
	Shards    []string
}

InstantQuery defines a log instant query.

type LabelResponse ¶

type LabelResponse struct {
	Status string   `json:"status"`
	Data   []string `json:"data,omitempty"`
}

LabelResponse represents the http json response to a label query

type LabelSet ¶

type LabelSet map[string]string

LabelSet is a key/value pair mapping of labels

func (l LabelSet) Map() map[string]string

func (l LabelSet) String() string

func (l *LabelSet) UnmarshalJSON(data []byte) error

type Matrix ¶

type Matrix []model.SampleStream

Matrix is a slice of SampleStreams

func (Matrix) Type() ResultType

type PushRequest ¶

type PushRequest struct {
	Streams []*Stream `json:"streams"`
}

PushRequest models a log stream push

type QueryResponse ¶

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

QueryResponse represents the http json response to a Loki range and instant query

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

type QueryResponseData ¶

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

QueryResponseData represents the http json response to a label query

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

type QueryStatus ¶

type QueryStatus string

QueryStatus holds the status of a query

type RangeQuery ¶

type RangeQuery struct {
	Start     time.Time
	End       time.Time
	Step      time.Duration
	Interval  time.Duration
	Query     string
	Direction int32
	Limit     uint32
	Shards    []string
}

RangeQuery defines a log range query.

type ResultType ¶

type ResultType string

ResultType holds the type of the result

type ResultValue ¶

type ResultValue interface {
	Type() ResultType
}

ResultValue interface mimics the promql.Value interface

type Scalar ¶

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 ¶

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

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

func (s *Stream) UnmarshalJSON(data []byte) error

type Streams ¶

type Streams []Stream

Streams is a slice of Stream

func (Streams) Type() ResultType

func (ss *Streams) UnmarshalJSON(data []byte) error

type Vector ¶

type Vector []model.Sample

Vector is a slice of Samples

func (Vector) Type() ResultType