bitbucket.org/ROKT/logrus_hooks

logrus_hooks

Logrus Hooks

Firehose Hook

Usage

import (
    "bitbucket.org/ROKT/logrus_firehose"
    "github.com/sirupsen/logrus"
	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/aws/session"
)

func main() {
    awsSession, _ := session.NewSession(&aws.Config{HTTPClient: newHttpClient()})
    hook, err := logrus_firehose.New("my_stream", firehose.New(awsSession))

    // set custom fire level
    hook.SetLevels([]logrus.Level{
        logrus.PanicLevel,
        logrus.ErrorLevel,
    })
    
    // send log with logrus
    logger := logrus.New()
    logger.Hooks.Add(hook)
    logger.WithFields(f).Error("my_message") // send log data to firehose as JSON
}