Documentation ¶
Index ¶
Constants ¶
View Source
const (
KafkaLoggingChannel = "stream.kafka"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaLogger ¶
func NewKafkaLogger ¶
func NewKafkaLogger(logger log.Logger) *KafkaLogger
func (*KafkaLogger) DebugLogger ¶
func (l *KafkaLogger) DebugLogger() LoggerWrapper
func (*KafkaLogger) ErrorLogger ¶
func (l *KafkaLogger) ErrorLogger() LoggerWrapper
type LoggerWrapper ¶
type LoggerWrapper func(template string, values ...interface{})
func (LoggerWrapper) Printf ¶
func (log LoggerWrapper) Printf(t string, v ...interface{})
Click to show internal directories.
Click to hide internal directories.