go logstash

go-logstash

로그를 Logstash에 직접 푸시하는 Go로 작성된 Logstash 로거입니다. JSON 형식과 문자열 형식으로 Logstash에 출력 쓰기를 지원합니다.

특징

• Logstash에 로그를 전송하기 위해 TCP 및 UDP 프로토콜을 지원합니다.
• 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. 새로운 Pull Request를 생성하세요.