application

package
v0.0.1-202407111759 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 11, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

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 NewQueue

func NewQueue(prefix string, queue storage.AdapterQueue) storage.AdapterQueue

NewQueue 创建对应上下文队列

Types

type AppModule

type AppModule struct {
	// contains filtered or unexported fields
}

func (AppModule) AddServer

func (a AppModule) AddServer(key string, server transport.Server) error

func (AppModule) GetServer

func (a AppModule) GetServer(key string) (transport.Server, error)

type Application

type Application struct {
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig() *Application

NewConfig 默认值

func (*Application) AddPlugin

func (e *Application) AddPlugin(plugin IPlugin) error

AddPlugin implements IApplication.

func (*Application) GetApp

func (e *Application) GetApp() []IAppModule

GetApp 获取所有map里的app数据

func (*Application) GetAppByKey

func (e *Application) GetAppByKey(key string) IAppModule

GetAppByKey 根据key获取app

func (*Application) GetAppRouters

func (e *Application) GetAppRouters() []func()

GetAppRouters 获取app的路由

func (*Application) GetAuth

func (e *Application) GetAuth() jwtauth.IAuth

func (*Application) GetBefore

func (e *Application) GetBefore() []func()

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) GetCasbinExclude

func (e *Application) GetCasbinExclude() map[string]interface{}

GetCasbinExclude 获取所有map里的Exclude数据

func (*Application) GetCasbinExcludeByKey

func (e *Application) GetCasbinExcludeByKey(key string) interface{}

GetCasbinExcludeByKey 根据key获取Exclude

func (*Application) GetCasbinKey

func (e *Application) GetCasbinKey(key string) *casbin.SyncedEnforcer

GetCasbinKey 根据key获取casbin

func (*Application) GetConfig

func (e *Application) GetConfig() *config.Config

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) GetDb

func (e *Application) GetDb() map[string]*gorm.DB

GetDb 获取所有map里的db数据

func (*Application) GetDbByKey

func (e *Application) GetDbByKey(key string) *gorm.DB

GetDbByKey 根据key获取db

func (*Application) GetEngine

func (e *Application) GetEngine() http.Handler

GetEngine 获取路由引擎

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) GetLockerAdapter

func (e *Application) GetLockerAdapter() storage.AdapterLocker

GetLockerAdapter 获取分布式锁

func (*Application) GetLockerPrefix

func (e *Application) GetLockerPrefix(key string) storage.AdapterLocker

func (*Application) GetLogger

func (e *Application) GetLogger() logger.Logger

GetLogger 获取日志组件

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) GetPlugin

func (e *Application) GetPlugin(key string) (IPlugin, bool)

GetPlugin implements IApplication.

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) GetRouter

func (e *Application) GetRouter() []Router

GetRouter 获取路由表

func (*Application) GetStorage

func (e *Application) GetStorage() *StorageSet

func (*Application) GetStreamMessage

func (e *Application) GetStreamMessage(id, stream string, value map[string]interface{}) (storage.Messager, error)

GetStreamMessage 获取队列需要用的message

func (*Application) RemovePlugin

func (e *Application) RemovePlugin(key string) error

RemovePlugin implements IApplication.

func (*Application) SetApp

func (e *Application) SetApp(app IAppModule) error

SetApp 设置对应key的app

func (*Application) SetAppRouters

func (e *Application) SetAppRouters(appRouters func())

SetAppRouters 设置app的路由

func (*Application) SetAuth

func (e *Application) SetAuth(auth jwtauth.IAuth)

func (*Application) SetBefore

func (e *Application) SetBefore(f func())

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) SetCasbinExclude

func (e *Application) SetCasbinExclude(key string, list interface{})

SetCasbinExclude 设置对应key的Exclude

func (*Application) SetConfig

func (e *Application) SetConfig(conf *config.Config)

// SetConfigByTenant 设置对应租户的config

func (e *Application) SetConfigByTenant(tenant string, value map[string]interface{}) {
	e.mux.Lock()
	defer e.mux.Unlock()
	e.configs[tenant] = value
}

// GetConfigByTenant 获取对应租户的config

func (e *Application) GetConfigByTenant(tenant string) interface{} {
	e.mux.Lock()
	defer e.mux.Unlock()
	return e.configs[tenant]
}

SetConfig 设置对应key的config

func (*Application) SetCrontab

func (e *Application) SetCrontab(key string, crontab *cron.Cron)

SetCrontab 设置对应key的crontab

func (*Application) SetDb

func (e *Application) SetDb(key string, db *gorm.DB)

SetDb 设置对应key的db

func (*Application) SetEngine

func (e *Application) SetEngine(engine http.Handler)

SetEngine 设置路由引擎

func (*Application) SetHandler

func (e *Application) SetHandler(key string, routerGroup func(r *gin.RouterGroup, hand ...*gin.HandlerFunc))

func (*Application) SetLockerAdapter

func (e *Application) SetLockerAdapter(c storage.AdapterLocker)

SetLockerAdapter 设置分布式锁

func (*Application) SetLogger

func (e *Application) SetLogger(l logger.Logger)

SetLogger 设置日志组件

func (*Application) SetMiddleware

func (e *Application) SetMiddleware(key string, middleware interface{})

