logger

Apr 11, 2018

Changes in this version

+ const MaxRedisQueueSize

+ const MaxStreamRedisQueueSize

+ const StreamRedisQueueTTL

+ func ConfigureLogging(sink *transport.Sink)

+ func IsLoggable(defaults []uint16, msg *stream.Message) bool

+ type ConsoleLogger struct

+ func (logger *ConsoleLogger) LogRecord(record *LogRecord)

+ type LogRecord struct

+ Command string

+ Core uint16

+ Message *stream.Message

+ type Logger interface

+ LogRecord func(record *LogRecord)

+ func NewConsoleLogger(defaults []uint16) Logger

+ func NewLedisLogger(sink *transport.Sink, defaults []uint16, size int64) Logger

+ func NewStreamLogger(db *transport.Sink, size int64) Logger

+ type Loggers []Logger

+ var Current Loggers

+ func (l Loggers) LogRecord(record *LogRecord)

+ func (l Loggers) Message(cmd *pm.Command, msg *stream.Message)