loki

Documentation

Index

• type Loki
  • func (l *Loki) Init(c *config.Config) error
  • func (l *Loki) Send(log string, metadata map[string]string)
  • func (l *Loki) Stream(entry chan utils.LogEntry)
• type LokiDTO
• type Streams

Types

type Loki

type Loki struct {
	// contains filtered or unexported fields
}

func (*Loki) Init

func (l *Loki) Init(c *config.Config) error

Init creates the loki configuration

func (*Loki) Send

func (l *Loki) Send(log string, metadata map[string]string)

func (*Loki) Stream

func (l *Loki) Stream(entry chan utils.LogEntry)

Stream sends the logs to Loki

type LokiDTO

type LokiDTO struct {
	Streams []Streams `json:"streams"`
}

type Streams

type Streams struct {
	Stream map[string]string `json:"stream"`
	Values [][]string        `json:"values"`
}