component

type CloseHandler interface {
	Close() error
}

type ComponentFunc func(c IContainer) error

type DeleteFallbackHandler interface {
	DeleteFallback(c *context.Context) interface{}
}

type DeleteHandler interface {
	DeleteHandle(c *context.Context) interface{}
}

type FallbackHandler interface {
	Fallback(c *context.Context) interface{}
}

type FallbackServiceFunc func(c *context.Context) (rs interface{})

type GetFallbackHandler interface {
	GetFallback(c *context.Context) interface{}
}

type GetHandler interface {
	GetHandle(c *context.Context) interface{}
}

type GlobalVarObjectCache struct {
	IContainer
	// contains filtered or unexported fields
}

type Handler interface {
	Handle(c *context.Context) interface{}
}

type HeadHandler interface {
	HeadHandle(c *context.Context) interface{}
}

type IComponent interface {
	AddCustomerService(service string, h interface{}, groupName string, tags ...string)
	IsCustomerService(service string, group ...string) bool
	GetFallbackHandlers() map[string]interface{}
	AddFallbackHandlers(map[string]interface{})
	LoadServices() error
	GetRegistryNames(groups ...string) map[string][]string
	GetGroupServices(group ...string) []string
	GetServices() []string

	GetGroups(service string) []string
	GetTags(service string) []string

	Fallback(c *context.Context) (rs interface{})
	Handling(c *context.Context) (rs interface{})
	Handled(c *context.Context) (rs interface{})
	Handle(c *context.Context) interface{}

	GetMeta(key string) interface{}
	SetMeta(key string, value interface{})

	Close() error
}

type IComponentCache interface {
	GetRegularCache(names ...string) (c cache.ICache)
	GetCache(names ...string) (c cache.ICache, err error)
	GetCacheBy(tpName string, name string) (c cache.ICache, err error)
	SaveCacheObject(tpName string, name string, f func(c conf.IConf) (cache.ICache, error)) (bool, cache.ICache, error)
	Close() error
}

type IComponentDB interface {
	GetRegularDB(names ...string) (d db.IDB)
	GetDB(names ...string) (d db.IDB, err error)
	GetDBBy(tpName string, name string) (c db.IDB, err error)
	SaveDBObject(tpName string, name string, f func(c conf.IConf) (db.IDB, error)) (bool, db.IDB, error)
	Close() error
}

type IComponentGlobalVarObject interface {
	GetGlobalObject(tpName string, name string) (c interface{}, err error)
	SaveGlobalObject(tpName string, name string, f func(c conf.IConf) (interface{}, error)) (bool, interface{}, error)
	Close() error
}

type IComponentHandler interface {
	GetServices() map[string]map[string]interface{}
	GetHandlings() []ServiceFunc
	GetHandleds() []ServiceFunc
	GetInitializings() []ComponentFunc
	GetClosings() []ComponentFunc
	GetTags(name string) []string
	GetDynamicQueue() chan *conf.Queue
	GetDynamicCron() chan *conf.Task
	GetRPCTLS() map[string][]string
	//GetBalancer 获取负载均衡模式
	GetBalancer() map[string]*rpc.BalancerMode
}

type IComponentInfluxDB interface {
	GetRegularInflux(names ...string) (c influxdb.IInfluxClient)
	GetInflux(names ...string) (d influxdb.IInfluxClient, err error)
	GetInfluxBy(tpName string, name string) (c influxdb.IInfluxClient, err error)
	SaveInfluxObject(tpName string, name string, f func(c conf.IConf) (influxdb.IInfluxClient, error)) (bool, influxdb.IInfluxClient, error)
	Close() error
}

type IComponentQueue interface {
	GetRegularQueue(names ...string) (c queue.IQueue)
	GetQueue(names ...string) (q queue.IQueue, err error)
	GetQueueBy(tpName string, name string) (c queue.IQueue, err error)
	SaveQueueObject(tpName string, name string, f func(c conf.IConf) (queue.IQueue, error)) (bool, queue.IQueue, error)
	Close() error
}

type IComponentRegistry interface {
	GetServices() map[string]map[string]interface{}
	GetHandlings() []ServiceFunc
	GetHandleds() []ServiceFunc
	GetInitializings() []ComponentFunc
	GetClosings() []ComponentFunc
	GetRPCTLS() map[string][]string
	IServiceRegistry
}

type IContainer interface {
	context.RPCInvoker
	GetComponent() IComponent
	conf.ISystemConf
	conf.IVarConf
	conf.IMainConf
	GetRegistry() registry.IRegistry
	GetLogger() logger.ILogging

	GetTags(name string) []string

	IContainerCache
	IContainerDB
	IContainerInflux
	IContainerQueue

	GetGlobalObject(tpName string, name string) (c interface{}, err error)
	SaveGlobalObject(tpName string, name string, f func(c conf.IConf) (interface{}, error)) (bool, interface{}, error)
	Close() error
}

type IContainerCache interface {
	GetRegularCache(names ...string) (c cache.ICache)
	GetCache(names ...string) (c cache.ICache, err error)
	GetCacheBy(tpName string, name string) (c cache.ICache, err error)
	SaveCacheObject(tpName string, name string, f func(c conf.IConf) (cache.ICache, error)) (bool, cache.ICache, error)
}

