dao

Documentation

Index

• Constants
• type Dao
  • func (d *Dao) ClusterRedisClient() (*goredis.ClusterClient, error)
  • func (d *Dao) Condition(data interface{}, call db.ConditionCallback) result.Result
  • func (d *Dao) DBClient() (*gorm.DB, error)
  • func (d *Dao) ElasticClient() (*elastic.Client, error)
  • func (d *Dao) Expire(key string, time time.Duration)
  • func (d *Dao) ExpireAt(key string, time time.Time)
  • func (d *Dao) Get(key string) (string, error)
  • func (d *Dao) GetInt(key string) (int, error)
  • func (d *Dao) HDel(key, field string) (int64, error)
  • func (d *Dao) HGet(key, field string) (string, error)
  • func (d *Dao) HGetAll(key string) (map[string]string, error)
  • func (d *Dao) HGetInt(key, field string) (int, error)
  • func (d *Dao) HInc(key, field string, value int64) (int64, error)
  • func (d *Dao) HSet(key, field string, value interface{}) (int64, error)
  • func (d *Dao) HSetNX(key, field string, value interface{}) (bool, error)
  • func (d *Dao) Inc(key string, value int64) (int64, error)
  • func (d *Dao) IsNotFound(db *gorm.DB) int
  • func (d *Dao) RedisClient() (*goredis.Client, error)
  • func (d *Dao) ResetEsClient()
  • func (d *Dao) ResetRdsClient()
  • func (d *Dao) SentinelRedisClient() (*goredis.SentinelClient, error)
  • func (d *Dao) Set(key string, value interface{}, expiration time.Duration) (string, error)
  • func (d *Dao) SetEX(key string, value interface{}, expiration time.Duration) (string, error)
  • func (d *Dao) SetNX(key string, value interface{}, expiration time.Duration) (bool, error)
  • func (d *Dao) WithContext(ctx context.Context) *Dao

Constants

const KCreateDatabase = "CREATE DATABASE IF NOT EXISTS `%s` CHARACTER SET utf8mb4;"

Types

type Dao

type Dao struct {
	Sql     db.SqlDatabase
	Redis   redis.Client
	Elastic db.EsDatabase
	Ctx     context.Context
	// contains filtered or unexported fields
}

Dao https://gorm.io/docs/query.html

func (*Dao) ClusterRedisClient

func (d *Dao) ClusterRedisClient() (*goredis.ClusterClient, error)

func (*Dao) Condition

func (d *Dao) Condition(data interface{}, call db.ConditionCallback) result.Result

func (*Dao) DBClient

func (d *Dao) DBClient() (*gorm.DB, error)

func (*Dao) ElasticClient

func (d *Dao) ElasticClient() (*elastic.Client, error)

func (*Dao) Expire

func (d *Dao) Expire(key string, time time.Duration)

Expire 过多久失效

func (*Dao) ExpireAt

func (d *Dao) ExpireAt(key string, time time.Time)

ExpireAt 在某个时间点过期

func (*Dao) Get

func (d *Dao) Get(key string) (string, error)

func (*Dao) GetInt

func (d *Dao) GetInt(key string) (int, error)

func (*Dao) HDel

func (d *Dao) HDel(key, field string) (int64, error)

func (*Dao) HGet

func (d *Dao) HGet(key, field string) (string, error)

func (*Dao) HGetAll

func (d *Dao) HGetAll(key string) (map[string]string, error)

func (*Dao) HGetInt

func (d *Dao) HGetInt(key, field string) (int, error)

func (*Dao) HInc

func (d *Dao) HInc(key, field string, value int64) (int64, error)

func (*Dao) HSet

func (d *Dao) HSet(key, field string, value interface{}) (int64, error)

func (*Dao) HSetNX

func (d *Dao) HSetNX(key, field string, value interface{}) (bool, error)

func (*Dao) Inc

func (d *Dao) Inc(key string, value int64) (int64, error)

func (*Dao) IsNotFound

func (d *Dao) IsNotFound(db *gorm.DB) int

func (*Dao) RedisClient

func (d *Dao) RedisClient() (*goredis.Client, error)

func (*Dao) ResetEsClient

func (d *Dao) ResetEsClient()

func (*Dao) ResetRdsClient

func (d *Dao) ResetRdsClient()

func (*Dao) SentinelRedisClient

func (d *Dao) SentinelRedisClient() (*goredis.SentinelClient, error)

func (*Dao) Set

func (d *Dao) Set(key string, value interface{}, expiration time.Duration) (string, error)

func (*Dao) SetEX

func (d *Dao) SetEX(key string, value interface{}, expiration time.Duration) (string, error)

func (*Dao) SetNX

func (d *Dao) SetNX(key string, value interface{}, expiration time.Duration) (bool, error)

func (*Dao) WithContext

func (d *Dao) WithContext(ctx context.Context) *Dao