SetMiddleware 设置中间件

func (*Application) SetQueueAdapter

func (e *Application) SetQueueAdapter(c storage.AdapterQueue)

SetQueueAdapter 设置队列适配器

func (*Application) Start

func (e *Application) Start(ctx context.Context) error

func (*Application) Stop

func (e *Application) Stop(ctx context.Context) error

type Cache

type Cache struct {
	// contains filtered or unexported fields
}

func (Cache) AddList

func (e Cache) AddList(key string, val ...interface{}) error

func (Cache) Append

func (e Cache) Append(key string, val ...interface{}) error

func (Cache) Connect

func (e Cache) Connect() error

Connect 初始化

func (Cache) Decrease

func (e Cache) Decrease(key string) error

func (Cache) Del

func (e Cache) Del(key string) error

Del delete key in cache

func (Cache) Expire

func (e Cache) Expire(key string, dur time.Duration) error

func (Cache) Get

func (e Cache) Get(key string) (string, error)

Get val in cache

func (Cache) GetList

func (e Cache) GetList(key string) ([]string, error)

func (Cache) GetPrefix

func (e Cache) GetPrefix(key string, length ...int) ([]string, error)

func (Cache) HashDel

func (e Cache) HashDel(hk, key string) error

HashDel delete one key:value pair in hashtable cache

func (Cache) HashGet

func (e Cache) HashGet(hk, key string) (string, error)

HashGet get val in hashtable cache

func (Cache) HashGetAll

func (e Cache) HashGetAll(hk string) (map[string]string, error)

func (*Cache) HashSet

func (e *Cache) HashSet(hk string, value interface{}, expire int) error

HashSet implements storage.AdapterCache.

func (Cache) Increase

func (e Cache) Increase(key string) error

Increase value

func (Cache) PutToken

func (e Cache) PutToken(token *oauth2.Token) error

PutToken 设置微信oauth2 token

func (Cache) Set

func (e Cache) Set(key string, val interface{}, expire int) error

Set val in cache

func (*Cache) SetPrefix

func (e *Cache) SetPrefix(prefix string)

SetPrefix 设置前缀

func (*Cache) String

func (e *Cache) String() string

String string输出

func (Cache) Token

func (e Cache) Token() (token *oauth2.Token, err error)

Token 获取微信oauth2 token

type IAppModule

type IAppModule interface {
	ModuleName() string
	Install(core IApplication) error
	InitRouter(core IApplication) error
	Migrate(core IApplication) error
	Start(context.Context) error
	Stop(context.Context) error
	AddServer(key string, server transport.Server) error
	GetServer(key string) (transport.Server, error)
}

type IApplication

type IApplication interface {
	// SetDb 多db设置,⚠️SetDbs不允许并发,可以根据自己的业务,例如app分库、host分库
	SetDb(key string, db *gorm.DB)
	GetDb() map[string]*gorm.DB
	GetDbByKey(key string) *gorm.DB

	GetStorage() *StorageSet

	SetApp(IAppModule) error
	GetApp() []IAppModule
	GetAppByKey(key string) IAppModule

	SetBefore(f func())
	GetBefore() []func()

	SetCasbinExclude(key string, list interface{})
	GetCasbinExclude() map[string]interface{}
	GetCasbinExcludeByKey(key string) interface{}

	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

	SetAuth(auth jwtauth.IAuth)
	GetAuth() jwtauth.IAuth

	AddPlugin(plugin IPlugin) error       // 添加插件
	GetPlugin(key string) (IPlugin, bool) // 获取插件
	RemovePlugin(key string) error        // 移除插件

	// 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

	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)

	// GetConfigByTenant(tenant string) interface{}
	GetConfig() *config.Config
	// SetConfigByTenant(tenant string, value map[string]interface{})
	SetConfig(*config.Config)

	// SetAppRouters set AppRouter
	SetAppRouters(appRouters func())
	GetAppRouters() []func()

	Start(context.Context) error
	Stop(context.Context) error
}

type IPlugin

type IPlugin interface {
	Key() string
	Install(context.Context, IApplication) error // 安装插件
	Uninstall(IApplication) error                // 卸载插件
}

type Locker

type Locker struct {
	// contains filtered or unexported fields
}

func (*Locker) Lock

func (e *Locker) Lock(key string, ttl int64, options *redislock.Options) (*redislock.Lock, error)

Lock 返回分布式锁对象

func (*Locker) String

func (e *Locker) String() string

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

func (*Queue) Append

func (e *Queue) Append(message storage.Messager) error

Append 增加数据到生产者

func (*Queue) Register

func (e *Queue) Register(name string, f storage.ConsumerFunc)

Register 注册消费者

func (*Queue) Run

func (e *Queue) Run()

Run 运行

func (*Queue) Shutdown

func (e *Queue) Shutdown()

Shutdown 停止

func (*Queue) String

func (e *Queue) String() string

type Router

type Router struct {
	HttpMethod, RelativePath, Handler string
}

type Routers

type Routers struct {
	List []Router
}

type StorageSet

type StorageSet struct {
	Cache     storage.AdapterCache // 缓存
	DB        *gorm.DB             // 默认db
	DbResolve map[string]*gorm.DB  // 多db
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL