core

type API struct {
	Name     string   `json:"name"` //接口名称
	Desc     string   `json:"desc"` //接口描述
	Disabled bool     `json:"disabled"`
	EndPoint EndPoint `json:"endpoint"` //API映射的slot
}

type APIDefine struct {
	Name        string    `json:"name"`
	APIVersions []OpenAPI `json:"versions"`
}

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

type APIGateway struct {
	EntityConfBase

	UseBreaker                    bool
	BreakerLimitAPI               bool //针对API
	BreakerLimitIP                bool //针对IP
	BreakerLimitUser              bool //针对用户
	BreakerRequestTimeout         int
	BreakerMaxConcurrentRequest   int
	BreakerRequestVolumeThreshold int
	BreakerSleepWindow            int
	BreakerErrorPercentThreshold  int
	BreakerDashboard              bool
	UserField                     string
	AddressField                  string
}

type APIGatewayOptions struct {
	ServerOptions

	Connectors  []IAPIConnector
	Middlewares []IAPIMiddleware
	Packers     []IAPIDataPacker
	I18n        IAPIi18n
}

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

type BaseAssetManager struct {
}

type BaseConnector struct {
	Gateway IAPIGateway

	Packer IAPIDataPacker
	// contains filtered or unexported fields
}

type BaseMiddleware struct {
	Gateway IAPIGateway
	// contains filtered or unexported fields
}

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

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

type BaseRouter struct {
	Services map[string]IService
	Entities map[string]IEntity
	// contains filtered or unexported fields
}

type CallerResponse struct {
	Data  interface{}
	Error *herrors.Error
}

type CmdArgs struct {
	Env string `cli:"e,env" usage:"当前运行环境(dev/test)"`
}

type ConnectorConf struct {
	EntityConfBase

	Lang   string
	Packer string
	Name   string
}

type DefaultAPIi18n struct {
	BaseAPIi18n
	// contains filtered or unexported fields
}

type EndPoint struct {
	Service string `json:"service"`
	Slot    string `json:"slot"`
}

type EntityConfBase struct {
	Disabled bool
	EID      string
}

type EntityGetter func(params htypes.Map) (htypes.Any, *herrors.Error)

type EntityMeta struct {
	ServerEID string `json:"server_eid"`
	EID       string `json:"eid"`
	Type      string `json:"type"`
	Class     string `json:"class"`
}

type EntitySetter func(params htypes.Map) *herrors.Error

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

type EntityStubOptions struct {
	Owner             IEntity
	Ping              EntityGetter //联通情况
	GetLoad           EntityGetter //负载情况
	ResetConfig       EntitySetter //恢复设置
	UpdateConfigItems EntitySetter //修改设置
	GetConfig         EntityGetter //获取全部配置
	GetConfigItems    EntityGetter //获取某项配置
}

type FileAssets struct {
	BaseAssetManager
}

type IAPIConnector interface {
	Open(gw IAPIGateway, ins IAPIConnector) *herrors.Error
	Name() string
	Close()
}

type IAPIDataPacker interface {
	Open(gw IAPIGateway, ins IAPIDataPacker) *herrors.Error
	Close()
	Marshal(data htypes.Any) ([]byte, *herrors.Error)
	Unmarshal(bytes []byte) (htypes.Any, *herrors.Error)
}

type IAPIGateway interface {
	Start()
	Shutdown()
	Server() IServer
	Router() IRouter
	Packer(name string) IAPIDataPacker
	I18n() IAPIi18n
	PreRequestMiddleware(version string, api string, params htypes.Map) *herrors.Error
	RequestAPI(version string, api string, params htypes.Map) (htypes.Any, *herrors.Error)
	RequestWSAPI(version string, api string, params htypes.Map) (htypes.Any, *herrors.Error)
}

type IAPIMiddleware interface {
	Open(gw IAPIGateway, ins IAPIMiddleware) *herrors.Error
	Close()
	HandleIn(seq uint64, version string, api string, data htypes.Map) (stop bool, err *herrors.Error)                      //入口处理
	HandleOut(seq uint64, version string, api string, result htypes.Any, e *herrors.Error) (stop bool, err *herrors.Error) //出口处理
	Type() string
}

