wehub-resource-sync
e071084ebe
govulncheck / govulncheck (push) Waiting to run
Harness (E2E) / Harnesses (mock LLM) (push) Waiting to run
Harness (E2E) / Provider harnesses (live LLM conformance) (push) Waiting to run
Lint / golangci-lint (push) Waiting to run
Run Tests / Unit Tests (push) Waiting to run
Run Tests / Etcd Integration Tests (push) Waiting to run
59 lines
1.2 KiB
Go
59 lines
1.2 KiB
Go
// Package log provides debug logging
|
|
package log
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"time"
|
|
)
|
|
|
|
var (
|
|
// Default buffer size if any.
|
|
DefaultSize = 1024
|
|
// DefaultLog logger.
|
|
DefaultLog = NewLog()
|
|
// Default formatter.
|
|
DefaultFormat = TextFormat
|
|
)
|
|
|
|
// Log is debug log interface for reading and writing logs.
|
|
type Log interface {
|
|
// Read reads log entries from the logger
|
|
Read(...ReadOption) ([]Record, error)
|
|
// Write writes records to log
|
|
Write(Record) error
|
|
// Stream log records
|
|
Stream() (Stream, error)
|
|
}
|
|
|
|
// Record is log record entry.
|
|
type Record struct {
|
|
// Timestamp of logged event
|
|
Timestamp time.Time `json:"timestamp"`
|
|
// Metadata to enrich log record
|
|
Metadata map[string]string `json:"metadata"`
|
|
// Value contains log entry
|
|
Message interface{} `json:"message"`
|
|
}
|
|
|
|
// Stream returns a log stream.
|
|
type Stream interface {
|
|
Chan() <-chan Record
|
|
Stop() error
|
|
}
|
|
|
|
// Format is a function which formats the output.
|
|
type FormatFunc func(Record) string
|
|
|
|
// TextFormat returns text format.
|
|
func TextFormat(r Record) string {
|
|
t := r.Timestamp.Format("2006-01-02 15:04:05")
|
|
return fmt.Sprintf("%s %v", t, r.Message)
|
|
}
|
|
|
|
// JSONFormat is a json Format func.
|
|
func JSONFormat(r Record) string {
|
|
b, _ := json.Marshal(r)
|
|
return string(b)
|
|
}
|