pulsarzap

README

pulsarzap

zap logger wrapper for pulsar Logger

Usage

import "github.com/ttys3/pulsarzap"

simple usage

client, err := pulsar.NewClient(pulsar.ClientOptions{
    URL:               "pulsar://pulsar-broker.service.dc1.consul:6650",
    Logger:            pulsarzap.NewDefault(),
})

use custom zap logger config

lc := zap.NewDevelopmentConfig()
lc.Level = zap.NewAtomicLevelAt(zap.DebugLevel)
lc.DisableStacktrace = true
lc.Encoding = "console"
lc.EncoderConfig.EncodeLevel = zapcore.CapitalColorLevelEncoder
logger, _ := lc.Build(zap.WithCaller(true))
log := pulsarzap.New(logger.Sugar())

client, err := pulsar.NewClient(pulsar.ClientOptions{
    URL:               "pulsar://pulsar-broker.service.dc1.consul:6650",
    Logger:            log,
})

Documentation

Index

• func New(lgr *zap.SugaredLogger) log.Logger
• func NewDefault() log.Logger

Functions

func New

func New(lgr *zap.SugaredLogger) log.Logger

func NewDefault

func NewDefault() log.Logger