Documentation ¶
Index ¶
- func NewG2Cache(g2cacheSetting *setting.G2CacheSettingS, out g2cache.OutCache, ...) (*g2cache.G2Cache, error)
- func NewMySQLGORMEngine(mysqlSetting *setting.MysqlSettingS) (*gorm.DB, error)
- func NewMySQLXORMEngine(mysqlSetting *setting.MysqlSettingS) (*xorm.Engine, error)
- func NewRedis(redisSetting *setting.RedisSettingS) (*redis.Pool, error)
- func NewServerMux() *http.ServeMux
- func SetUpAMQPQueue(amqpQueueSetting *setting.QueueAMQPSettingS, ...) *queue.MachineryQueue
- func SetUpAliAMQPQueue(aliAMQPQueueSetting *setting.QueueAliAMQPSettingS, ...) *queue.MachineryQueue
- func SetUpRedisQueue(redisQueueSetting *setting.QueueRedisSettingS, ...) *queue.MachineryQueue
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewG2Cache ¶ added in v1.1.0
func NewG2Cache(g2cacheSetting *setting.G2CacheSettingS, out g2cache.OutCache, local g2cache.LocalCache) (*g2cache.G2Cache, error)
func NewMySQLGORMEngine ¶
func NewMySQLGORMEngine(mysqlSetting *setting.MysqlSettingS) (*gorm.DB, error)
NewMySQL returns *gorm.DB instance.
func NewMySQLXORMEngine ¶
func NewMySQLXORMEngine(mysqlSetting *setting.MysqlSettingS) (*xorm.Engine, error)
NewMySQL returns *xorm.DB instance.
func SetUpAMQPQueue ¶
func SetUpAMQPQueue(amqpQueueSetting *setting.QueueAMQPSettingS, namedTaskFuncs map[string]interface{}) *queue.MachineryQueue
SetUpAMQPQueue returns *queue.MachineryQueue instance of AMQP queue.
func SetUpAliAMQPQueue ¶
func SetUpAliAMQPQueue(aliAMQPQueueSetting *setting.QueueAliAMQPSettingS, namedTaskFuncs map[string]interface{}) *queue.MachineryQueue
SetUpAliAMQPQueue returns *queue.MachineryQueue instance of aliyun AMQP queue.
func SetUpRedisQueue ¶
func SetUpRedisQueue(redisQueueSetting *setting.QueueRedisSettingS, namedTaskFuncs map[string]interface{}) *queue.MachineryQueue
SetUpRedisQueue returns *queue.MachineryQueue instance of redis queue.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.