logging

package

v0.9.267 Latest Latest Go to latest Published: Oct 15, 2025 License: AGPL-3.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cedana/cedana

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AddLogger(writer io.Writer)
func FromFile(ctx context.Context, logfile string, level zerolog.Level, ...) (lastMsg string)
func GetLogger() zerolog.Logger
func InitLogger(level string, writers ...io.Writer)
func InitSigNoz(ctx context.Context, wg *sync.WaitGroup, service, version string)
func LastMsgFromFile(logfile string, format ...func([]byte) (string, error)) (lastMsg string, err error)
func RedactEnv(v any) any
func SetLevel(level string)
func SetLogger(writer io.Writer)
func StreamLogger() grpc.StreamServerInterceptor
func UnaryLogger() grpc.UnaryServerInterceptor
type LineInfoHook
- func (h LineInfoHook) Run(e *zerolog.Event, l zerolog.Level, msg string)
type LogWriter
- func Writer(ctx context.Context, level zerolog.Level) *LogWriter
- func (w *LogWriter) Close() error
- func (w *LogWriter) Write(p []byte) (n int, err error)
type SigNozLogEntry
type SigNozWriter
- func (sw *SigNozWriter) Write(p []byte) (n int, err error)

Constants ¶

View Source

const (
	ZEROLOG_TIME_FORMAT_DEFAULT = time.RFC3339Nano // zerolog's default format for With().Timestamp()
	LOG_TIME_FORMAT             = time.TimeOnly
	LOG_CALLER_SKIP             = 3 // stack frame depth
)

View Source

const (
	DEFAULT_MAX_BATCH_SIZE_JSON    = 100
	DEFAULT_FLUSH_INTERVAL_MS_JSON = 5000 // 5 seconds
)

Variables ¶

View Source

var (
	Level         = zerolog.Disabled
	GlobalWriter  io.Writer
	ConsoleWriter = zerolog.ConsoleWriter{
		Out:          os.Stdout,
		TimeFormat:   LOG_TIME_FORMAT,
		TimeLocation: time.Local,
	}
)

Functions ¶

func AddLogger ¶ added in v0.9.260

func AddLogger(writer io.Writer)

func FromFile ¶ added in v0.9.264

func FromFile(ctx context.Context, logfile string, level zerolog.Level, format ...func([]byte) (string, error)) (lastMsg string)

Log messages from a file. Can provide an arbitrary format function to format the log message. Noop if the current log level is higher than the provided level

func GetLogger ¶ added in v0.9.261

func GetLogger() zerolog.Logger

func InitLogger ¶ added in v0.9.247

func InitLogger(level string, writers ...io.Writer)

func InitSigNoz ¶ added in v0.9.260

func InitSigNoz(ctx context.Context, wg *sync.WaitGroup, service, version string)

func LastMsgFromFile ¶ added in v0.9.264

func LastMsgFromFile(logfile string, format ...func([]byte) (string, error)) (lastMsg string, err error)

func RedactEnv ¶ added in v0.9.253

func RedactEnv(v any) any

RedactEnv recursively removes Env fields for logging

func SetLevel ¶

func SetLevel(level string)

func SetLogger ¶ added in v0.9.247

func SetLogger(writer io.Writer)

func StreamLogger ¶

func StreamLogger() grpc.StreamServerInterceptor

func UnaryLogger ¶

func UnaryLogger() grpc.UnaryServerInterceptor

TODO NR - this needs a deep copy to properly redact

Types ¶

type LineInfoHook ¶

type LineInfoHook struct{}

func (LineInfoHook) Run ¶

func (h LineInfoHook) Run(e *zerolog.Event, l zerolog.Level, msg string)

type LogWriter ¶

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

func Writer ¶

func Writer(ctx context.Context, level zerolog.Level) *LogWriter

func (*LogWriter) Close ¶

func (w *LogWriter) Close() error

func (*LogWriter) Write ¶

func (w *LogWriter) Write(p []byte) (n int, err error)

type SigNozLogEntry ¶ added in v0.9.244

type SigNozLogEntry struct {
	Timestamp      int64             `json:"timestamp"` // Unix nanoseconds
	TraceID        string            `json:"trace_id,omitempty"`
	SpanID         string            `json:"span_id,omitempty"`
	TraceFlags     uint32            `json:"trace_flags,omitempty"` // Typically 0 or 1 (sampled)
	SeverityText   string            `json:"severity_text"`
	SeverityNumber int32             `json:"severity_number"`
	Body           string            `json:"body"`
	Attributes     map[string]string `json:"attributes,omitempty"`
	Resources      map[string]string `json:"resources,omitempty"`
}

type SigNozWriter ¶ added in v0.9.260

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

SigNozWriter implements io.Writer to send logs to SigNoz /logs/json endpoint

func (*SigNozWriter) Write ¶ added in v0.9.260

func (sw *SigNozWriter) Write(p []byte) (n int, err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL