go logstash

去logstash

Logstash Logger 用 Go 编写，将日志直接推送到 Logstash。它支持以 JSON 格式和字符串格式将输出写入 Logstash。

特征

• 支持 TCP 和 UDP 协议将日志发送到 Logstash。
• 支持JSON和字符串两种格式写入日志。
• 提供用于配置 Logstash 连接的可自定义选项。

入门

1. 使用以下命令安装软件包：

 go get github.com/KaranJagtiani/go-logstash

2. 将包导入到您的 Go 应用程序中：

 import "github.com/KaranJagtiani/go-logstash" 

3. 使用您的Logstash 服务器详细信息和连接类型初始化logstash_logger实例：

 logger := logstash_logger. Init ( "<host>" , < port > , "protocol" , < timeout > )

logstash_logger.Init()具有以下配置选项：

• 主机：Logstash 服务器主机名。
• 端口：Logstash 服务器端口号。
• 协议：Logstash 连接协议，“tcp”或“udp”。
• 超时：连接超时（以秒为单位）。

例子：

 logger := logstash_logger . Init ( "logstash" , 5228 , "udp" , 5 )

4. 使用提供的不同方法之一将日志发送到 Logstash：

 payload := map [ string ] interface {}{
		"message" : "test message" ,
		"error" :   false ,
}

// Generic - For logging the payload as it is
logger . Log ( payload )

// Adds a attribute called "severity": "INFO" to the payload
logger . Info ( payload )

// Adds a attribute called "severity": "DEBUG" to the payload
logger . Debug ( payload )

// Adds a attribute called "severity": "WARN" to the payload
logger . Warn ( payload )

// Adds a attribute called "severity": "ERROR" to the payload
logger . Error ( payload )

// For sending a string message to Logstash
logger . LogString ( "String Message" )

贡献

欢迎为 go-logstash 做出贡献！如果您发现错误或想要添加新功能，请在 GitHub 上创建问题或提交拉取请求。

提交请求请求

1. 分叉这个存储库。
2. 创建您的功能分支（git checkout -b my-new-feature）。
3. 提交您的更改（git commit -am '添加一些功能'）。
4. 推送到分支（git push origin my-new-feature）。
5. 创建一个新的拉取请求。