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 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 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)