How to use tearDown method of logger Package

1package dugong2import (3	"bufio"4	"encoding/json"5	"io/ioutil"6	"os"7	"path/filepath"8	"runtime"9	"sync"10	"sync/atomic"11	"testing"12	log "github.com/Sirupsen/logrus"13)14const (15	fieldName  = "my_field"16	fieldValue = "my_value"17)18func TestFSHookInfo(t *testing.T) {19	logger, hook, wait, teardown := setupLogHook(t)20	defer teardown()21	logger.WithField(fieldName, fieldValue).Info("Info message")22	wait()23	checkLogFile(t, hook.infoPath, "info")24}25func TestFSHookWarn(t *testing.T) {26	logger, hook, wait, teardown := setupLogHook(t)27	defer teardown()28	logger.WithField(fieldName, fieldValue).Warn("Warn message")29	wait()30	checkLogFile(t, hook.infoPath, "warning")31	checkLogFile(t, hook.warnPath, "warning")32}33func TestFSHookError(t *testing.T) {34	logger, hook, wait, teardown := setupLogHook(t)35	defer teardown()36	logger.WithField(fieldName, fieldValue).Error("Error message")37	wait()38	checkLogFile(t, hook.infoPath, "error")39	checkLogFile(t, hook.warnPath, "error")40	checkLogFile(t, hook.errorPath, "error")41}42func TestFsHookInterleaved(t *testing.T) {43	logger, hook, wait, teardown := setupLogHook(t)44	defer teardown()45	logger.WithField("counter", 0).Info("message")46	logger.WithField("counter", 1).Warn("message")47	logger.WithField("counter", 2).Error("message")48	logger.WithField("counter", 3).Warn("message")49	logger.WithField("counter", 4).Info("message")50	wait()51	file, err := os.Open(hook.infoPath)52	if err != nil {53		t.Fatalf("Failed to open file: %v", err)54	}55	scanner := bufio.NewScanner(file)56	count := 057	for scanner.Scan() {58		data := make(map[string]interface{})59		if err := json.Unmarshal([]byte(scanner.Text()), &data); err != nil {60			t.Fatalf("Failed to parse JSON: %v", err)61		}62		dataCounter := int(data["counter"].(float64))63		if count != dataCounter {64			t.Fatalf("Counter: want %d got %d", count, dataCounter)65		}66		count++67	}68	if count != 5 {69		t.Fatalf("Lines: want 5 got %d", count)70	}71}72func TestFSHookMultiple(t *testing.T) {73	logger, hook, wait, teardown := setupLogHook(t)74	defer teardown()75	for i := 0; i < 100; i++ {76		logger.WithField("counter", i).Info("message")77	}78	wait()79	file, err := os.Open(hook.infoPath)80	if err != nil {81		t.Fatalf("Failed to open file: %v", err)82	}83	scanner := bufio.NewScanner(file)84	count := 085	for scanner.Scan() {86		data := make(map[string]interface{})87		if err := json.Unmarshal([]byte(scanner.Text()), &data); err != nil {88			t.Fatalf("Failed to parse JSON: %v", err)89		}90		dataCounter := int(data["counter"].(float64))91		if count != dataCounter {92			t.Fatalf("Counter: want %d got %d", count, dataCounter)93		}94		count++95	}96	if count != 100 {97		t.Fatalf("Lines: want 100 got %d", count)98	}99}100func TestFSHookConcurrent(t *testing.T) {101	logger, hook, wait, teardown := setupLogHook(t)102	defer teardown()103	var wg sync.WaitGroup104	for i := 0; i < 100; i++ {105		wg.Add(1)106		go func(counter int) {107			defer wg.Done()108			logger.WithField("counter", counter).Info("message")109		}(i)110	}111	wg.Wait()112	wait()113	file, err := os.Open(hook.infoPath)114	if err != nil {115		t.Fatalf("Failed to open file: %v", err)116	}117	scanner := bufio.NewScanner(file)118	count := 0119	for scanner.Scan() {120		data := make(map[string]interface{})121		if err := json.Unmarshal([]byte(scanner.Text()), &data); err != nil {122			t.Fatalf("Failed to parse JSON: %v", err)123		}124		count++125	}126	if count != 100 {127		t.Fatalf("Lines: want 100 got %d", count)128	}129}130func setupLogHook(t *testing.T) (logger *log.Logger, hook *fsHook, wait func(), teardown func()) {131	dir, err := ioutil.TempDir("", "TestFSHook")132	if err != nil {133		t.Fatalf("Failed to make temporary directory: %v", err)134	}135	infoPath := filepath.Join(dir, "info.log")136	warnPath := filepath.Join(dir, "warn.log")137	errorPath := filepath.Join(dir, "error.log")138	hook = NewFSHook(infoPath, warnPath, errorPath).(*fsHook)139	logger = log.New()140	logger.Hooks.Add(hook)141	wait = func() {142		for atomic.LoadInt32(&hook.queueSize) != 0 {143			runtime.Gosched()144		}145	}146	teardown = func() {147		os.RemoveAll(dir)148	}149	return150}151func checkLogFile(t *testing.T, path, expectedLevel string) {152	contents, err := ioutil.ReadFile(path)153	if err != nil {154		t.Fatalf("Failed to read file: %v", err)155	}156	data := make(map[string]interface{})157	if err := json.Unmarshal(contents, &data); err != nil {158		t.Fatalf("Failed to parse JSON: %v", err)159	}160	if data["level"] != expectedLevel {161		t.Fatalf("level: want %q got %q", expectedLevel, data["level"])162	}163	if data[fieldName] != fieldValue {164		t.Fatalf("%s: want %q got %q", fieldName, fieldValue, data[fieldName])165	}166}...

