Gecko [ www.smanegeri1koba.sch.id ]

Name	Size	Permission
.github	[ DIR ]	dr-xr-xr-x
level	[ DIR ]	dr-xr-xr-x
syslog	[ DIR ]	dr-xr-xr-x
term	[ DIR ]	dr-xr-xr-x
.gitignore	269 B	-r--r--r--
LICENSE	1.04 KB	-r--r--r--
README.md	5.19 KB	-r--r--r--
benchmark_test.go	443 B	-r--r--r--
concurrency_test.go	653 B	-r--r--r--
doc.go	5.23 KB	-r--r--r--
example_test.go	2.71 KB	-r--r--r--
go.mod	82 B	-r--r--r--
go.sum	173 B	-r--r--r--
json_logger.go	2.03 KB	-r--r--r--
json_logger_test.go	4.61 KB	-r--r--r--
log.go	6.32 KB	-r--r--r--
log_test.go	8.65 KB	-r--r--r--
logfmt_logger.go	1.34 KB	-r--r--r--
logfmt_logger_test.go	1.38 KB	-r--r--r--
nop_logger.go	206 B	-r--r--r--
nop_logger_test.go	502 B	-r--r--r--
staticcheck.conf	17 B	-r--r--r--
stdlib.go	4.16 KB	-r--r--r--
stdlib_test.go	9.26 KB	-r--r--r--
sync.go	3.18 KB	-r--r--r--
sync_test.go	1.99 KB	-r--r--r--
value.go	3.33 KB	-r--r--r--
value_test.go	3.84 KB	-r--r--r--

Code Editor : sync_test.go

package log_test

import (
	"bytes"
	"io"
	"os"
	"testing"

"github.com/go-kit/log"
)

func TestSwapLogger(t *testing.T) {
	t.Parallel()
	var logger log.SwapLogger

// Zero value does not panic or error.
	err := logger.Log("k", "v")
	if got, want := err, error(nil); got != want {
		t.Errorf("got %v, want %v", got, want)
	}

buf := &bytes.Buffer{}
	json := log.NewJSONLogger(buf)
	logger.Swap(json)

if err := logger.Log("k", "v"); err != nil {
		t.Error(err)
	}
	if got, want := buf.String(), `{"k":"v"}`+"\n"; got != want {
		t.Errorf("got %v, want %v", got, want)
	}

buf.Reset()
	prefix := log.NewLogfmtLogger(buf)
	logger.Swap(prefix)

if err := logger.Log("k", "v"); err != nil {
		t.Error(err)
	}
	if got, want := buf.String(), "k=v\n"; got != want {
		t.Errorf("got %v, want %v", got, want)
	}

buf.Reset()
	logger.Swap(nil)

if err := logger.Log("k", "v"); err != nil {
		t.Error(err)
	}
	if got, want := buf.String(), ""; got != want {
		t.Errorf("got %v, want %v", got, want)
	}
}

func TestSwapLoggerConcurrency(t *testing.T) {
	t.Parallel()
	testConcurrency(t, &log.SwapLogger{}, 10000)
}

func TestSyncLoggerConcurrency(t *testing.T) {
	var w io.Writer //lint:ignore S1021 I prefer this
	w = &bytes.Buffer{}
	logger := log.NewLogfmtLogger(w)
	logger = log.NewSyncLogger(logger)
	testConcurrency(t, logger, 10000)
}

func TestSyncWriterConcurrency(t *testing.T) {
	var w io.Writer
	w = &bytes.Buffer{}
	w = log.NewSyncWriter(w)
	testConcurrency(t, log.NewLogfmtLogger(w), 10000)
}

func TestSyncWriterFd(t *testing.T) {
	_, ok := log.NewSyncWriter(os.Stdout).(interface {
		Fd() uintptr
	})

if !ok {
		t.Error("NewSyncWriter does not pass through Fd method")
	}
}

func TestSyncLoggerPanic(t *testing.T) {
	var logger log.Logger
	logger = log.LoggerFunc(func(...interface{}) error { panic("!") })
	logger = log.NewSyncLogger(logger)

f := func() {
		defer func() {
			if x := recover(); x != nil {
				t.Log(x)
			}
		}()
		logger.Log("hello", "world")
	}

f()
	f() // without defer Unlock, this one can deadlock
}

${this.title}

Code Editor : sync_test.go