loki

Documentation

Index

• func RequestHandler(path string, w http.ResponseWriter, r *http.Request) bool
• type Entry
• type LabelPair
• type PushRequest
  • func (pr *PushRequest) MarshalProtobuf(dst []byte) []byte
  • func (pr *PushRequest) UnmarshalProtobuf(src []byte) error
• type Stream
• type Timestamp

Functions

func RequestHandler

func RequestHandler(path string, w http.ResponseWriter, r *http.Request) bool

RequestHandler processes Loki insert requests

Types

type Entry

type Entry struct {
	Timestamp          time.Time
	Line               string
	StructuredMetadata []LabelPair
}

Entry represents Loki entry.

See https://github.com/grafana/loki/blob/4220737a52da7ab6c9346b12d5a5d7bedbcd641d/pkg/push/push.proto#L38

type LabelPair

type LabelPair struct {
	Name  string
	Value string
}

LabelPair represents Loki label pair.

See https://github.com/grafana/loki/blob/4220737a52da7ab6c9346b12d5a5d7bedbcd641d/pkg/push/push.proto#L33

type PushRequest

type PushRequest struct {
	Streams []Stream
	// contains filtered or unexported fields
}

PushRequest represents Loki PushRequest

See https://github.com/grafana/loki/blob/4220737a52da7ab6c9346b12d5a5d7bedbcd641d/pkg/push/push.proto#L14C1-L14C20

func (*PushRequest) MarshalProtobuf

func (pr *PushRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf marshals r to protobuf message, appends it to dst and returns the result.

func (*PushRequest) UnmarshalProtobuf

func (pr *PushRequest) UnmarshalProtobuf(src []byte) error

UnmarshalProtobuf unmarshals pr from protobuf message at src.

pr remains valid until src is modified.

type Stream

type Stream struct {
	Labels  string
	Entries []Entry
}

Stream represents Loki stream.

See https://github.com/grafana/loki/blob/4220737a52da7ab6c9346b12d5a5d7bedbcd641d/pkg/push/push.proto#L23

type Timestamp

type Timestamp struct {
	Seconds int64
	Nanos   int32
}

Timestamp is protobuf well-known timestamp type.