dao

Documentation

Index

• Constants
• type Dao
  • func (d *Dao) ClusterRedisClient() (*goredis.ClusterClient, error)
  • func (d *Dao) Condition(ctx context.Context, 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(ctx context.Context, key string, time time.Duration)
  • func (d *Dao) ExpireAt(ctx context.Context, key string, time time.Time)
  • func (d *Dao) Get(ctx context.Context, key string) (string, error)
  • func (d *Dao) GetInt(ctx context.Context, key string) (int, error)
  • func (d *Dao) HDel(ctx context.Context, key, field string) (int64, error)
  • func (d *Dao) HGet(ctx context.Context, key, field string) (string, error)
  • func (d *Dao) HGetAll(ctx context.Context, key string) (map[string]string, error)
  • func (d *Dao) HGetInt(ctx context.Context, key, field string) (int, error)
  • func (d *Dao) HInc(ctx context.Context, key, field string, value int64) (int64, error)
  • func (d *Dao) HSet(ctx context.Context, key, field string, value interface{}) (int64, error)
  • func (d *Dao) HSetNX(ctx context.Context, key, field string, value interface{}) (bool, error)
  • func (d *Dao) Inc(ctx context.Context, 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(ctx context.Context, key string, value interface{}, expiration time.Duration) (string, error)
  • func (d *Dao) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) (string, error)
  • func (d *Dao) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) (bool, error)

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
	// 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(ctx context.Context, 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(ctx context.Context, key string, time time.Duration)

Expire 过多久失效

func (*Dao) ExpireAt

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

ExpireAt 在某个时间点过期

func (*Dao) Get

func (d *Dao) Get(ctx context.Context, key string) (string, error)

func (*Dao) GetInt

func (d *Dao) GetInt(ctx context.Context, key string) (int, error)

func (*Dao) HDel

func (d *Dao) HDel(ctx context.Context, key, field string) (int64, error)

func (*Dao) HGet

func (d *Dao) HGet(ctx context.Context, key, field string) (string, error)

func (*Dao) HGetAll

func (d *Dao) HGetAll(ctx context.Context, key string) (map[string]string, error)

func (*Dao) HGetInt

func (d *Dao) HGetInt(ctx context.Context, key, field string) (int, error)

func (*Dao) HInc

func (d *Dao) HInc(ctx context.Context, key, field string, value int64) (int64, error)

func (*Dao) HSet

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

func (*Dao) HSetNX

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

func (*Dao) Inc

func (d *Dao) Inc(ctx context.Context, 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(ctx context.Context, key string, value interface{}, expiration time.Duration) (string, error)

func (*Dao) SetEX

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

func (*Dao) SetNX

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