type IContainerDB interface {
	GetRegularDB(names ...string) (d db.IDB)
	GetDB(names ...string) (d db.IDB, err error)
	GetDBBy(tpName string, name string) (c db.IDB, err error)
	SaveDBObject(tpName string, name string, f func(c conf.IConf) (db.IDB, error)) (bool, db.IDB, error)
}

type IContainerInflux interface {
	GetRegularInflux(names ...string) (c influxdb.IInfluxClient)
	GetInflux(names ...string) (d influxdb.IInfluxClient, err error)
	GetInfluxBy(tpName string, name string) (c influxdb.IInfluxClient, err error)
	SaveInfluxObject(tpName string, name string, f func(c conf.IConf) (influxdb.IInfluxClient, error)) (bool, influxdb.IInfluxClient, error)
}

type IContainerQueue interface {
	GetRegularQueue(names ...string) (c queue.IQueue)
	GetQueue(names ...string) (q queue.IQueue, err error)
	GetQueueBy(tpName string, name string) (c queue.IQueue, err error)
	SaveQueueObject(tpName string, name string, f func(c conf.IConf) (queue.IQueue, error)) (bool, queue.IQueue, error)
}

type IHandler interface {
	Handle(c *context.Context) interface{}
}

type IServiceRegistry interface {
	//Customer 添加自定义服务
	Customer(group string, name string, h interface{}, tags ...string)

	//Micro 添加微服务（api,rpc）
	Micro(name string, h interface{}, tags ...string)

	//API 添加微服务
	API(name string, h interface{}, tags ...string)

	//RPC 添加微服务
	RPC(name string, h interface{}, tags ...string)

	//Flow 添加自动流程(mqc,cron)
	Flow(name string, h interface{}, tags ...string)

	//MQC 添加自动流程
	MQC(name string, h interface{}, tags ...string)

	//CRON 添加自动流程
	CRON(name string, h interface{}, tags ...string)

	//WS 添加websocket(mqc,cron)
	WS(name string, h interface{}, tags ...string)

	//Page 添加web页面服务(web)
	Web(name string, h interface{}, tags ...string)

	//Fallback 默认降级函数
	Fallback(name string, h interface{})

	//Get RESTful GET请求服务
	Get(name string, h interface{})

	//Get RESTful GET请求服务的降级服务
	GetFallback(name string, h interface{})

	//Post RESTful POST请求服务
	Post(name string, h interface{})

	//PostFallback RESTful POST请求服务的降级服务
	PostFallback(name string, h interface{})

	//Delete RESTful DELETE请求服务
	Delete(name string, h interface{})

	//DeleteFallback RESTful DELETE请求服务的降级服务
	DeleteFallback(name string, h interface{})

	//Put RESTful PUT请求服务
	Put(name string, h interface{})

	//PutFallback RESTful PUT请求服务的降级服务
	PutFallback(name string, h interface{})

	//Initializing 初始化
	Initializing(c func(IContainer) error)

	//GetDynamicQueue 获取动态队列注册消息
	GetDynamicQueue() chan *conf.Queue

	//GetDynamicCron 获取动态任务
	GetDynamicCron() chan *conf.Task

	//Closing 关闭组件
	Closing(c func(IContainer) error)
	//Handling 每个请求的预处理函数
	Handling(h func(c *context.Context) (rs interface{}))

	//Handled 请求后处理函数
	Handled(h func(c *context.Context) (rs interface{}))

	GetTags(name string) []string

	//AddRPCTLS 添加RPC安全认证证书
	AddRPCTLS(platName string, cert string, key string) error

	//SetBalancer 设置平台对应的负载均衡器 platName:平台名称 mode:rpc.RoundRobin 或rpc.LocalFirst
	SetBalancer(platName string, mode int, p ...string) error

	//GetBalancer 获取负载均衡模式
	GetBalancer() map[string]*rpc.BalancerMode
}

type PostFallbackHandler interface {
	PostFallback(c *context.Context) interface{}
}

type PostHandler interface {
	PostHandle(c *context.Context) interface{}
}

type PutFallbackHandler interface {
	PutFallback(c *context.Context) interface{}
}

type PutHandler interface {
	PutHandle(c *context.Context) interface{}
}

type ServiceFunc func(c *context.Context) (rs interface{})

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

type StandardCache struct {
	IContainer
	// contains filtered or unexported fields
}

type StandardComponent struct {
	HandlerCache map[string]map[string]interface{} //handler缓存
	Container    IContainer
	Name         string //组件名称

	Handlers         map[string]interface{} //每个服务对应的处理程序
	FallbackHandlers map[string]interface{} //每个服务对应的降级处理程序
	Services         []string               //所有服务
	GroupServices    map[string][]string    //每个分组包含的服务
	ServiceGroup     map[string][]string    //每个服务对应的分组
	ServiceTags      map[string][]string    //每个服务对应的页面
	CloseHandler     []interface{}          //用于关闭所有handler
	// contains filtered or unexported fields
}

type StandardDB struct {
	IContainer
	// contains filtered or unexported fields
}

type StandardInfluxDB struct {
	IContainer
	// contains filtered or unexported fields
}

type StandardQueue struct {
	IContainer
	// contains filtered or unexported fields
}