loki

package

v1.12.1 Latest Latest Go to latest Published: Aug 10, 2024 License: Apache-2.0 Imports: 17 Imported by: 3

Details

View Source

const LOG_ENTRIES_CHAN_SIZE = 5000

View Source

const (
	LokiPushPath = "/loki/api/v1/push"
)

This section is empty.

This section is empty.

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

LokiLogger send log messages towards Loki.

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

func (c *LokiLogger) DiscoverLokiServer(ctx context.Context, log zerolog.Logger) error

DiscoverLokiServer automatically updates Loki URL when loki service on mDNS changes. Runs until context is canceled.

func (c *LokiLogger) SetLokiServer(host string, port int, secure bool)

SetLokiServer updates the URL to push logs to.

func (c *LokiLogger) SetTimeoffset(timeOffset int64)

Set the timeoffset in seconds

func (c *LokiLogger) Shutdown()

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

Write a std message

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

Write a message with given level

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

func NewLokiProxy(log zerolog.Logger, host string, port int, secure bool) *LokiProxy

NewLokiProxy constructs a new loki proxy that forwards loki push requests to the given host:port.

func (lp *LokiProxy) HandlePushRequest(resp http.ResponseWriter, req *http.Request)

HandlePushRequest receives a standard Loki push request, updates all time entries and forwards the request to the configure loki URL.

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

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

Path	Synopsis
test