Documentation ¶
Index ¶
- func NewCache(prefix string, store storage.AdapterCache, wxTokenStoreKey string) storage.AdapterCache
- func NewLocker(prefix string, locker storage.AdapterLocker) storage.AdapterLocker
- func NewModeration(prefix string, moderation moderation.AdapterModeration) moderation.AdapterModeration
- func NewQueue(prefix string, queue storage.AdapterQueue) storage.AdapterQueue
- type Amqp
- type Application
- func (e *Application) GetAmqpAdapter() message.AdapterAmqp
- func (e *Application) GetAmqpAdapters() map[string]message.AdapterAmqp
- func (e *Application) GetAmqpKey(key string) message.AdapterAmqp
- func (e *Application) GetAppRouters() []func()
- func (e *Application) GetBlockChainAdapter() block_chain.AdapterBroker
- func (e *Application) GetBlockChainAdapters() map[string]block_chain.AdapterBroker
- func (e *Application) GetBlockChainKey(key string) block_chain.AdapterBroker
- func (e *Application) GetCacheAdapter() storage.AdapterCache
- func (e *Application) GetCachePrefix(key string) storage.AdapterCache
- func (e *Application) GetCasbin() map[string]*casbin.SyncedEnforcer
- func (e *Application) GetCasbinKey(key string) *casbin.SyncedEnforcer
- func (e *Application) GetConfig(key string) interface{}
- func (e *Application) GetCrontab() map[string]*cron.Cron
- func (e *Application) GetCrontabKey(key string) *cron.Cron
- func (e *Application) GetDb() map[string]*gorm.DB
- func (e *Application) GetDbByKey(key string) *gorm.DB
- func (e *Application) GetEngine() http.Handler
- func (e *Application) GetFileStoreAdapter() storage.AdapterFileStore
- func (e *Application) GetFileStoreAdapters() map[string]storage.AdapterFileStore
- func (e *Application) GetFileStoreKey(key string) storage.AdapterFileStore
- func (e *Application) GetHandler() map[string][]func(r *gin.RouterGroup, hand ...*gin.HandlerFunc)
- func (e *Application) GetHandlerPrefix(key string) []func(r *gin.RouterGroup, hand ...*gin.HandlerFunc)
- func (e *Application) GetLocationBasedServiceAdapter() lbs.AdapterLocationBasedService
- func (e *Application) GetLocationBasedServiceAdapters() map[string]lbs.AdapterLocationBasedService
- func (e *Application) GetLocationBasedServiceKey(key string) lbs.AdapterLocationBasedService
- func (e *Application) GetLockerAdapter() storage.AdapterLocker
- func (e *Application) GetLockerPrefix(key string) storage.AdapterLocker
- func (e *Application) GetLogger() logger.Logger
- func (e *Application) GetMailAdapter() message.AdapterMail
- func (e *Application) GetMailAdapters() map[string]message.AdapterMail
- func (e *Application) GetMailKey(key string) message.AdapterMail
- func (e *Application) GetMemoryQueue(prefix string) storage.AdapterQueue
- func (e *Application) GetMiddleware() map[string]interface{}
- func (e *Application) GetMiddlewareKey(key string) interface{}
- func (e *Application) GetModerationAdapter() moderation.AdapterModeration
- func (e *Application) GetModerationAdapters() map[string]moderation.AdapterModeration
- func (e *Application) GetModerationKey(key string) moderation.AdapterModeration
- func (e *Application) GetPaymentServiceAdapter() payment.AdapterPaymentService
- func (e *Application) GetPaymentServiceAdapters() map[string]payment.AdapterPaymentService
- func (e *Application) GetPaymentServiceKey(key string) payment.AdapterPaymentService
- func (e *Application) GetQueueAdapter() storage.AdapterQueue
- func (e *Application) GetQueuePrefix(key string) storage.AdapterQueue
- func (e *Application) GetRouter() []Router
- func (e *Application) GetSmsAdapter() message.AdapterSms
- func (e *Application) GetSmsAdapters() map[string]message.AdapterSms
- func (e *Application) GetSmsKey(key string) message.AdapterSms
- func (e *Application) GetStreamMessage(id, stream string, value map[string]interface{}) (storage.Messager, error)
- func (e *Application) GetThirdPartyAdapter() third_party.AdapterThirdParty
- func (e *Application) GetThirdPartyAdapters() map[string]third_party.AdapterThirdParty
- func (e *Application) GetThirdPartyKey(key string) third_party.AdapterThirdParty
- func (e *Application) SetAmqpAdapter(key string, c message.AdapterAmqp)
- func (e *Application) SetAppRouters(appRouters func())
- func (e *Application) SetBlockChainAdapter(key string, c block_chain.AdapterBroker)
- func (e *Application) SetCacheAdapter(c storage.AdapterCache)
- func (e *Application) SetCasbin(key string, enforcer *casbin.SyncedEnforcer)
- func (e *Application) SetConfig(key string, value interface{})
- func (e *Application) SetCrontab(key string, crontab *cron.Cron)
- func (e *Application) SetDb(key string, db *gorm.DB)
- func (e *Application) SetEngine(engine http.Handler)
- func (e *Application) SetFileStoreAdapter(key string, c storage.AdapterFileStore)
- func (e *Application) SetHandler(key string, routerGroup func(r *gin.RouterGroup, hand ...*gin.HandlerFunc))
- func (e *Application) SetLocationBasedServiceAdapter(key string, c lbs.AdapterLocationBasedService)
- func (e *Application) SetLockerAdapter(c storage.AdapterLocker)
- func (e *Application) SetLogger(l logger.Logger)
- func (e *Application) SetMailAdapter(key string, c message.AdapterMail)
- func (e *Application) SetMiddleware(key string, middleware interface{})
- func (e *Application) SetModerationAdapter(key string, c moderation.AdapterModeration)
- func (e *Application) SetPaymentServiceAdapter(key string, c payment.AdapterPaymentService)
- func (e *Application) SetQueueAdapter(c storage.AdapterQueue)
- func (e *Application) SetSmsAdapter(key string, c message.AdapterSms)
- func (e *Application) SetThirdPartyAdapter(key string, c third_party.AdapterThirdParty)
- type BlockChain
- type Cache
- func (e Cache) Connect() error
- func (e Cache) Decrease(key string) error
- func (e Cache) Del(key ...string) error
- func (e Cache) DelPattern(pattern string) error
- func (e Cache) Expire(key string, dur time.Duration) error
- func (e Cache) Get(key string) (string, error)
- func (e Cache) GetClient() interface{}
- func (e Cache) HashDel(hk string, key ...string) error
- func (e Cache) HashDelPattern(hk, pattern string) error
- func (e Cache) HashGet(hk, key string) (string, error)
- func (e Cache) HashKeys(hk string) ([]string, error)
- func (e Cache) HashSet(hk, key string, val interface{}, expire int) error
- func (e Cache) Increase(key string) error
- func (e Cache) PutToken(token *oauth2.Token) error
- func (e Cache) Set(key string, val interface{}, expire int) error
- func (e *Cache) SetPrefix(prefix string)
- func (e *Cache) String() string
- func (e Cache) Token() (token *oauth2.Token, err error)
- type FileStore
- type Locker
- type Mail
- type Moderation
- func (e *Moderation) AuditImage(url string, result *int, label *string, score *int, detail *string) error
- func (e *Moderation) AuditResult(body *[]byte, result *int, label *string, score *int, detail *string, ...) error
- func (e *Moderation) AuditText(content string, result *int, label *string, score *int, detail *string) error
- func (e *Moderation) AuditVideo(url string, frame int32, jobId *string) error
- func (e *Moderation) GetClient() interface{}
- func (e *Moderation) String() string
- type Queue
- type Router
- type Routers
- type Runtime
- type Sms
- type ThirdParty
- func (e *ThirdParty) GetAccessToken(cache storage.AdapterCache) (string, error)
- func (e *ThirdParty) GetConnectUrl(state, scope string, popUp bool) (string, error)
- func (e *ThirdParty) GetJSApiTicket(cache storage.AdapterCache) (string, error)
- func (e *ThirdParty) GetUserAccessToken(code, state string) (string, error)
- func (e *ThirdParty) GetUserInfo(userAccessToken, openId string) (string, error)
- func (e *ThirdParty) RefreshUserToken(refreshToken string, appId string) (string, error)
- func (e *ThirdParty) SendTemplateMessage(cache storage.AdapterCache, openId, templateId, url string, data []byte) (string, error)
- func (e *ThirdParty) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCache ¶
func NewCache(prefix string, store storage.AdapterCache, wxTokenStoreKey string) storage.AdapterCache
NewCache 创建对应上下文缓存
func NewLocker ¶
func NewLocker(prefix string, locker storage.AdapterLocker) storage.AdapterLocker
NewLocker 创建对应上下文分布式锁
func NewModeration ¶ added in v1.4.13
func NewModeration(prefix string, moderation moderation.AdapterModeration) moderation.AdapterModeration
NewModeration 创建对应上下文缓存
func NewQueue ¶
func NewQueue(prefix string, queue storage.AdapterQueue) storage.AdapterQueue
NewQueue 创建对应上下文队列
Types ¶
type Amqp ¶
type Amqp struct {
// contains filtered or unexported fields
}
func (*Amqp) PublishOnQueue ¶
PublishOnQueue 发送消息
func (*Amqp) SubscribeToQueue ¶
func (e *Amqp) SubscribeToQueue(queueName string, consumerName string, tag string, f message.AmqpConsumerFunc) error
SubscribeToQueue 消费消息
type Application ¶
type Application struct {
// contains filtered or unexported fields
}
func (*Application) GetAmqpAdapter ¶
func (e *Application) GetAmqpAdapter() message.AdapterAmqp
GetAmqpAdapter 获取缓存
func (*Application) GetAmqpAdapters ¶
func (e *Application) GetAmqpAdapters() map[string]message.AdapterAmqp
GetAmqpAdapters 获取缓存
func (*Application) GetAmqpKey ¶
func (e *Application) GetAmqpKey(key string) message.AdapterAmqp
GetAmqpKey 获取带租户标记的amqp
func (*Application) GetAppRouters ¶ added in v1.3.25
func (e *Application) GetAppRouters() []func()
GetAppRouters 获取app的路由
func (*Application) GetBlockChainAdapter ¶ added in v1.3.17
func (e *Application) GetBlockChainAdapter() block_chain.AdapterBroker
GetBlockChainAdapter 获取缓存
func (*Application) GetBlockChainAdapters ¶ added in v1.3.17
func (e *Application) GetBlockChainAdapters() map[string]block_chain.AdapterBroker
GetBlockChainAdapters 获取缓存
func (*Application) GetBlockChainKey ¶ added in v1.3.17
func (e *Application) GetBlockChainKey(key string) block_chain.AdapterBroker
GetBlockChainKey 获取带租户标记
func (*Application) GetCacheAdapter ¶
func (e *Application) GetCacheAdapter() storage.AdapterCache
GetCacheAdapter 获取缓存
func (*Application) GetCachePrefix ¶
func (e *Application) GetCachePrefix(key string) storage.AdapterCache
GetCachePrefix 获取带租户标记的cache
func (*Application) GetCasbin ¶
func (e *Application) GetCasbin() map[string]*casbin.SyncedEnforcer
func (*Application) GetCasbinKey ¶
func (e *Application) GetCasbinKey(key string) *casbin.SyncedEnforcer
GetCasbinKey 根据key获取casbin
func (*Application) GetConfig ¶ added in v1.3.25
func (e *Application) GetConfig(key string) interface{}
GetConfig 获取对应key的config
func (*Application) GetCrontab ¶
func (e *Application) GetCrontab() map[string]*cron.Cron
GetCrontab 获取所有map里的crontab数据
func (*Application) GetCrontabKey ¶
func (e *Application) GetCrontabKey(key string) *cron.Cron
GetCrontabKey 根据key获取crontab
func (*Application) GetDbByKey ¶
func (e *Application) GetDbByKey(key string) *gorm.DB
GetDbByKey 根据key获取db
func (*Application) GetFileStoreAdapter ¶
func (e *Application) GetFileStoreAdapter() storage.AdapterFileStore
GetFileStoreAdapter 获取缓存
func (*Application) GetFileStoreAdapters ¶
func (e *Application) GetFileStoreAdapters() map[string]storage.AdapterFileStore
GetFileStoreAdapters 获取缓存
func (*Application) GetFileStoreKey ¶
func (e *Application) GetFileStoreKey(key string) storage.AdapterFileStore
GetFileStoreKey 获取带租户标记的cos
func (*Application) GetHandler ¶
func (e *Application) GetHandler() map[string][]func(r *gin.RouterGroup, hand ...*gin.HandlerFunc)
func (*Application) GetHandlerPrefix ¶
func (e *Application) GetHandlerPrefix(key string) []func(r *gin.RouterGroup, hand ...*gin.HandlerFunc)
func (*Application) GetLocationBasedServiceAdapter ¶ added in v1.3.28
func (e *Application) GetLocationBasedServiceAdapter() lbs.AdapterLocationBasedService
GetLocationBasedServiceAdapter 获取LBS
func (*Application) GetLocationBasedServiceAdapters ¶ added in v1.3.28
func (e *Application) GetLocationBasedServiceAdapters() map[string]lbs.AdapterLocationBasedService
GetLocationBasedServiceAdapters 获取LBS
func (*Application) GetLocationBasedServiceKey ¶ added in v1.3.28
func (e *Application) GetLocationBasedServiceKey(key string) lbs.AdapterLocationBasedService
GetLocationBasedServiceKey 获取LBS
func (*Application) GetLockerAdapter ¶
func (e *Application) GetLockerAdapter() storage.AdapterLocker
GetLockerAdapter 获取分布式锁
func (*Application) GetLockerPrefix ¶
func (e *Application) GetLockerPrefix(key string) storage.AdapterLocker
func (*Application) GetMailAdapter ¶ added in v1.3.13
func (e *Application) GetMailAdapter() message.AdapterMail
GetMailAdapter 获取缓存
func (*Application) GetMailAdapters ¶ added in v1.3.13
func (e *Application) GetMailAdapters() map[string]message.AdapterMail
GetMailAdapters 获取缓存
func (*Application) GetMailKey ¶ added in v1.3.13
func (e *Application) GetMailKey(key string) message.AdapterMail
GetMailKey 获取带租户标记的mail
func (*Application) GetMemoryQueue ¶
func (e *Application) GetMemoryQueue(prefix string) storage.AdapterQueue
func (*Application) GetMiddleware ¶
func (e *Application) GetMiddleware() map[string]interface{}
GetMiddleware 获取所有中间件
func (*Application) GetMiddlewareKey ¶
func (e *Application) GetMiddlewareKey(key string) interface{}
GetMiddlewareKey 获取对应key的中间件
func (*Application) GetModerationAdapter ¶ added in v1.4.11
func (e *Application) GetModerationAdapter() moderation.AdapterModeration
GetModerationAdapter 获取缓存
func (*Application) GetModerationAdapters ¶ added in v1.4.11
func (e *Application) GetModerationAdapters() map[string]moderation.AdapterModeration
GetModerationAdapters 获取缓存
func (*Application) GetModerationKey ¶ added in v1.4.11
func (e *Application) GetModerationKey(key string) moderation.AdapterModeration
GetModerationKey 获取带租户标记的cos
func (*Application) GetPaymentServiceAdapter ¶ added in v1.4.10
func (e *Application) GetPaymentServiceAdapter() payment.AdapterPaymentService
GetPaymentServiceAdapter 获取支付
func (*Application) GetPaymentServiceAdapters ¶ added in v1.4.10
func (e *Application) GetPaymentServiceAdapters() map[string]payment.AdapterPaymentService
GetPaymentServiceAdapters 获取支付
func (*Application) GetPaymentServiceKey ¶ added in v1.4.10
func (e *Application) GetPaymentServiceKey(key string) payment.AdapterPaymentService
GetPaymentServiceKey 获取支付
func (*Application) GetQueueAdapter ¶
func (e *Application) GetQueueAdapter() storage.AdapterQueue
GetQueueAdapter 获取队列适配器
func (*Application) GetQueuePrefix ¶
func (e *Application) GetQueuePrefix(key string) storage.AdapterQueue
GetQueuePrefix 获取带租户标记的queue
func (*Application) GetSmsAdapter ¶ added in v1.3.13
func (e *Application) GetSmsAdapter() message.AdapterSms
GetSmsAdapter 获取缓存
func (*Application) GetSmsAdapters ¶ added in v1.3.13
func (e *Application) GetSmsAdapters() map[string]message.AdapterSms
GetSmsAdapters 获取缓存
func (*Application) GetSmsKey ¶ added in v1.3.13
func (e *Application) GetSmsKey(key string) message.AdapterSms
GetSmsKey 获取带租户标记的sms
func (*Application) GetStreamMessage ¶
func (e *Application) GetStreamMessage(id, stream string, value map[string]interface{}) (storage.Messager, error)
GetStreamMessage 获取队列需要用的message
func (*Application) GetThirdPartyAdapter ¶ added in v1.3.16
func (e *Application) GetThirdPartyAdapter() third_party.AdapterThirdParty
GetThirdPartyAdapter 获取缓存
func (*Application) GetThirdPartyAdapters ¶ added in v1.3.16
func (e *Application) GetThirdPartyAdapters() map[string]third_party.AdapterThirdParty
GetThirdPartyAdapters 获取缓存
func (*Application) GetThirdPartyKey ¶ added in v1.3.16
func (e *Application) GetThirdPartyKey(key string) third_party.AdapterThirdParty
GetThirdPartyKey 获取带租户标记的amqp
func (*Application) SetAmqpAdapter ¶
func (e *Application) SetAmqpAdapter(key string, c message.AdapterAmqp)
SetAmqpAdapter 设置缓存
func (*Application) SetAppRouters ¶ added in v1.3.25
func (e *Application) SetAppRouters(appRouters func())
SetAppRouters 设置app的路由
func (*Application) SetBlockChainAdapter ¶ added in v1.3.17
func (e *Application) SetBlockChainAdapter(key string, c block_chain.AdapterBroker)
SetBlockChainAdapter 设置缓存
func (*Application) SetCacheAdapter ¶
func (e *Application) SetCacheAdapter(c storage.AdapterCache)
SetCacheAdapter 设置缓存
func (*Application) SetCasbin ¶
func (e *Application) SetCasbin(key string, enforcer *casbin.SyncedEnforcer)
func (*Application) SetConfig ¶ added in v1.3.25
func (e *Application) SetConfig(key string, value interface{})
SetConfig 设置对应key的config
func (*Application) SetCrontab ¶
func (e *Application) SetCrontab(key string, crontab *cron.Cron)
SetCrontab 设置对应key的crontab
func (*Application) SetEngine ¶
func (e *Application) SetEngine(engine http.Handler)
SetEngine 设置路由引擎
func (*Application) SetFileStoreAdapter ¶
func (e *Application) SetFileStoreAdapter(key string, c storage.AdapterFileStore)
SetFileStoreAdapter 设置缓存
func (*Application) SetHandler ¶
func (e *Application) SetHandler(key string, routerGroup func(r *gin.RouterGroup, hand ...*gin.HandlerFunc))
func (*Application) SetLocationBasedServiceAdapter ¶ added in v1.3.28
func (e *Application) SetLocationBasedServiceAdapter(key string, c lbs.AdapterLocationBasedService)
SetLocationBasedServiceAdapter 设置LBS
func (*Application) SetLockerAdapter ¶
func (e *Application) SetLockerAdapter(c storage.AdapterLocker)
SetLockerAdapter 设置分布式锁
func (*Application) SetMailAdapter ¶ added in v1.3.13
func (e *Application) SetMailAdapter(key string, c message.AdapterMail)
SetMailAdapter 设置缓存
func (*Application) SetMiddleware ¶
func (e *Application) SetMiddleware(key string, middleware interface{})
SetMiddleware 设置中间件
func (*Application) SetModerationAdapter ¶ added in v1.4.11
func (e *Application) SetModerationAdapter(key string, c moderation.AdapterModeration)
SetModerationAdapter 设置缓存
func (*Application) SetPaymentServiceAdapter ¶ added in v1.4.10
func (e *Application) SetPaymentServiceAdapter(key string, c payment.AdapterPaymentService)
SetPaymentServiceAdapter 设置支付
func (*Application) SetQueueAdapter ¶
func (e *Application) SetQueueAdapter(c storage.AdapterQueue)
SetQueueAdapter 设置队列适配器
func (*Application) SetSmsAdapter ¶ added in v1.3.13
func (e *Application) SetSmsAdapter(key string, c message.AdapterSms)
SetSmsAdapter 设置缓存
func (*Application) SetThirdPartyAdapter ¶ added in v1.3.16
func (e *Application) SetThirdPartyAdapter(key string, c third_party.AdapterThirdParty)
SetThirdPartyAdapter 设置缓存
type BlockChain ¶ added in v1.3.17
type BlockChain struct {
// contains filtered or unexported fields
}
type Cache ¶
type Cache struct {
// contains filtered or unexported fields
}
func (Cache) DelPattern ¶ added in v1.3.30
DelPattern delete key in cache
func (Cache) HashDelPattern ¶ added in v1.3.30
HashDelPattern delete one key:value pair in hashtable cache
type FileStore ¶
type FileStore struct {
// contains filtered or unexported fields
}
type Locker ¶
type Locker struct {
// contains filtered or unexported fields
}
type Mail ¶ added in v1.3.13
type Mail struct {
// contains filtered or unexported fields
}
type Moderation ¶ added in v1.4.11
type Moderation struct {
// contains filtered or unexported fields
}
func (*Moderation) AuditImage ¶ added in v1.4.11
func (e *Moderation) AuditImage(url string, result *int, label *string, score *int, detail *string) error
AuditImage 图片审核
func (*Moderation) AuditResult ¶ added in v1.4.13
func (e *Moderation) AuditResult(body *[]byte, result *int, label *string, score *int, detail *string, jobId *string) error
AuditResult 审核结果
func (*Moderation) AuditText ¶ added in v1.4.11
func (e *Moderation) AuditText(content string, result *int, label *string, score *int, detail *string) error
AuditText 文本审核
func (*Moderation) AuditVideo ¶ added in v1.4.11
func (e *Moderation) AuditVideo(url string, frame int32, jobId *string) error
AuditVideo 视频审核
func (*Moderation) GetClient ¶ added in v1.4.11
func (e *Moderation) GetClient() interface{}
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
type Runtime ¶
type Runtime interface { // SetDb 多db设置,⚠️SetDbs不允许并发,可以根据自己的业务,例如app分库、host分库 SetDb(key string, db *gorm.DB) GetDb() map[string]*gorm.DB GetDbByKey(key string) *gorm.DB SetCasbin(key string, enforcer *casbin.SyncedEnforcer) GetCasbin() map[string]*casbin.SyncedEnforcer GetCasbinKey(key string) *casbin.SyncedEnforcer // SetEngine 使用的路由 SetEngine(engine http.Handler) GetEngine() http.Handler GetRouter() []Router // SetLogger 使用go-admin定义的logger,参考来源go-micro SetLogger(logger logger.Logger) GetLogger() logger.Logger // SetCrontab crontab SetCrontab(key string, crontab *cron.Cron) GetCrontab() map[string]*cron.Cron GetCrontabKey(key string) *cron.Cron // SetMiddleware middleware SetMiddleware(string, interface{}) GetMiddleware() map[string]interface{} GetMiddlewareKey(key string) interface{} // SetCacheAdapter cache SetCacheAdapter(storage.AdapterCache) GetCacheAdapter() storage.AdapterCache GetCachePrefix(string) storage.AdapterCache GetMemoryQueue(string) storage.AdapterQueue SetQueueAdapter(storage.AdapterQueue) GetQueueAdapter() storage.AdapterQueue GetQueuePrefix(string) storage.AdapterQueue SetLockerAdapter(storage.AdapterLocker) GetLockerAdapter() storage.AdapterLocker GetLockerPrefix(string) storage.AdapterLocker SetSmsAdapter(string, message.AdapterSms) GetSmsAdapter() message.AdapterSms GetSmsAdapters() map[string]message.AdapterSms GetSmsKey(key string) message.AdapterSms SetMailAdapter(string, message.AdapterMail) GetMailAdapter() message.AdapterMail GetMailAdapters() map[string]message.AdapterMail GetMailKey(key string) message.AdapterMail SetFileStoreAdapter(string, storage.AdapterFileStore) GetFileStoreAdapter() storage.AdapterFileStore GetFileStoreAdapters() map[string]storage.AdapterFileStore GetFileStoreKey(string) storage.AdapterFileStore SetModerationAdapter(string, moderation.AdapterModeration) GetModerationAdapter() moderation.AdapterModeration GetModerationAdapters() map[string]moderation.AdapterModeration GetModerationKey(string) moderation.AdapterModeration SetAmqpAdapter(string, message.AdapterAmqp) GetAmqpAdapter() message.AdapterAmqp GetAmqpAdapters() map[string]message.AdapterAmqp GetAmqpKey(key string) message.AdapterAmqp SetThirdPartyAdapter(string, third_party.AdapterThirdParty) GetThirdPartyAdapter() third_party.AdapterThirdParty GetThirdPartyAdapters() map[string]third_party.AdapterThirdParty GetThirdPartyKey(key string) third_party.AdapterThirdParty SetLocationBasedServiceAdapter(string, lbs.AdapterLocationBasedService) GetLocationBasedServiceAdapter() lbs.AdapterLocationBasedService GetLocationBasedServiceAdapters() map[string]lbs.AdapterLocationBasedService GetLocationBasedServiceKey(string) lbs.AdapterLocationBasedService SetPaymentServiceAdapter(string, payment.AdapterPaymentService) GetPaymentServiceAdapter() payment.AdapterPaymentService GetPaymentServiceAdapters() map[string]payment.AdapterPaymentService GetPaymentServiceKey(string) payment.AdapterPaymentService SetBlockChainAdapter(string, block_chain.AdapterBroker) GetBlockChainAdapter() block_chain.AdapterBroker GetBlockChainAdapters() map[string]block_chain.AdapterBroker GetBlockChainKey(key string) block_chain.AdapterBroker SetHandler(key string, routerGroup func(r *gin.RouterGroup, hand ...*gin.HandlerFunc)) GetHandler() map[string][]func(r *gin.RouterGroup, hand ...*gin.HandlerFunc) GetHandlerPrefix(key string) []func(r *gin.RouterGroup, hand ...*gin.HandlerFunc) GetStreamMessage(id, stream string, value map[string]interface{}) (storage.Messager, error) GetConfig(key string) interface{} SetConfig(key string, value interface{}) // SetAppRouters set AppRouter SetAppRouters(appRouters func()) GetAppRouters() []func() }
type Sms ¶ added in v1.3.13
type Sms struct {
// contains filtered or unexported fields
}
type ThirdParty ¶ added in v1.3.16
type ThirdParty struct {
// contains filtered or unexported fields
}
func NewThirdParty ¶ added in v1.4.13
func NewThirdParty(prefix string, thirdParty third_party.AdapterThirdParty) *ThirdParty
NewThirdParty 创建对应上下文缓存
func (*ThirdParty) GetAccessToken ¶ added in v1.3.16
func (e *ThirdParty) GetAccessToken(cache storage.AdapterCache) (string, error)
func (*ThirdParty) GetConnectUrl ¶ added in v1.3.16
func (e *ThirdParty) GetConnectUrl(state, scope string, popUp bool) (string, error)
func (*ThirdParty) GetJSApiTicket ¶ added in v1.3.30
func (e *ThirdParty) GetJSApiTicket(cache storage.AdapterCache) (string, error)
func (*ThirdParty) GetUserAccessToken ¶ added in v1.3.16
func (e *ThirdParty) GetUserAccessToken(code, state string) (string, error)
func (*ThirdParty) GetUserInfo ¶ added in v1.3.16
func (e *ThirdParty) GetUserInfo(userAccessToken, openId string) (string, error)
func (*ThirdParty) RefreshUserToken ¶ added in v1.3.30
func (e *ThirdParty) RefreshUserToken(refreshToken string, appId string) (string, error)
func (*ThirdParty) SendTemplateMessage ¶ added in v1.3.16
func (e *ThirdParty) SendTemplateMessage(cache storage.AdapterCache, openId, templateId, url string, data []byte) (string, error)
SendTemplateMessage 发送模板消息