engines

Jun 2, 2022

Changes in this version

type SQLTb

+ func (my *SQLTb) Exec(queryFn func(tx *gorm.DB) *gorm.DB) error

+ func (my *SQLTb) ExecToSQL(queryFn func(tx *gorm.DB) *gorm.DB) (sql string, err error)

+ func (my *SQLTb) ToSQLExec(queryFn func(tx *gorm.DB) *gorm.DB) (sql string, err error)

May 5, 2022

Changes in this version

+ func NewMongoDb(name string) interfaces.MongoDb

+ func NewRedis(name int) interfaces.RedisDb

+ func NewSQLDb(name string) interfaces.SQLDb

+ func NewSeaweedFS(prePath string) interfaces.SeaweedFS

+ type MongoDb struct

+ func (my *MongoDb) TB(name string) interfaces.MongoTb

+ type MongoTb struct

+ func (my *MongoTb) Delete(condi interface{}) error

+ func (my *MongoTb) FindALL(result interface{}, condi interface{}) error

+ func (my *MongoTb) FindOne(result interface{}, condi interface{}) error

+ func (my *MongoTb) Insert(data interface{}) error

+ func (my *MongoTb) Update(replacement, condi interface{}) error

+ func (my *MongoTb) Upsert(replacement, condi interface{}) error

+ type RedisDb struct

+ func (my *RedisDb) Publish(topic, msg string) (int64, error)

+ func (my *RedisDb) Subscribe(topic string, msgFn func(pubsub interfaces.RedisMsg))

+ type RedisMsg struct

+ Channel string

+ Pattern string

+ Payload string

+ func (my *RedisMsg) GetChannel() string

+ func (my *RedisMsg) GetPattern() string

+ func (my *RedisMsg) GetPayload() string

+ type SQLDb struct

+ func (my *SQLDb) CreateTB(models ...interface{}) error

+ func (my *SQLDb) TB(name string) interfaces.SQLTb

+ type SQLTb struct

+ func (my *SQLTb) Count(query interface{}, args ...interface{}) (int64, error)

+ func (my *SQLTb) Delete(query interface{}, args ...interface{}) (string, error)

+ func (my *SQLTb) Exist(query interface{}, args ...interface{}) (bool, error)

+ func (my *SQLTb) FindALL(result interface{}, query interface{}, args ...interface{}) (string, error)

+ func (my *SQLTb) FindOne(result interface{}, query interface{}, args ...interface{}) (string, error)

+ func (my *SQLTb) Insert(data interface{}) (string, error)

+ func (my *SQLTb) Update(replacement interface{}, query interface{}, args ...interface{}) (string, error)

+ func (my *SQLTb) Upsert(replacement interface{}, query interface{}, args ...interface{}) (string, error)

+ func (my *SQLTb) UseGorm(queryFn func(tx *gorm.DB) error) error

+ func (my *SQLTb) UseXorm(queryFn func(tx *xorm.Engine) error) error

+ type SeaweedFS struct

+ func (my *SeaweedFS) Delete(path string) error

+ func (my *SeaweedFS) Download(path string) ([]byte, error)

+ func (my *SeaweedFS) Info(path string) (interfaces.SeaweedFile, error)

+ func (my *SeaweedFS) List(dirpath string) ([]interfaces.SeaweedFile, error)

+ func (my *SeaweedFS) Upload(path string, content []byte) error

+ type SeaweedFile struct

+ func (my *SeaweedFile) IsDir() bool

+ func (my *SeaweedFile) Name() string

+ func (my *SeaweedFile) Path() string