data

README

Data

Documentation

Index

• Variables
• func DelFromLocal(key string)
• func GetFromLocal(key string) (string, error)
• func NewAuthClient(c *conf.Bootstrap) (auth.AuthClient, error)
• func NewCache(c *conf.Bootstrap, client redis.UniversalClient) biz.Cache
• func NewClient[T any](name, endpoint string, health bool, timeout time.Duration, ...) (client T, err error)
• func NewDB(c *conf.Bootstrap) (gormTenant *tenant.Tenant, err error)
• func NewGameRepo(data *Data) biz.GameRepo
• func NewRedis(c *conf.Bootstrap) (client redis.UniversalClient, err error)
• func NewSonyflake(c *conf.Bootstrap) (sf *id.Sonyflake, err error)
• func NewTracer(c *conf.Bootstrap) (tp *trace.TracerProvider, err error)
• func NewTransaction(d *Data) biz.Transaction
• func Set2Local(key, val string, expire int)
• type Cache
  • func (c *Cache) Cache() redis.UniversalClient
  • func (c *Cache) Del(ctx context.Context, action string)
  • func (c *Cache) Flush(ctx context.Context, handler func(ctx context.Context) error) (err error)
  • func (c *Cache) FlushByPrefix(ctx context.Context, prefix ...string) (err error)
  • func (c *Cache) Get(ctx context.Context, action string, ...) (res string, err error)
  • func (c *Cache) Lock(ctx context.Context, action string) (*redislock.Lock, error)
  • func (c *Cache) Set(ctx context.Context, action, data string, short bool)
  • func (c *Cache) SetWithExpiration(ctx context.Context, action, data string, seconds int64)
  • func (c *Cache) WithPrefix(prefix string) biz.Cache
  • func (c *Cache) WithRefresh() biz.Cache
• type Data
  • func NewData(redis redis.UniversalClient, gormTenant *tenant.Tenant, ...) (d *Data, cleanup func())
  • func (d *Data) Cache() redis.UniversalClient
  • func (d *Data) DB(ctx context.Context) *gorm.DB
  • func (*Data) HiddenSQL(ctx context.Context) context.Context
  • func (d *Data) ID(ctx context.Context) uint64
  • func (d *Data) Tx(ctx context.Context, handler func(ctx context.Context) error) error

Variables

var ProviderSet = wire.NewSet(
	NewRedis, NewDB, NewSonyflake, NewTracer, NewData, NewTransaction, NewCache,
	NewAuthClient,
	NewGameRepo,
)

ProviderSet is data providers.

Functions

func DelFromLocal

func DelFromLocal(key string)

func GetFromLocal

func GetFromLocal(key string) (string, error)

func NewAuthClient

func NewAuthClient(c *conf.Bootstrap) (auth.AuthClient, error)

func NewCache

func NewCache(c *conf.Bootstrap, client redis.UniversalClient) biz.Cache

NewCache .

func NewClient

func NewClient[T any](name, endpoint string, health bool, timeout time.Duration, newClient func(cc g.ClientConnInterface) T) (client T, err error)

func NewDB

func NewDB(c *conf.Bootstrap) (gormTenant *tenant.Tenant, err error)

NewDB is initialize db connection from config

func NewGameRepo

func NewGameRepo(data *Data) biz.GameRepo

func NewRedis

func NewRedis(c *conf.Bootstrap) (client redis.UniversalClient, err error)

NewRedis is initialize redis connection from config

func NewSonyflake

func NewSonyflake(c *conf.Bootstrap) (sf *id.Sonyflake, err error)

NewSonyflake is initialize sonyflake id generator

func NewTracer

func NewTracer(c *conf.Bootstrap) (tp *trace.TracerProvider, err error)

func NewTransaction

func NewTransaction(d *Data) biz.Transaction

NewTransaction .

func Set2Local

func Set2Local(key, val string, expire int)

Types

type Cache

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

Cache .

func (*Cache) Cache

func (c *Cache) Cache() redis.UniversalClient

func (*Cache) Del

func (c *Cache) Del(ctx context.Context, action string)

func (*Cache) Flush

func (c *Cache) Flush(ctx context.Context, handler func(ctx context.Context) error) (err error)

func (*Cache) FlushByPrefix

func (c *Cache) FlushByPrefix(ctx context.Context, prefix ...string) (err error)

func (*Cache) Get

func (c *Cache) Get(
	ctx context.Context,
	action string,
	write func(context.Context) (string, error),
) (res string, err error)

func (*Cache) Lock

func (c *Cache) Lock(ctx context.Context, action string) (*redislock.Lock, error)

func (*Cache) Set

func (c *Cache) Set(ctx context.Context, action, data string, short bool)

func (*Cache) SetWithExpiration

func (c *Cache) SetWithExpiration(ctx context.Context, action, data string, seconds int64)

func (*Cache) WithPrefix

func (c *Cache) WithPrefix(prefix string) biz.Cache

func (*Cache) WithRefresh

func (c *Cache) WithRefresh() biz.Cache

type Data

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

Data .

func NewData

func NewData(
	redis redis.UniversalClient,
	gormTenant *tenant.Tenant,
	sonyflake *id.Sonyflake,
	tp *trace.TracerProvider,
	auth auth.AuthClient,
) (d *Data, cleanup func())

NewData .

func (*Data) Cache

func (d *Data) Cache() redis.UniversalClient

Cache can get cache instance

func (*Data) DB

func (d *Data) DB(ctx context.Context) *gorm.DB

DB can get tx from ctx, if not exist return db

func (*Data) HiddenSQL

func (*Data) HiddenSQL(ctx context.Context) context.Context

HiddenSQL return a hidden sql ctx

func (*Data) ID

func (d *Data) ID(ctx context.Context) uint64

ID can get unique id

func (*Data) Tx

func (d *Data) Tx(ctx context.Context, handler func(ctx context.Context) error) error

Tx is transaction wrapper