1// Package testutil contains miscellaneous testing utilities.2package testutil3import (4	"context"5	"fmt"6	"io/ioutil"7	"net/http"8	"net/http/httputil"9	"path/filepath"10	"testing"11	"go.uber.org/zap" // Logging.12	"go.uber.org/zap/zaptest"13	gock "gopkg.in/h2non/gock.v1" // HTTP request mocking.14)15// TestLogger returns a zap Logger that logs all messages to the given testing.TB.16// It replaces the zap global Logger and redirects the stdlib log to the test Logger.17func TestLogger(t *testing.T) (logger *zap.Logger, teardown func()) {18	logger = zaptest.NewLogger(t)19	teardownLogger1 := zap.ReplaceGlobals(logger)20	teardownLogger2 := zap.RedirectStdLog(logger)21	teardown = func() {22		teardownLogger2()23		teardownLogger1()24		_ = logger.Sync()25	}26	return27}28// GockLogObserver returns a gock.ObserverFunc that logs HTTP requests to a zap Logger.29func GockLogObserver(logger *zap.Logger) gock.ObserverFunc {30	return func(request *http.Request, mock gock.Mock) {31		bytes, _ := httputil.DumpRequestOut(request, true)32		logger.Debug("gock intercepted http request",33			zap.String("request", string(bytes)),34			zap.Bool("matches_mock", mock != nil),35		)36	}37}38// LoadTestData is a helper to load test data from a `testdata` directory relaive to the CWD.39func LoadTestData(name string) string {40	path := filepath.Join("testdata", name) // relative path41	data, err := ioutil.ReadFile(path)42	if err != nil {43		panic(fmt.Sprintf("failed to load test data file %s: %s", name, err))44	}45	return string(data)46}47// ClientTestSetup sets up zap test logging, intercepts HTTP requests using gock, and creates48// a context with the zap logger embedded.49func ClientTestSetup(t *testing.T) (ctx context.Context, logger *zap.Logger, teardown func()) {50	logger, teardownLogging := TestLogger(t)51	gock.Intercept()52	gock.Observe(GockLogObserver(logger))53	ctx, cancel := context.WithCancel(context.Background())54	teardown = func() {55		cancel()56		gock.OffAll()57		gock.Observe(nil)58		teardownLogging()59	}60	return61}...

1// Copyright © 2019 The Homeport Team2//3// Permission is hereby granted, free of charge, to any person obtaining a copy4// of this software and associated documentation files (the "Software"), to deal5// in the Software without restriction, including without limitation the rights6// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell7// copies of the Software, and to permit persons to whom the Software is8// furnished to do so, subject to the following conditions:9//10// The above copyright notice and this permission notice shall be included in11// all copies or substantial portions of the Software.12//13// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR14// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,15// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE16// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER17// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,18// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN19// THE SOFTWARE.20package services21import (22	"github.com/homeport/watchful/pkg/cfw"23	"github.com/homeport/watchful/pkg/logger"24)25// TeardownService tears down the cf test instance26type TeardownService struct {27	WatchfulLogger logger.Logger28	Worker         cfw.CloudFoundryWorker29}30// NewTeardownService creates a new teardown task31func NewTeardownService(watchfulLogger logger.Logger, worker cfw.CloudFoundryWorker) *TeardownService {32	return &TeardownService{WatchfulLogger: watchfulLogger, Worker: worker}33}34// Execute executes a teardown35func (e *TeardownService) Execute() error {36	e.WatchfulLogger.WriteString(logger.Info, "Tearing down test environment")37	if err := e.Worker.TeardownTestEnvironment(); err != nil {38		e.WatchfulLogger.WriteString(logger.Error, "Could not teardown test environment")39		return err40	}41	return nil42}...

