go logstash

go-logstash

Logstash Logger, написанный на Go, который отправляет журналы непосредственно в Logstash. Он поддерживает запись результатов в Logstash в формате JSON, а также в формате String.

Функции

• Поддерживает протоколы TCP и UDP для отправки журналов в Logstash.
• Поддерживает запись журналов как в формате JSON, так и в строковом формате.
• Предоставляет настраиваемые параметры для настройки соединения Logstash.

Начиная

1. Установите пакет, используя:

 go get github.com/KaranJagtiani/go-logstash

2. Импортируйте пакет в приложение Go:

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

3. Инициализируйте экземпляр logstash_logger , указав данные вашего сервера Logstash и тип подключения:

 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. Создайте новый запрос на включение.