dao

Documentation

Index

• type CurrentDb
  • func (d *CurrentDb) OK() bool
• type CurrentElastic
  • func (d *CurrentElastic) OK() bool
• type CurrentRedis
  • func (d *CurrentRedis) Expire(ctx context.Context, key string, time time.Duration)
  • func (d *CurrentRedis) ExpireAt(ctx context.Context, key string, time time.Time)
  • func (d *CurrentRedis) Get(ctx context.Context, key string) (string, error)
  • func (d *CurrentRedis) GetInt(ctx context.Context, key string) (int, error)
  • func (d *CurrentRedis) HDel(ctx context.Context, key, field string) (int64, error)
  • func (d *CurrentRedis) HGet(ctx context.Context, key, field string) (string, error)
  • func (d *CurrentRedis) HGetAll(ctx context.Context, key string) (map[string]string, error)
  • func (d *CurrentRedis) HGetInt(ctx context.Context, key, field string) (int, error)
  • func (d *CurrentRedis) HInc(ctx context.Context, key, field string, value int64) (int64, error)
  • func (d *CurrentRedis) HSet(ctx context.Context, key, field string, value interface{}) (int64, error)
  • func (d *CurrentRedis) HSetNX(ctx context.Context, key, field string, value interface{}) (bool, error)
  • func (d *CurrentRedis) Inc(ctx context.Context, key string, value int64) (int64, error)
  • func (d *CurrentRedis) OK() bool
  • func (d *CurrentRedis) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) (string, error)
  • func (d *CurrentRedis) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) (string, error)
  • func (d *CurrentRedis) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) (bool, error)
  • func (d *CurrentRedis) Warning(r *perf.RunTime, err error)
• type Dao
  • func (d *Dao) ClusterRedisClient(opts ...commonoption.Option) (*goredis.ClusterClient, error)
  • func (d *Dao) Condition(ctx context.Context, data interface{}, call db.ConditionCallback, ...) result.Result
  • func (d *Dao) DBClient(opts ...commonoption.Option) (*gorm.DB, error)
  • func (d *Dao) ElasticClient(opts ...commonoption.Option) (*elastic.Client, error)
  • func (d *Dao) IsNotFound(db *gorm.DB) int
  • func (d *Dao) RedisClient(opts ...commonoption.Option) (*goredis.Client, error)
  • func (d *Dao) SentinelRedisClient(opts ...commonoption.Option) (*goredis.SentinelClient, error)
  • func (d *Dao) UseDB(opts ...commonoption.Option) CurrentDb
  • func (d *Dao) UseElastic(opts ...commonoption.Option) CurrentElastic
  • func (d *Dao) UseRedis(opts ...commonoption.Option) CurrentRedis

Types

type CurrentDb

type CurrentDb struct {
	*gorm.DB
}

func (*CurrentDb) OK

func (d *CurrentDb) OK() bool

type CurrentElastic

type CurrentElastic struct {
	*elastic.Client
}

func (*CurrentElastic) OK

func (d *CurrentElastic) OK() bool

type CurrentRedis

type CurrentRedis struct {
	*goredis.Client
	// contains filtered or unexported fields
}

func (*CurrentRedis) Expire

func (d *CurrentRedis) Expire(ctx context.Context, key string, time time.Duration)

Expire 过多久失效

func (*CurrentRedis) ExpireAt

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

ExpireAt 在某个时间点过期

func (*CurrentRedis) Get

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

func (*CurrentRedis) GetInt

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

func (*CurrentRedis) HDel

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

func (*CurrentRedis) HGet

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

func (*CurrentRedis) HGetAll

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

func (*CurrentRedis) HGetInt

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

func (*CurrentRedis) HInc

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

func (*CurrentRedis) HSet

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

func (*CurrentRedis) HSetNX

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

func (*CurrentRedis) Inc

func (d *CurrentRedis) Inc(ctx context.Context, key string, value int64) (int64, error)

func (*CurrentRedis) OK

func (d *CurrentRedis) OK() bool

func (*CurrentRedis) Set

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

func (*CurrentRedis) SetEX

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

func (*CurrentRedis) SetNX

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

func (*CurrentRedis) Warning

func (d *CurrentRedis) Warning(r *perf.RunTime, err error)

type Dao

type Dao struct {
	Sql     db.SqlDatabase
	Redis   redis.Client
	Elastic db.EsDatabase
}

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

func (*Dao) ClusterRedisClient

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

func (*Dao) Condition

func (d *Dao) Condition(ctx context.Context, data interface{}, call db.ConditionCallback, opts ...commonoption.Option) result.Result

func (*Dao) DBClient

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

func (*Dao) ElasticClient

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

func (*Dao) IsNotFound

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

func (*Dao) RedisClient

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

func (*Dao) SentinelRedisClient

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

func (*Dao) UseDB

func (d *Dao) UseDB(opts ...commonoption.Option) CurrentDb

func (*Dao) UseElastic

func (d *Dao) UseElastic(opts ...commonoption.Option) CurrentElastic

func (*Dao) UseRedis

func (d *Dao) UseRedis(opts ...commonoption.Option) CurrentRedis