Documentation
¶
Index ¶
- func NewAMQPQueue(amqpQueueSetting *setting.QueueAMQPSettingS, ...) (*queue.MachineryQueue, error)
- func NewAliAMQPQueue(aliAMQPQueueSetting *setting.QueueAliAMQPSettingS, ...) (*queue.MachineryQueue, error)
- func NewG2Cache(g2cacheSetting *setting.G2CacheSettingS, out g2cache.OutCache, ...) (*g2cache.G2Cache, error)
- func NewMongoDBClient(mongodbSetting *setting.MongoDBSettingS) (*qmgo.QmgoClient, error)
- func NewMySQLWithGORM(mysqlSetting *setting.MysqlSettingS) (*gorm.DB, error)
- func NewMySQLWithXORM(mysqlSetting *setting.MysqlSettingS) (xorm.EngineInterface, error)
- func NewRedis(redisSetting *setting.RedisSettingS) (*redis.Pool, error)
- func NewRedisQueue(redisQueueSetting *setting.QueueRedisSettingS, ...) (*queue.MachineryQueue, error)
- func SetGORMCreateCallback(db *gorm.DB, callback func(scope *gorm.Scope))
- func SetGORMDeleteCallback(db *gorm.DB, callback func(scope *gorm.Scope))
- func SetGORMUpdateCallback(db *gorm.DB, callback func(scope *gorm.Scope))
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAMQPQueue ¶
func NewAMQPQueue(amqpQueueSetting *setting.QueueAMQPSettingS, namedTaskFuncs map[string]interface{}) (*queue.MachineryQueue, error)
SetUpAMQPQueue returns *queue.MachineryQueue instance of AMQP queue.
func NewAliAMQPQueue ¶
func NewAliAMQPQueue(aliAMQPQueueSetting *setting.QueueAliAMQPSettingS, namedTaskFuncs map[string]interface{}) (*queue.MachineryQueue, error)
NewAliAMQPQueue returns *kelvinsqueue.MachineryQueue instance of aliyun AMQP queue.
func NewG2Cache ¶ added in v1.6.3
func NewG2Cache(g2cacheSetting *setting.G2CacheSettingS, out g2cache.OutCache, local g2cache.LocalCache) (*g2cache.G2Cache, error)
func NewMongoDBClient ¶
func NewMongoDBClient(mongodbSetting *setting.MongoDBSettingS) (*qmgo.QmgoClient, error)
func NewMySQLWithGORM ¶
func NewMySQLWithGORM(mysqlSetting *setting.MysqlSettingS) (*gorm.DB, error)
NewMySQLWithGORM NewMySQL returns *gorm.DB instance.
func NewMySQLWithXORM ¶
func NewMySQLWithXORM(mysqlSetting *setting.MysqlSettingS) (xorm.EngineInterface, error)
NewMySQLWithXORM NewMySQL returns *xorm.DB instance.
func NewRedis ¶
func NewRedis(redisSetting *setting.RedisSettingS) (*redis.Pool, error)
NewRedis returns *redis.Pool instance.
func NewRedisQueue ¶
func NewRedisQueue(redisQueueSetting *setting.QueueRedisSettingS, namedTaskFuncs map[string]interface{}) (*queue.MachineryQueue, error)
NewRedisQueue returns *kelvinsqueue.MachineryQueue instance of redis queue.
func SetGORMCreateCallback ¶
SetGORMCreateCallback is set create callback
func SetGORMDeleteCallback ¶
SetGORMDeleteCallback is set delete callback
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.