dbs

Documentation

Index

• Constants
• func DB() *gorm.DB
• func DBWithOption(conn *Connection, config *gorm.Config) *gorm.DB
• func MysqlInit() *gorm.DB
• func PostgresInit() *gorm.DB
• func RC() redis.Cmdable
• func Redis() redis.Cmdable
• func RedisCluster() redis.Cmdable
• func SqliteInit() *gorm.DB
• type Connection
• type Mutex
  • func NewMutex(client redis.UniversalClient, key string, options ...Option) *Mutex
  • func (m *Mutex) TryLock(ctx context.Context) (bool, error)
  • func (m *Mutex) Unlock(ctx context.Context) error
• type Option
  • func WithLeaseDuration(leaseDuration time.Duration) Option
• type Options
• type Redisson
  • func NewRedisson(redisClient *redis.Client) *Redisson
  • func (r *Redisson) NewMutex(key string, options ...Option) *Mutex

Constants

const (
	Sqlite   = "lite"
	Mysql    = "mysql"
	Postgres = "pgsql"
)

Functions

func DB

func DB() *gorm.DB

func DBWithOption

func DBWithOption(conn *Connection, config *gorm.Config) *gorm.DB

func MysqlInit

func MysqlInit() *gorm.DB

func PostgresInit

func PostgresInit() *gorm.DB

func RC

func RC() redis.Cmdable

func Redis

func Redis() redis.Cmdable

func RedisCluster

func RedisCluster() redis.Cmdable

func SqliteInit

func SqliteInit() *gorm.DB

Types

type Connection

type Connection struct {
	Kind   string
	Host   string
	Port   int
	User   string
	Pass   string
	Dbname string
	Prefix string
}

type Mutex

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

func NewMutex

func NewMutex(client redis.UniversalClient, key string, options ...Option) *Mutex

func (*Mutex) TryLock

func (m *Mutex) TryLock(ctx context.Context) (bool, error)

func (*Mutex) Unlock

func (m *Mutex) Unlock(ctx context.Context) error

type Option

type Option func(*Options)

func WithLeaseDuration

func WithLeaseDuration(leaseDuration time.Duration) Option

type Options

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

type Redisson

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

func NewRedisson

func NewRedisson(redisClient *redis.Client) *Redisson

func (*Redisson) NewMutex

func (r *Redisson) NewMutex(key string, options ...Option) *Mutex