sql

Documentation

Index

• type Dao
  • func (Dao) TableName() string
• type ExecCloser
  • func NewExec(client *gorm.DB, loggerTableName string) ExecCloser
  • func NewExecWithURL(client *gorm.DB, loggerTableName string) ExecCloser
• type Hook
  • func Default(client *gorm.DB, tableName string, opts ...Option) *Hook
  • func DefaultWithURL(client *gorm.DB, tableName string, opts ...Option) *Hook
  • func New(opt ...Option) *Hook
  • func (h *Hook) Fire(entryLogrus *logrus.Entry) error
  • func (h *Hook) Flush()
  • func (h *Hook) Levels() []logrus.Level
• type Option
  • func SetExec(exec ExecCloser) Option
  • func SetExtra(extra map[string]any) Option
  • func SetLevels(levels ...logrus.Level) Option
  • func SetMaxQueues(maxQueues int) Option
  • func SetMaxWorkers(maxWorkers int) Option
  • func SetOut(out io.Writer) Option

Types

type Dao

type Dao struct {
	Id        *int64         `gorm:"primaryKey;autoIncrement;column:id" json:"id"`
	Host      null.String    `gorm:"column:host" json:"host"`
	Timestamp null.TimeStamp `gorm:"column:timestamp" json:"timestamp"`
	File      null.String    `gorm:"column:file" json:"file"`
	Func      null.String    `gorm:"column:func" json:"func"`
	Message   null.String    `gorm:"column:message" json:"message"`
	Level     null.String    `gorm:"column:level" json:"level"`
	Data      null.JSON      `gorm:"column:data" json:"data"`
}

func (Dao) TableName

func (Dao) TableName() string

表名重写为 tableName

type ExecCloser

type ExecCloser interface {
	Exec(entry *entry.Entry) error
}

ExecCloser 将logrus条目写入数据库并关闭数据库

func NewExec

func NewExec(client *gorm.DB, loggerTableName string) ExecCloser

NewExec create an exec instance

func NewExecWithURL

func NewExecWithURL(client *gorm.DB, loggerTableName string) ExecCloser

NewExecWithURL create an exec instance

type Hook

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

Hook 将日志发送到数据库

func Default

func Default(client *gorm.DB, tableName string, opts ...Option) *Hook

Default create a default mongo hook

func DefaultWithURL

func DefaultWithURL(client *gorm.DB, tableName string, opts ...Option) *Hook

DefaultWithURL create a default mongo hook

func New

func New(opt ...Option) *Hook

New 创建一个要添加到logger实例的钩子

func (*Hook) Fire

func (h *Hook) Fire(entryLogrus *logrus.Entry) error

Fire 触发日志事件时将调用

func (*Hook) Flush

func (h *Hook) Flush()

Flush 等待日志队列为空

func (*Hook) Levels

func (h *Hook) Levels() []logrus.Level

Levels 返回可用的日志记录级别

type Option

type Option func(*options)

Option 钩子参数选项

func SetExec

func SetExec(exec ExecCloser) Option

SetExec 设置Execer接口

func SetExtra

func SetExtra(extra map[string]any) Option

SetExtra 设置扩展参数

func SetLevels

func SetLevels(levels ...logrus.Level) Option

SetLevels 设置可用的日志级别

func SetMaxQueues

func SetMaxQueues(maxQueues int) Option

SetMaxQueues 设置缓冲区的数量

func SetMaxWorkers

func SetMaxWorkers(maxWorkers int) Option

SetMaxWorkers 设置工作线程数

func SetOut

func SetOut(out io.Writer) Option

SetOut 设置错误输出