handler

Jun 1, 2023

Changes in this version

type Database

+ func (d *Database) AutoMigrate() error

+ func (d *Database) GetTableComment(database string, table string) (string, error)

+ func (d *Database) GetTableFieldComment(database string, table string) ([]Field, error)

+ type Field struct

+ ColumnComment string

+ ColumnName string

+ DataType string

type RedisClient

+ func (r *RedisClient) HDel(key string, field string) *redis.IntCmd

+ func (r *RedisClient) SetContext(ctx context.Context)

+ func (r *RedisClient) SetNx(key string, value any, expiration ...time.Duration) *redis.BoolCmd

Apr 10, 2023

Changes in this version

type RedisClient

+ func (r *RedisClient) GetPool() *redis.Pool

Apr 10, 2023

Changes in this version

+ type SubscribeCallback func(message string)

Feb 23, 2023

Changes in this version

+ var WebsocketHandler *socket.WebSocket

+ func InitializeWebsocket(pattern string, address string) *socket.WebSocket

Feb 21, 2023

Changes in this version

+ func InitializeMysql(config dirver.LinkParams) *gorm.DB

+ func InitializeRedisPool(config RedisConfig) *redis.Client

+ type CommonModel struct

+ CreatedAt time.Time

+ Id int

+ UpdatedAt time.Time

+ type Database struct

+ Result any

+ var DBHandler *Database

+ func NewDatabase(db *gorm.DB) *Database

+ func (d *Database) Begin() *gorm.DB

+ func (d *Database) Create(model any) error

+ func (d *Database) Delete(model any) error

+ func (d *Database) DeleteByWhere(where any) error

+ func (d *Database) ExecuteSql(sql string, logMod ...bool) error

+ func (d *Database) Exist(where Where) (bool, error)

+ func (d *Database) Find(id any) error

+ func (d *Database) First(where Where, not ...Where) error

+ func (d *Database) Get(where ...any) error

+ func (d *Database) GetByPage(pagination PaginationQuery, where any) PageData

+ func (d *Database) GetDb() *gorm.DB

+ func (d *Database) Save(model any) error

+ func (d *Database) SetMode() error

+ func (d *Database) SetModel(executeModel any) *Database

+ func (d *Database) SetResult(resultModel any) *Database

+ type ModelAction interface

+ DataId func() int

+ TableName func() string

+ type PageData struct

+ DataList any

+ PageInfo PageInfo

+ type PageInfo struct

+ CurrPage int

+ EndOffset int

+ NextPage int

+ Offset int

+ Pages []int

+ PrevPage int

+ TotalCount int

+ TotalPage int

+ type PaginationQuery struct

+ Order string

+ OrderBy string

+ PageNum int

+ PageSize int

+ type PipAction func(pipeLiner redis.Pipeliner)

+ type RedisClient struct

+ var RedisHandler *RedisClient

+ func NewRedis(client *redis.Client) *RedisClient

+ func (r *RedisClient) BLPop(key string, timeout time.Duration) ([]string, error)

+ func (r *RedisClient) Delete(key ...string) error

+ func (r *RedisClient) Get(key string) (bool, string, error)

+ func (r *RedisClient) HGet(key, field string) (string, error)

+ func (r *RedisClient) HGetAll(key string) (map[string]string, error)

+ func (r *RedisClient) HSet(key string, values map[string]string) (int64, error)

+ func (r *RedisClient) HSetNX(key, field string, value any) (bool, error)

+ func (r *RedisClient) Keys(pattern string) ([]string, error)

+ func (r *RedisClient) LPop(key string) (string, error)

+ func (r *RedisClient) LPush(key string, value any) (int64, error)

+ func (r *RedisClient) Publish(channel string, message any) (int64, error)

+ func (r *RedisClient) SelectDbAction(index int, action PipAction) (map[int]any, error)

+ func (r *RedisClient) Set(key string, value any, expiration time.Duration) error

+ func (r *RedisClient) SetNX(key string, value any, expiration time.Duration) (bool, error)

+ func (r *RedisClient) Subscribe(channel string) <-chan *redis.Message

+ type RedisConfig struct

+ Db int

+ Host string

+ MaxRetries int

+ Password string

+ Port int

+ type SubscribeData struct

+ Channel string

+ Pattern string

+ Payload string

+ PayloadSlice any

+ type Where any