writer

ExampleAsyncDiodeWriter 示例代码

// 创建Test配置
cfg := appconfig.NewAppConfig()
testConfig := map[string]interface{}{
	"application.appLog.rollConf.maxSize":               10,
	"application.appLog.rollConf.maxBackups":            3,
	"application.appLog.rollConf.maxAge":                7,
	"application.appLog.rollConf.compress":              false,
	"application.appLog.asyncConf.diodes.size":          1000000,
	"application.appLog.asyncConf.diodes.bufferSize":    4096,
	"application.appLog.asyncConf.diodes.flushInterval": 50,
}
cfg.LoadDefault(testConfig)

// 创建异步写入器
writer := NewAsyncDiodeWriter(cfg, "example.log")
defer func() {
	if err := writer.Close(); err != nil {
		// 处理关闭错误
	}
}()

// 写入日志
if _, err := writer.Write([]byte("Hello, World!\n")); err != nil {
	// 处理写入错误
}
if _, err := writer.Write([]byte("This is an example log message\n")); err != nil {
	// 处理写入错误
}

// 等待写入完成
time.Sleep(100 * time.Millisecond) // 大于application.appLog.asyncConf.diodes.flushInterval配置项