loki

Documentation

Index

• Constants
• func MakeValue(t time.Time, line string) []string
• func MakeValues(lines []string) (values [][]string)
• type QueryData
• type QueryResponse
• type Receiver
  • func NewReceiver(ns, name string) *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
  • func (sv StreamValues) Lines() (lines []string)
  • func (sv StreamValues) Records() (records []map[string]interface{})

Constants

const (
	Image = "grafana/loki:2.8.4"
	Port  = int32(3100)
)

Functions

func MakeValue

func MakeValue(t time.Time, line string) []string

MakeValue returns a [timestamp, line] pair.

func MakeValues

func MakeValues(lines []string) (values [][]string)

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

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

QueryResponse is the response to a loki query.

type Receiver

type Receiver struct {
	Name string
	Pod  *corev1.Pod
	// contains filtered or unexported fields
}

Receiver is a service running loki in single-process mode.

func NewReceiver

func NewReceiver(ns, name string) *Receiver

NewReceiver creates a Receiver to run Loki in single-process mode.

func (*Receiver) Create

func (r *Receiver) Create(c *client.Client) error

Create the receiver's resources. Blocks till created.

func (*Receiver) Delete

func (r *Receiver) Delete(c *client.Client) error

Delete the receiver's resources. Blocks till created.

func (*Receiver) ExternalURL

func (r *Receiver) ExternalURL(path string) *url.URL

ExternalURL returns the URL of the external route. Only valid after Create()

func (*Receiver) InternalURL

func (r *Receiver) InternalURL(path string) *url.URL

InternalURL returns the internal svc.cluster.local URL

func (*Receiver) Labels

func (r *Receiver) Labels() ([]string, error)

func (*Receiver) Push

func (r *Receiver) Push(sv ...StreamValues) error

func (*Receiver) Query

func (r *Receiver) Query(logQL string, orgID string, limit int) ([]StreamValues, error)

Query from outside cluster for logs matching logQL query expression. Returns up to limit values.

func (*Receiver) QueryUntil

func (r *Receiver) QueryUntil(logQL string, orgID string, n int) (values []StreamValues, err error)

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"}