package main

import (
    "time"
    writer "github.com/zhengliu92/es-log-writer"
)

func main() {
    config := &writer.Config{
        Addresses:     []string{"http://localhost:9200"},
        IndexPrefix:   "app-logs",
        BufferSize:    100,
        FlushInterval: 5 * time.Second,
    }
    
    w, err := writer.NewElasticsearchWriter(config)
    if err != nil {
        panic(err)
    }
    defer w.Close()
    
    // 直接使用
    w.Info("用户登录成功")
    w.Error("数据库连接失败")
    w.Info("请求处理完成",
        writer.Field("duration", 50*time.Millisecond),
        writer.Field("trace", "abc123"),
        writer.Field("user_id", 12345),
    )
}

package main

import (
    "time"
    writer "github.com/zhengliu92/es-log-writer"
)

func main() {
    config := &writer.Config{
        Addresses:     []string{"http://localhost:9200"},
        IndexPrefix:   "app-logs",
        BufferSize:    100,
        FlushInterval: 5 * time.Second,
    }
    
    // 创建 Elasticsearch Writer
    esWriter, err := writer.NewElasticsearchWriter(config)
    if err != nil {
        panic(err)
    }
    defer esWriter.Close()
    
    // 创建控制台 Writer
    consoleWriter := writer.NewConsoleWriter()
    
    // 创建多路复用 Writer，同时输出到控制台和 Elasticsearch
    w := writer.NewMultiWriter(consoleWriter, esWriter)
    defer w.Close()
    
    // 日志会同时输出到控制台和 Elasticsearch
    w.Info("用户登录成功")
    w.Error("数据库连接失败")
    w.Info("请求处理完成",
        writer.Field("duration", 50*time.Millisecond),
        writer.Field("trace", "abc123"),
        writer.Field("user_id", 12345),
    )
}

package main

import (
    "time"
    "github.com/zeromicro/go-zero/core/logx"
    writer "github.com/zhengliu92/es-log-writer"
    logxadapter "github.com/zhengliu92/es-log-writer/logx"  // 适配器
)

func main() {
    config := &writer.Config{
        Addresses:     []string{"http://localhost:9200"},
        IndexPrefix:   "go-zero-logs",
        BufferSize:    100,
        FlushInterval: 5 * time.Second,
    }
    
    // 创建 logx 适配器
    adapter, err := logxadapter.NewEsAdapter(config)
    if err != nil {
        panic(err)
    }
    defer adapter.Close()
    
    // 设置 logx 使用 Elasticsearch Writer
    logx.SetWriter(adapter)
    
    // 正常使用 logx
    logx.Info("日志内容")
    logx.Infow("带字段的日志",
        logx.Field("trace", "abc123"),
        logx.Field("duration", 20*time.Millisecond),
    )
}

package main

import (
    "time"
    "github.com/zeromicro/go-zero/core/logx"
    writer "github.com/zhengliu92/es-log-writer"
    logxadapter "github.com/zhengliu92/es-log-writer/logx"
)

func main() {
    config := &writer.Config{
        Addresses:     []string{"http://localhost:9200"},
        IndexPrefix:   "go-zero-logs",
        BufferSize:    100,
        FlushInterval: 5 * time.Second,
    }
    
    // 创建 Elasticsearch 适配器
    adapter, err := logxadapter.NewEsAdapter(config)
    if err != nil {
        panic(err)
    }
    defer adapter.Close()
    
    // 创建控制台 Writer
    consoleWriter := logxadapter.NewConsoleWriter()
    
    // 创建多路复用 Writer，同时写入控制台和 Elasticsearch
    multiWriter := logxadapter.NewMultiWriter(consoleWriter, adapter)
    
    // 设置 logx 使用多路复用 Writer
    logx.SetWriter(multiWriter)
    
    // 日志会同时输出到控制台和 Elasticsearch
    logx.Info("这条日志会同时出现在控制台和 ES")
    logx.Infow("带字段的日志",
        logx.Field("trace", "abc123"),
        logx.Field("duration", 20*time.Millisecond),
    )
}

type Writer interface {
    Info(content any, fields ...LogField)
    Error(content any, fields ...LogField)
    Debug(content any, fields ...LogField)
    Warn(content any, fields ...LogField)
    Log(level string, content any, fields ...LogField)
    Close() error
}

// 创建 Elasticsearch 写入器
esWriter, err := writer.NewElasticsearchWriter(config)

// 创建控制台写入器
consoleWriter := writer.NewConsoleWriter()

// 创建多路复用写入器（可组合多个 Writer）
multiWriter := writer.NewMultiWriter(consoleWriter, esWriter, ...)

// 基本日志方法
w.Info(content, fields...)
w.Error(content, fields...)
w.Debug(content, fields...)
w.Warn(content, fields...)

// 通用日志方法（可指定任意级别）
w.Log("custom", content, fields...)

// 创建字段
writer.Field("key", value)

// 特殊字段（会自动提取到对应位置）
writer.Field("trace", "trace-id")      // 提取到 LogEntry.Trace
writer.Field("span", "span-id")        // 提取到 LogEntry.Span
writer.Field("duration", time.Duration) // 提取到 LogEntry.Duration，自动格式化

// 检查 Elasticsearch 连接（仅 ElasticsearchWriter）
err := esWriter.Ping(ctx)

// 关闭 Writer（会刷新所有缓冲的日志）
err := w.Close()

// 创建 ES 适配器（实现 logx.Writer 接口）
adapter, err := logxadapter.NewEsAdapter(config)

// 创建控制台 Writer（实现 logx.Writer 接口）
consoleWriter := logxadapter.NewConsoleWriter()

// 创建多路复用 Writer（可组合多个 Writer）
multiWriter := logxadapter.NewMultiWriter(consoleWriter, adapter, ...)

// 设置 logx 使用适配器
logx.SetWriter(adapter)
// 或使用多路复用 Writer
logx.SetWriter(multiWriter)

// 基本方法
logx.Info(v, fields...)
logx.Error(v, fields...)
logx.Debug(v, fields...)

// go-zero 特有方法
logx.Slow(v, fields...)      // 慢日志
logx.Stat(v, fields...)       // 统计日志
logx.Stack(v)                 // 堆栈日志
logx.Alert(v)                 // 告警日志
logx.Severe(v)                // 严重错误日志

// 带字段的方法
logx.Infow("message", logx.Field("key", value), ...)
logx.Errorw("message", logx.Field("key", value), ...)

// 检查 ES 连接
err := adapter.Ping(ctx)

// 关闭适配器
err := adapter.Close()
multiWriter.Close()  // 会关闭所有包含的 Writer

consoleWriter := writer.NewConsoleWriter()
esWriter, _ := writer.NewElasticsearchWriter(config)
multiWriter := writer.NewMultiWriter(consoleWriter, esWriter)

config := &writer.Config{
    Addresses: []string{"https://your-es:9200"},
    APIKey:    "your-api-key",  // 或使用 Username/Password
}