From c97a3a69960acd5299511927c03e3c61e9d5667d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Vin=C3=ADcius=20Garcia?= Date: Fri, 14 Jul 2023 12:55:08 -0300 Subject: [PATCH] Improve some comments --- logger.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/logger.go b/logger.go index 6296d5d..0df561c 100644 --- a/logger.go +++ b/logger.go @@ -13,6 +13,11 @@ var _ LoggerFn = ErrorLogger // ErrorLogger is a builtin logger that can be passed to // ksql.InjectLogger() to only log when an error occurs. +// +// Note: Only errors that happen after KSQL sends the +// query to the backend adapter will be logged. +// +// Validation errors will just return an error as usual. func ErrorLogger(ctx context.Context, values LogValues) { if values.Err == nil { return @@ -25,6 +30,11 @@ var _ LoggerFn = Logger // Logger is a builtin logger that can be passed to // ksql.InjectLogger() to log every query and query errors. +// +// Note: Only errors that happen after KSQL sends the +// query to the backend adapter will be logged. +// +// Validation errors will just return an error as usual. func Logger(ctx context.Context, values LogValues) { m := map[string]interface{}{ "query": values.Query,