setup

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

Functions

func NewG2Cache

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 NewRedis

func NewRedis(redisSetting *setting.RedisSettingS) (*redis.Pool, error)

func NewServerMux

func NewServerMux() *http.ServeMux

NewServerMux ...

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.