type IAPIi18n interface {
	Open() *herrors.Error
	Close()
	Translate(lang string, text string) string
}

type IAssetManager interface {
	Init() *herrors.Error
	File(path string) ([]byte, *herrors.Error)
}

type IEntity interface {
	Class() string
	Server() IServer
	Config() IEntityConf

	EntityMeta() *EntityMeta
	EntityStub() *EntityStub
}

type IEntityConf interface {
	GetEID() string
	GetDisabled() bool
	SetEID(eid string)
	SetDisabled(dis bool)
}

type IPlugin interface {
	Open(server IServer, ins IPlugin) *herrors.Error
	Close()
	Capability() htypes.Any
}

type IRouter interface {
	Open(s IServer, ins IRouter) *herrors.Error
	Close()

	//服务相关方法
	RegisterService(s IService) *herrors.Error                                                  //注册服务
	UnRegisterService(s IService)                                                               //注销服务
	RequestService(service string, slot string, params htypes.Map) (htypes.Any, *herrors.Error) //同步请求服务

	// 实体治理相关方法
	AllEntities() []*EntityMeta
	RegisterEntity(m IEntity) *herrors.Error
	ManageEntity(mm *EntityMeta, slot string, params htypes.Map) (htypes.Any, *herrors.Error)
}

type IServer interface {
	Start()
	Shutdown()

	Router() IRouter
	Plugin(cls string) IPlugin
	Services() map[string]IService
	Slot(service string, slot string) *Slot
	Assets() IAssetManager

	RegisterService(service IService, options htypes.Any)
	RequestService(service string, slot string, params htypes.Map) (htypes.Any, *herrors.Error)
}

type IService interface {
	Open(s IServer, instance IService, options htypes.Any) *herrors.Error
	Close()
	Name() string

	//插件依赖申请
	UsePlugin(name string) IPlugin

	//槽相关方法
	Slot(slot string) *Slot

	//服务调用相关方法
	Request(slot string, params htypes.Map) (htypes.Any, *herrors.Error)
}

type ISlotRequest interface {
	FromJSON(str string, instance interface{}) *herrors.Error
	FromMap(data htypes.Map, ins interface{}) *herrors.Error
}

type InMiddleware struct {
	BaseMiddleware
}

type InOutMiddleware struct {
	BaseMiddleware
}

type MethodCaller struct {
	Object  reflect.Value
	Handler reflect.Value
}

type OpenAPI struct {
	Version string `json:"version"`
	APIs    []API  `json:"apis"`
}

type OutMiddleware struct {
	BaseMiddleware
}

type PbServiceRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Slot                 string   `protobuf:"bytes,2,opt,name=slot,proto3" json:"slot,omitempty"`
	Encoding             string   `protobuf:"bytes,3,opt,name=encoding,proto3" json:"encoding,omitempty"`
	Params               []byte   `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type PbServiceResponse struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type PluginConf struct {
	EntityConfBase
}

type RpcRequestArguments struct {
	Service string
	Slot    string
	Params  map[string]interface{}
}

type Server struct {
	EntityConfBase

	MaxProcs  int
	PprofPort int
}

type ServerImplement struct {
	Instance IServer
	// contains filtered or unexported fields
}

type ServerOptions struct {
	Router        IRouter
	Plugins       []IPlugin
	AssetsManager IAssetManager
}

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

type ServiceConf struct {
	EntityConfBase

	Name         string
	LimitedSlots string
}

type Slot struct {
	Name        string                    `json:"name"`
	Params      map[string]*SlotParameter `json:"params"`
	ReqInstance htypes.Any
}

type SlotParameter struct {
	Name            string
	Require         bool
	InsensitiveCase bool
	Validate        string
	Type            string
}

type SlotRequestBase struct {
}

type SlotResponse struct {
	Error *herrors.Error
	Data  interface{}
}

type SlotWsRequestBase struct {
	SlotRequestBase

	WsID   *string `json:"WsID"`
	INITWS *bool   `json:"INITWS"`
	BREAK  *bool   `json:"BREAK"`
}

type SlotsRequest struct {
	SlotRequestBase
}