db

Documentation

Overview

*

• @author huqiuyun
• 数据Elasticsearch

*

• @author huqiuyun
• 数据服务

Index

• type Adapter
  • func NewAdapter(cfg *server.Sql) (*Adapter, error)
  • func (a *Adapter) Close()
  • func (a *Adapter) Db() *gorm.DB
  • func (a *Adapter) Name() string
• type ConditionCallback
• type EsDatabase
  • func NewES(cfg []server.Elastic) (EsDatabase, error)
• type Logger
  • func (l *Logger) Error(ctx context.Context, msg string, data ...interface{})
  • func (l *Logger) Info(ctx context.Context, msg string, data ...interface{})
  • func (l *Logger) LogMode(level gormLogger.LogLevel) gormLogger.Interface
  • func (l Logger) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error)
  • func (l *Logger) Warn(ctx context.Context, msg string, data ...interface{})
• type ScopesFunc
• type Sql
• type SqlDatabase
  • func NewDB(cfgs []server.Sql) (SqlDatabase, error)

Types

type Adapter

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

Adapter represents the Gorm adapter for policy storage.

func NewAdapter

func NewAdapter(cfg *server.Sql) (*Adapter, error)

NewAdapter is the constructor for Adapter.

func (*Adapter) Close

func (a *Adapter) Close()

func (*Adapter) Db

func (a *Adapter) Db() *gorm.DB

func (*Adapter) Name

func (a *Adapter) Name() string

type ConditionCallback

type ConditionCallback func(data interface{}, db *gorm.DB) *gorm.DB

type EsDatabase

type EsDatabase interface {
	Get(dbname string) (*elastic.Client, error)
	Do(name string, call func(es *elastic.Client) error) error
	Close(name string) error
	CloseAll()
	Select(name string)
}

func NewES

func NewES(cfg []server.Elastic) (EsDatabase, error)

type Logger

type Logger struct {
	LogLevel                  gormLogger.LogLevel
	SlowThreshold             time.Duration
	IgnoreRecordNotFoundError bool
}

func (*Logger) Error

func (l *Logger) Error(ctx context.Context, msg string, data ...interface{})

Error print error messages

func (*Logger) Info

func (l *Logger) Info(ctx context.Context, msg string, data ...interface{})

Info print info

func (*Logger) LogMode

func (l *Logger) LogMode(level gormLogger.LogLevel) gormLogger.Interface

LogMode log mode

func (Logger) Trace

func (l Logger) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error)

Trace print sql message

func (*Logger) Warn

func (l *Logger) Warn(ctx context.Context, msg string, data ...interface{})

Warn print warn messages

type ScopesFunc

type ScopesFunc func(db *gorm.DB) *gorm.DB

type Sql

type Sql interface {
	Db() *gorm.DB
	Name() string
}

type SqlDatabase

type SqlDatabase interface {
	Get(dbname string) (Sql, error)
	Do(dbname string, c func(db Sql) error) error
	Close(dbname string)
	CloseAll()
	Select(name string)
}

func NewDB

func NewDB(cfgs []server.Sql) (SqlDatabase, error)