loki

Documentation

Index

• Constants
• type LokiLogger
  • func NewLokiLogger(rootUrl, job string, timeOffset int64) (*LokiLogger, error)
  • func (c *LokiLogger) SetTimeoffset(timeOffset int64)
  • func (c *LokiLogger) Shutdown()
  • func (l *LokiLogger) Write(p []byte) (int, error)
  • func (l *LokiLogger) WriteLevel(level zerolog.Level, p []byte) (n int, err error)
• type PushRequest
• type StreamAdapter

Constants

const LOG_ENTRIES_CHAN_SIZE = 5000

Types

type LokiLogger

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

LokiLogger send log messages towards Loki.

func NewLokiLogger

func NewLokiLogger(rootUrl, job string, timeOffset int64) (*LokiLogger, error)

func (*LokiLogger) SetTimeoffset

func (c *LokiLogger) SetTimeoffset(timeOffset int64)

Set the timeoffset in seconds

func (*LokiLogger) Shutdown

func (c *LokiLogger) Shutdown()

func (*LokiLogger) Write

func (l *LokiLogger) Write(p []byte) (int, error)

Write a std message

func (*LokiLogger) WriteLevel

func (l *LokiLogger) WriteLevel(level zerolog.Level, p []byte) (n int, err error)

Write a message with given level

type PushRequest

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

type StreamAdapter

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