Documentation ¶
Index ¶
- Constants
- func MakeValue(t time.Time, line string) []string
- func MakeValues(lines []string) (values [][]string)
- type QueryData
- type QueryResponse
- type Receiver
- func (r *Receiver) Create(c *client.Client) error
- func (r *Receiver) Delete(c *client.Client) error
- func (r *Receiver) ExternalURL(path string) *url.URL
- func (r *Receiver) InternalURL(path string) *url.URL
- func (r *Receiver) Labels() ([]string, error)
- func (r *Receiver) Push(sv ...StreamValues) error
- func (r *Receiver) Query(logQL string, orgID string, limit int) ([]StreamValues, error)
- func (r *Receiver) QueryUntil(logQL string, orgID string, n int) (values []StreamValues, err error)
- type StreamValues
Constants ¶
const ( Image = "grafana/loki:2.8.4" Port = int32(3100) )
Variables ¶
This section is empty.
Functions ¶
func MakeValues ¶
MakeValues takes a slice of entries and returns a slice of [timestamp,line] values.
Types ¶
type QueryData ¶
type QueryData struct { ResultType string `json:"resultType"` Result []StreamValues `json:"result"` }
QueryData holds the data for a query
type QueryResponse ¶
QueryResponse is the response to a loki query.
type Receiver ¶
Receiver is a service running loki in single-process mode.
func NewReceiver ¶
NewReceiver creates a Receiver to run Loki in single-process mode.
func (*Receiver) ExternalURL ¶
ExternalURL returns the URL of the external route. Only valid after Create()
func (*Receiver) InternalURL ¶
InternalURL returns the internal svc.cluster.local URL
func (*Receiver) Push ¶
func (r *Receiver) Push(sv ...StreamValues) error
func (*Receiver) Query ¶
Query from outside cluster for logs matching logQL query expression. Returns up to limit values.
func (*Receiver) QueryUntil ¶
QueryUntil repeats the query until at least n lines are received.
type StreamValues ¶
type StreamValues struct { Stream map[string]string `json:"stream"` Values [][]string `json:"values"` }
StreamValues is a set of log values ["time", "line"] for a log stream.
func (StreamValues) Lines ¶
func (sv StreamValues) Lines() (lines []string)
Lines extracts all the log lines from a QueryResult
func (StreamValues) Records ¶
func (sv StreamValues) Records() (records []map[string]interface{})
Records extracts log lines and parses as JSON maps. Lines that are not valid JSON are are returned as: {"INVALID <error-message>": "original line"}