db

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

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

type DialFunc func(string) gorm.Dialector

type EsDatabase interface {
	// Get return client,version,error
	Get(name string) (*elastic.Client, string, error)
	Do(name string, call func(es *elastic.Client, version string) error) error
	Close(name string) error
	CloseAll()
	Select(name string)
	GetSelector() string
}

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

type ServerPubKeyFunc func(cnf *commontls.ServerPubKey) (*rsa.PublicKey, error)

type Sql interface {
	Db() *gorm.DB
	Name() string
	Version() string
	// CollectData 主要统计 Stats
	CollectData() (data.Model, error)
}

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

type Stats struct {
	MaxOpenConnections int           `json:"maxOpenConnections"` //最大打开连接数
	OpenConnections    int           `json:"openConnections"`    // 连接数，The number of established connections both in use and idle.
	InUse              int           `json:"inUse"`              // 正在使用数，The number of connections currently in use.
	Idle               int           `json:"idle"`               // 当前空闲连接数
	WaitCount          int64         `json:"waitCount"`          // The total number of connections waited for.
	WaitDuration       time.Duration `json:"waitDuration"`       // The total time blocked waiting for a new connection.
	MaxIdleClosed      int64         `json:"maxIdleClosed"`      // The total number of connections closed due to SetMaxIdleConns.
	MaxIdleTimeClosed  int64         `json:"maxIdleTimeClosed"`  // The total number of connections closed due to SetConnMaxIdleTime.
	MaxLifetimeClosed  int64         `json:"maxLifetimeClosed"`  // 连接被关闭的次数（因达到最大存活时间）The total number of connections closed due to SetConnMaxLifetime.
}