logging

package

v0.9.244 Latest Latest Go to latest Published: May 28, 2025 License: AGPL-3.0 Imports: 17 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
func CloseLoggers()
func SetLevel(level string)
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(context string, id string, level zerolog.Level) *LogWriter
- func (w *LogWriter) Close() error
- func (w *LogWriter) Write(p []byte) (n int, err error)
type SigNozJsonWriter
- func NewSigNozJsonWriter(endpoint, token, serviceName string, otherResourceAttrs map[string]string, ...) *SigNozJsonWriter
- func (sw *SigNozJsonWriter) Close() error
- func (sw *SigNozJsonWriter) Write(p []byte) (n int, err error)
type SigNozLogEntry

Constants ¶

View Source

const (
	LOG_TIME_FORMAT = time.TimeOnly
	LOG_CALLER_SKIP = 3 // stack frame depth
)

View Source

const (
	DEFAULT_SERVICE_NAME           = "cedana"
	DEFAULT_MAX_BATCH_SIZE_JSON    = 100
	DEFAULT_FLUSH_INTERVAL_MS_JSON = 5000             // 5 seconds
	ZEROLOG_TIMESTAMP_FIELD_FORMAT = time.RFC3339Nano // zerolog's default format for With().Timestamp()
)

Variables ¶

This section is empty.

Functions ¶

func CloseLoggers ¶ added in v0.9.244

func CloseLoggers()

func SetLevel ¶

func SetLevel(level string)

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 {
	io.Writer
	// contains filtered or unexported fields
}

func Writer ¶

func Writer(context string, id string, 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 SigNozJsonWriter ¶ added in v0.9.244

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

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

func NewSigNozJsonWriter ¶ added in v0.9.244

func NewSigNozJsonWriter(endpoint, token, serviceName string, otherResourceAttrs map[string]string, maxBatchSize int, flushIntervalMs int) *SigNozJsonWriter

func (*SigNozJsonWriter) Close ¶ added in v0.9.244

func (sw *SigNozJsonWriter) Close() error

func (*SigNozJsonWriter) Write ¶ added in v0.9.244

func (sw *SigNozJsonWriter) 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"`
}

Source Files ¶

View all Source files

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