Skip to content
Snippets Groups Projects
Commit 7c2bea66 authored by ko_oler's avatar ko_oler
Browse files

revert лишних изменений

parent ca72ec35
Branches
Tags
No related merge requests found
......@@ -24,10 +24,10 @@ func TestBufferedWriteSyncer_Write(t *testing.T) {
ws := &BufferedWriteSyncer{Service: service}
err := ws.Write(&logs.Entry{Message: "first logs message"})
err := ws.Write(&logs.Entry{Message: "first log message"})
require.NoError(t, err)
err = ws.Write(&logs.Entry{Message: "second logs message"})
err = ws.Write(&logs.Entry{Message: "second log message"})
require.NoError(t, err)
err = ws.Stop()
......@@ -53,7 +53,7 @@ func TestBufferedWriteSyncer_Write_Concurrent(t *testing.T) {
wg.Add(1)
go func(wg *sync.WaitGroup) {
defer wg.Done()
require.NoError(t, ws.Write(&logs.Entry{Message: "logs message"}))
require.NoError(t, ws.Write(&logs.Entry{Message: "log message"}))
}(&wg)
}
......@@ -77,7 +77,7 @@ func TestBufferedWriteSyncer_Flush(t *testing.T) {
for i := 0; i < 10; i++ {
for j := 0; j < 10; j++ {
require.NoError(t, ws.Write(&logs.Entry{Message: "logs message"}))
require.NoError(t, ws.Write(&logs.Entry{Message: "log message"}))
}
require.NoError(t, ws.Sync())
}
......@@ -100,7 +100,7 @@ func TestBufferedWriteSyncer_MaxBufferSize(t *testing.T) {
ws := &BufferedWriteSyncer{Service: service, MaxBufferSize: 10}
for i := 0; i < 100; i++ {
require.NoError(t, ws.Write(&logs.Entry{Message: "logs message"}))
require.NoError(t, ws.Write(&logs.Entry{Message: "log message"}))
}
require.NoError(t, ws.Stop())
......@@ -121,7 +121,7 @@ func TestBufferedWriteSyncer_FlushInterval(t *testing.T) {
ws := &BufferedWriteSyncer{Service: service, FlushInterval: time.Second}
for j := 0; j < 10; j++ {
require.NoError(t, ws.Write(&logs.Entry{Message: "logs message"}))
require.NoError(t, ws.Write(&logs.Entry{Message: "log message"}))
}
time.Sleep(3 * time.Second) // ждем, пока сработает интервал
......
// Code generated by gowrap. DO NOT EDIT.
// template: ../../../assets/templates/middleware/logs.tmpl
// template: ../../../assets/templates/middleware/log.tmpl
// gowrap: http://github.com/hexdigest/gowrap
package middleware
......
......@@ -67,8 +67,8 @@ type filterCore struct {
// core = WithFilters(core, ContainsField(zap.Int("a", 5)))
//
// logger := zap.New(core)
// logger.Info("Test logs") // НЕ будет записан
// logger.Info("Test logs", zap.Int("a", 5)) // будет записан
// logger.Info("Test log") // НЕ будет записан
// logger.Info("Test log", zap.Int("a", 5)) // будет записан
func WithFilters(core zapcore.Core, filters ...FilterFunc) zapcore.Core {
return &filterCore{
Core: core,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment