logging

package
v1.28.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 17, 2021 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DDLLogerType      = "ddl-debug"
	QueriesLoggerType = "sql-debug"
)

Variables

View Source 
var ConfigErr string
View Source 
var ConfigWarn string
View Source 
var GlobalLogsWriter io.Writer
View Source 
var LogLevel = UNKNOWN
View Source 
var TokenIdExtractRegexp = regexp.MustCompile("incoming.tok=(.*)-\\d\\d\\d\\d-\\d\\d-\\d\\dT")

regex for reading already rotated and closed log files

Functions

func CreateLogWriter added in v0.0.22 

func CreateLogWriter(config *Config) io.Writer

func Debug 

func Debug(v ...interface{})

func Debugf 

func Debugf(format string, v ...interface{})

func Error 

func Error(v ...interface{})

func Errorf 

func Errorf(format string, v ...interface{})

func Fatal 

func Fatal(v ...interface{})

func Fatalf 

func Fatalf(format string, v ...interface{})

func Info 

func Info(v ...interface{})

func Infof 

func Infof(format string, v ...interface{})

func InitGlobalLogger 

func InitGlobalLogger(writer io.Writer, levelStr string) error

Initialize main logger

func InitInMemoryWriter 

func InitInMemoryWriter() io.WriteCloser

func IsDirWritable 

func IsDirWritable(dir string) bool

func NewRollingWriter 

func NewRollingWriter(config *Config) io.WriteCloser

func SystemError 

func SystemError(v ...interface{})

func SystemErrorf 

func SystemErrorf(format string, v ...interface{})

func Warn 

func Warn(v ...interface{})

func Warnf 

func Warnf(format string, v ...interface{})

Types

type AsyncLogger 

type AsyncLogger struct {
	// contains filtered or unexported fields
}

AsyncLogger write json logs to file system in different goroutine

func NewAsyncLogger 

func NewAsyncLogger(writer io.WriteCloser, showInGlobalLogger bool) *AsyncLogger

Create AsyncLogger and run goroutine that's read from channel and write to file

func (*AsyncLogger) Close 

func (al *AsyncLogger) Close() (resultErr error)

Close underlying log file writer

func (*AsyncLogger) Consume 

func (al *AsyncLogger) Consume(event map[string]interface{}, tokenId string)

Consume event event and put it to channel

func (*AsyncLogger) ConsumeAny 

func (al *AsyncLogger) ConsumeAny(object interface{})

ConsumeAny put interface{} to the channel

type Config 

type Config struct {
	FileName    string
	FileDir     string
	RotationMin int64
	MaxBackups  int
	Compress    bool

	RotateOnClose bool
}

func (Config) Validate 

func (c Config) Validate() error

type DateTimeWriterProxy 

type DateTimeWriterProxy struct {
	// contains filtered or unexported fields
}

func (DateTimeWriterProxy) Write 

func (wp DateTimeWriterProxy) Write(bytes []byte) (int, error)

type Dual 

type Dual struct {
	FileWriter io.Writer
	Stdout     io.Writer
}

Dual write logs into fileWriter and into stdout as well

func (Dual) Write 

func (wp Dual) Write(bytes []byte) (int, error)

type Factory 

type Factory struct {
	// contains filtered or unexported fields
}

func NewFactory 

func NewFactory(logEventPath string, logRotationMin int64, showInServer bool, ddlLogsWriter io.Writer, queryLogsWriter io.Writer) *Factory

func (*Factory) CreateFailedLogger 

func (f *Factory) CreateFailedLogger(destinationName string) *AsyncLogger

func (*Factory) CreateIncomingLogger 

func (f *Factory) CreateIncomingLogger(tokenId string) *AsyncLogger

func (*Factory) CreateSQLQueryLogger 

func (f *Factory) CreateSQLQueryLogger(destinationName string) *QueryLogger

func (*Factory) CreateStreamingArchiveLogger 

func (f *Factory) CreateStreamingArchiveLogger(destinationName string) *AsyncLogger

func (*Factory) NewFactoryWithDDLLogsWriter added in v0.0.22 

func (f *Factory) NewFactoryWithDDLLogsWriter(overriddenDDLLogsWriter io.Writer) *Factory

NewFactory return a new factory instance with overridden DDL debug logs writer

func (*Factory) NewFactoryWithQueryLogsWriter added in v0.0.22 

func (f *Factory) NewFactoryWithQueryLogsWriter(overriddenQueryLogsWriter io.Writer) *Factory

NewFactory return a new factory instance with overridden sql query debug logs writer

type Level 

type Level int
const (
	UNKNOWN Level = iota
	DEBUG
	INFO
	WARN
	ERROR
	FATAL
)

func ToLevel 

func ToLevel(levelStr string) Level

func (Level) String 

func (l Level) String() string

type LoggerConfig added in v0.0.22 

type LoggerConfig struct {
	Path        string `mapstructure:"path" json:"path,omitempty" yaml:"path,omitempty"`
	RotationMin int64  `mapstructure:"rotation_min" json:"rotation_min,omitempty" yaml:"rotation_min,omitempty"`
	MaxBackups  int    `mapstructure:"max_backups" json:"max_backups,omitempty" yaml:"max_backups,omitempty"`
}

type QueryLogger 

type QueryLogger struct {
	// contains filtered or unexported fields
}

func NewQueryLogger 

func NewQueryLogger(identifier string, ddlWriter io.Writer, queryWriter io.Writer) *QueryLogger

func (*QueryLogger) LogDDL 

func (l *QueryLogger) LogDDL(query string)

func (*QueryLogger) LogQuery 

func (l *QueryLogger) LogQuery(query string)

func (*QueryLogger) LogQueryWithValues 

func (l *QueryLogger) LogQueryWithValues(query string, values []interface{})

type RollingWriterProxy 

type RollingWriterProxy struct {
	// contains filtered or unexported fields
}

RollingWriterProxy for lumberjack.Logger Rotate() only if file isn't empty

func (*RollingWriterProxy) Close 

func (rwp *RollingWriterProxy) Close() error

func (*RollingWriterProxy) Write 

func (rwp *RollingWriterProxy) Write(p []byte) (int, error)

type SQLDebugConfig added in v0.0.22 

type SQLDebugConfig struct {
	DDL     *LoggerConfig `mapstructure:"ddl" json:"ddl,omitempty" yaml:"ddl,omitempty"`
	Queries *LoggerConfig `mapstructure:"queries" json:"queries,omitempty" yaml:"queries,omitempty"`
}

type StringWriter 

type StringWriter struct {
	// contains filtered or unexported fields
}

func NewStringWriter 

func NewStringWriter() *StringWriter

func (*StringWriter) Close 

func (sw *StringWriter) Close() error

func (*StringWriter) String 

func (sw *StringWriter) String() string

func (*StringWriter) Write 

func (sw *StringWriter) Write(p []byte) (n int, err error)

type SyncLogger 

type SyncLogger struct {
	// contains filtered or unexported fields
}

SyncLogger write logs to file system synchronously

func NewSyncLogger 

func NewSyncLogger(writer io.WriteCloser) *SyncLogger

Create SyncLogger

func (*SyncLogger) Close 

func (sl *SyncLogger) Close() (resultErr error)

Close underlying log file writer

func (*SyncLogger) Error 

func (sl *SyncLogger) Error(v ...interface{})

func (*SyncLogger) Errorf 

func (sl *SyncLogger) Errorf(format string, v ...interface{})

func (*SyncLogger) Info 

func (sl *SyncLogger) Info(v ...interface{})

func (*SyncLogger) Infof 

func (sl *SyncLogger) Infof(format string, v ...interface{})

func (*SyncLogger) Warn 

func (sl *SyncLogger) Warn(v ...interface{})

func (*SyncLogger) Warnf 

func (sl *SyncLogger) Warnf(format string, v ...interface{})

type WriterMock 

type WriterMock struct {
	Data [][]byte
}
var InstanceMock *WriterMock

func (*WriterMock) Close 

func (im *WriterMock) Close() (err error)

func (*WriterMock) Write 

func (im *WriterMock) Write(dataToWrite []byte) (n int, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.