1logger.tearDown();2logger.tearDown();3logger.tearDown();4logger.tearDown();5logger.tearDown();6logger.tearDown();7logger.tearDown();8logger.tearDown();9logger.tearDown();10logger.tearDown();11logger.tearDown();12logger.tearDown();13logger.tearDown();14logger.tearDown();15logger.tearDown();16logger.tearDown();17logger.tearDown();18logger.tearDown();19logger.tearDown();20logger.tearDown();21logger.tearDown();22logger.tearDown();23logger.tearDown();24logger.tearDown();

1logger.tearDown();2logger.tearDown();3logger.tearDown();4logger.tearDown();5logger.tearDown();6logger.tearDown();7logger.tearDown();8logger.tearDown();9logger.tearDown();10logger.tearDown();11logger.tearDown();12logger.tearDown();13logger.tearDown();14logger.tearDown();15logger.tearDown();16logger.tearDown();17logger.tearDown();18logger.tearDown();19logger.tearDown();20logger.tearDown();21logger.tearDown();22logger.tearDown();23logger.tearDown();24logger.tearDown();25logger.tearDown();26logger.tearDown();27logger.tearDown();28logger.tearDown();29logger.tearDown();

1import "fmt"2import "log"3import "os"4func main() {5    f, err := os.OpenFile("test.log", os.O_RDWR | os.O_CREATE | os.O_APPEND, 0666)6    if err != nil {7        fmt.Printf("error opening file: %v", err)8        os.Exit(1)9    }10    defer f.Close()11    log.SetOutput(f)12    log.Println("This is a test

1import (2func main() {3	logger := logger.NewLogger("test.log")4	logger.Log("Hello World!")5	fmt.Println("Hello World!")6	logger.TearDown()7}8import (9func main() {10	logger := logger.NewLogger("test.log")11	logger.Log("Hello World!")12	fmt.Println("Hello World!")13	logger.TearDown()14}15import (16func main() {17	logger := logger.NewLogger("test.log")18	logger.Log("Hello World!")19	fmt.Println("Hello World!")20	logger.TearDown()21}22import (23func main() {24	logger := logger.NewLogger("test.log")25	logger.Log("Hello World!")26	fmt.Println("Hello World!")27	logger.TearDown()28}29import (30func main() {31	logger := logger.NewLogger("test.log")32	logger.Log("Hello World!")33	fmt.Println("Hello World!")34	logger.TearDown()35}36import (37func main() {38	logger := logger.NewLogger("test.log")39	logger.Log("Hello World!")40	fmt.Println("Hello World!")41	logger.TearDown()42}43import (44func main() {45	logger := logger.NewLogger("test.log")46	logger.Log("Hello World!")47	fmt.Println("Hello World!")48	logger.TearDown()49}50import (51func main() {52	logger := logger.NewLogger("test.log")53	logger.Log("Hello World!")54	fmt.Println("Hello World!")55	logger.TearDown()56}57import (

1func main() {2    logger := NewLogger()3    defer logger.tearDown()4    logger.Log("Hello World")5}6func main() {7    logger := NewLogger()8    defer logger.tearDown()9    logger.Log("Hello World")10}11func main() {12    logger := NewLogger()13    defer logger.tearDown()14    logger.Log("Hello World")15}16func main() {17    logger := NewLogger()18    defer logger.tearDown()19    logger.Log("Hello World")20}21func main() {22    logger := NewLogger()23    defer logger.tearDown()24    logger.Log("Hello World")25}26func main() {27    logger := NewLogger()28    defer logger.tearDown()29    logger.Log("Hello World")30}31func main() {32    logger := NewLogger()33    defer logger.tearDown()34    logger.Log("Hello World")35}36func main() {37    logger := NewLogger()38    defer logger.tearDown()39    logger.Log("Hello World")40}41func main() {42    logger := NewLogger()43    defer logger.tearDown()44    logger.Log("Hello World")45}46func main() {47    logger := NewLogger()48    defer logger.tearDown()49    logger.Log("Hello World")50}

1import (2func main() {3    log.Println("starting the program")4    log.Println("Ending the program")5}6log.SetOutput(file)

1func main() {2    logger := log.NewLogger(log.INFO)3    logger.Info("Hello World")4    logger.Close()5}6The Close() method is used to close the file object and flush the buffer. The Close() method is used to close the file object and