logger

Documentation

Index

• func GetLoggerEncoder(format string) zapcore.Encoder
• func GetLoggerWriter(logPath, suffix string) zapcore.WriteSyncer
• func NewLogger(logPath string) *zap.Logger
• type KafkaWriterSync
  • func NewKafkaWriterSync(producer *sarama.SyncProducer) *KafkaWriterSync
  • func (k KafkaWriterSync) Sync() error
  • func (k KafkaWriterSync) Write(p []byte) (n int, err error)

Functions

func GetLoggerEncoder

func GetLoggerEncoder(format string) zapcore.Encoder

获取 json 或者普通日志格式编码

func GetLoggerWriter

func GetLoggerWriter(logPath, suffix string) zapcore.WriteSyncer

获取日志写入对象

func NewLogger

func NewLogger(logPath string) *zap.Logger

Types

type KafkaWriterSync

type KafkaWriterSync struct {
	Topic string `json:"topic"`
	// contains filtered or unexported fields
}

func NewKafkaWriterSync

func NewKafkaWriterSync(producer *sarama.SyncProducer) *KafkaWriterSync

func (KafkaWriterSync) Sync

func (k KafkaWriterSync) Sync() error

func (KafkaWriterSync) Write

func (k KafkaWriterSync) Write(p []byte) (n int, err error)