Documentation ¶
Overview ¶
Package eosc SPDX-License-Identifier: Apache-2.0
Example ¶
type MyConfig struct { Id string `json:"id" require:"" readonly:"true"` Target RequireId `json:"target" skill:"service.service.IService"` } sc, err := schema.Generate(reflect.TypeOf(MyConfig{}), nil) if err != nil { fmt.Println(err) return } data, _ := json.MarshalIndent(sc, "", "\t") fmt.Println(string(data))
Output: ""
Index ¶
- Constants
- Variables
- func CreateFile(name string) (*os.File, error)
- func Decompress(filePath string, dest string) error
- func FileSha1(file *os.File, size int64) (string, error)
- func GetRealIP(r *http.Request) string
- func Now() string
- func SHA1(data []byte) string
- func ToWorkerId(name, profession string) (string, bool)
- func Version() string
- type DriverConfig
- func (*DriverConfig) Descriptor() ([]byte, []int)deprecated
- func (x *DriverConfig) GetDesc() string
- func (x *DriverConfig) GetId() string
- func (x *DriverConfig) GetLabel() string
- func (x *DriverConfig) GetName() string
- func (x *DriverConfig) GetParams() map[string]string
- func (*DriverConfig) ProtoMessage()
- func (x *DriverConfig) ProtoReflect() protoreflect.Message
- func (x *DriverConfig) Reset()
- func (x *DriverConfig) String() string
- type ExtenderBuilder
- type ExtenderRegister
- type ExtendersSettings
- func (*ExtendersSettings) Descriptor() ([]byte, []int)deprecated
- func (x *ExtendersSettings) GetExtenders() map[string]string
- func (*ExtendersSettings) ProtoMessage()
- func (x *ExtendersSettings) ProtoReflect() protoreflect.Message
- func (x *ExtendersSettings) Reset()
- func (x *ExtendersSettings) String() string
- type FormatterConfig
- type IDataMarshaller
- type IEntry
- type IExtenderConfigChecker
- type IExtenderDriver
- type IExtenderDriverFactory
- type IExtenderDriverManager
- type IExtenderDriverRegister
- type IExtenderDrivers
- type IFormatter
- type IFormatterFactory
- type IProfession
- type IProfessions
- type IRegister
- type IUntyped
- type IWorker
- type IWorkerResources
- type IWorkers
- type Item
- type ProcessStatus
- func (*ProcessStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessStatus) GetData() []byte
- func (x *ProcessStatus) GetMsg() string
- func (x *ProcessStatus) GetStatus() int32
- func (*ProcessStatus) ProtoMessage()
- func (x *ProcessStatus) ProtoReflect() protoreflect.Message
- func (x *ProcessStatus) Reset()
- func (x *ProcessStatus) String() string
- type ProfessionConfig
- func (*ProfessionConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ProfessionConfig) GetAppendLabels() []string
- func (x *ProfessionConfig) GetDependencies() []string
- func (x *ProfessionConfig) GetDesc() string
- func (x *ProfessionConfig) GetDrivers() []*DriverConfig
- func (x *ProfessionConfig) GetLabel() string
- func (x *ProfessionConfig) GetMod() ProfessionConfig_ProfessionMod
- func (x *ProfessionConfig) GetName() string
- func (*ProfessionConfig) ProtoMessage()
- func (x *ProfessionConfig) ProtoReflect() protoreflect.Message
- func (x *ProfessionConfig) Reset()
- func (x *ProfessionConfig) String() string
- type ProfessionConfig_ProfessionMod
- func (ProfessionConfig_ProfessionMod) Descriptor() protoreflect.EnumDescriptor
- func (x ProfessionConfig_ProfessionMod) Enum() *ProfessionConfig_ProfessionMod
- func (ProfessionConfig_ProfessionMod) EnumDescriptor() ([]byte, []int)deprecated
- func (x ProfessionConfig_ProfessionMod) Number() protoreflect.EnumNumber
- func (x ProfessionConfig_ProfessionMod) String() string
- func (ProfessionConfig_ProfessionMod) Type() protoreflect.EnumType
- type ProfessionConfigs
- func (*ProfessionConfigs) Descriptor() ([]byte, []int)deprecated
- func (x *ProfessionConfigs) GetData() []*ProfessionConfig
- func (*ProfessionConfigs) ProtoMessage()
- func (x *ProfessionConfigs) ProtoReflect() protoreflect.Message
- func (x *ProfessionConfigs) Reset()
- func (x *ProfessionConfigs) String() string
- type Register
- type RequireId
- type TWorker
- type WorkerConfig
- func (*WorkerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerConfig) GetBody() []byte
- func (x *WorkerConfig) GetCreate() string
- func (x *WorkerConfig) GetDescription() string
- func (x *WorkerConfig) GetDriver() string
- func (x *WorkerConfig) GetId() string
- func (x *WorkerConfig) GetName() string
- func (x *WorkerConfig) GetProfession() string
- func (x *WorkerConfig) GetUpdate() string
- func (*WorkerConfig) ProtoMessage()
- func (x *WorkerConfig) ProtoReflect() protoreflect.Message
- func (x *WorkerConfig) Reset()
- func (x *WorkerConfig) String() string
Examples ¶
Constants ¶
View Source
const ( EventInit = "init" EventSet = "set" EventReset = "reset" EventDel = "delete" )
View Source
const ( NamespaceProfession = "profession" NamespaceWorker = "worker" NamespaceExtender = "extender" )
View Source
const ( //ProcessMaster master进程,守护进程 ProcessMaster = "master" //ProcessWorker worker进程,负责网关主流程的执行 ProcessWorker = "worker" //ProcessHelper helper进程,临时进程,用于检测插件下载操作 ProcessHelper = "helper" //ProcessAdmin admin进程,缓存配置信息,常驻进程 ProcessAdmin = "admin" )
Variables ¶
View Source
var ( ErrorDriverNotExist = errors.New("driver not exist") ErrorProfessionNotExist = errors.New("profession not exist") ErrorNotAllowCreateForSingleton = errors.New("not allow create for singleton profession") ErrorWorkerNotExits = errors.New("worker-data not exits") ErrorRegisterConflict = errors.New("conflict of register") ErrorNotGetSillForRequire = errors.New("not get skill for require") ErrorTargetNotImplementSkill = errors.New("require of skill not implement") ErrorParamsIsNil = errors.New("params is nil") ErrorParamNotExist = errors.New("not exist") ErrorStoreReadOnly = errors.New("store read only") ErrorRequire = errors.New("require") ErrorProfessionDependencies = errors.New("profession dependencies not complete") ErrorConfigIsNil = errors.New("config is nil") ErrorConfigFieldUnknown = errors.New("unknown type") )
View Source
var ( ProfessionConfig_ProfessionMod_name = map[int32]string{ 0: "Worker", 1: "Singleton", } ProfessionConfig_ProfessionMod_value = map[string]int32{ "Worker": 0, "Singleton": 1, } )
Enum value maps for ProfessionConfig_ProfessionMod.
View Source
var File_message_proto protoreflect.FileDescriptor
View Source
var Namespaces = []string{ NamespaceProfession, NamespaceWorker, NamespaceExtender, }
Functions ¶
func Decompress ¶ added in v0.3.0
Decompress 解压文件
func ToWorkerId ¶ added in v0.1.0
Types ¶
type DriverConfig ¶
type DriverConfig struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Label string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"` Desc string `protobuf:"bytes,4,opt,name=desc,proto3" json:"desc,omitempty"` Params map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DriverConfig) Descriptor
deprecated
added in
v0.1.0
func (*DriverConfig) Descriptor() ([]byte, []int)
Deprecated: Use DriverConfig.ProtoReflect.Descriptor instead.
func (*DriverConfig) GetDesc ¶ added in v0.1.0
func (x *DriverConfig) GetDesc() string
func (*DriverConfig) GetId ¶ added in v0.1.0
func (x *DriverConfig) GetId() string
func (*DriverConfig) GetLabel ¶ added in v0.1.0
func (x *DriverConfig) GetLabel() string
func (*DriverConfig) GetName ¶ added in v0.1.0
func (x *DriverConfig) GetName() string
func (*DriverConfig) GetParams ¶ added in v0.1.0
func (x *DriverConfig) GetParams() map[string]string
func (*DriverConfig) ProtoMessage ¶ added in v0.1.0
func (*DriverConfig) ProtoMessage()
func (*DriverConfig) ProtoReflect ¶ added in v0.1.0
func (x *DriverConfig) ProtoReflect() protoreflect.Message
func (*DriverConfig) Reset ¶ added in v0.1.0
func (x *DriverConfig) Reset()
func (*DriverConfig) String ¶ added in v0.1.0
func (x *DriverConfig) String() string
type ExtenderBuilder ¶ added in v0.3.2
type ExtenderBuilder interface {
Register(register IExtenderDriverRegister)
}
type ExtenderRegister ¶ added in v0.3.0
type ExtenderRegister struct {
// contains filtered or unexported fields
}
func NewExtenderRegister ¶ added in v0.3.0
func NewExtenderRegister() *ExtenderRegister
func (*ExtenderRegister) GetDriver ¶ added in v0.3.0
func (p *ExtenderRegister) GetDriver(name string) (IExtenderDriverFactory, bool)
func (*ExtenderRegister) RegisterExtenderDriver ¶ added in v0.3.0
func (p *ExtenderRegister) RegisterExtenderDriver(name string, factory IExtenderDriverFactory) error
func (*ExtenderRegister) Remove ¶ added in v0.3.1
func (p *ExtenderRegister) Remove(name string)
type ExtendersSettings ¶ added in v0.3.0
type ExtendersSettings struct { Extenders map[string]string `` /* 159-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ExtendersSettings) Descriptor
deprecated
added in
v0.3.0
func (*ExtendersSettings) Descriptor() ([]byte, []int)
Deprecated: Use ExtendersSettings.ProtoReflect.Descriptor instead.
func (*ExtendersSettings) GetExtenders ¶ added in v0.3.0
func (x *ExtendersSettings) GetExtenders() map[string]string
func (*ExtendersSettings) ProtoMessage ¶ added in v0.3.0
func (*ExtendersSettings) ProtoMessage()
func (*ExtendersSettings) ProtoReflect ¶ added in v0.3.0
func (x *ExtendersSettings) ProtoReflect() protoreflect.Message
func (*ExtendersSettings) Reset ¶ added in v0.3.0
func (x *ExtendersSettings) Reset()
func (*ExtendersSettings) String ¶ added in v0.3.0
func (x *ExtendersSettings) String() string
type FormatterConfig ¶ added in v0.4.0
type IDataMarshaller ¶ added in v0.1.0
type IExtenderConfigChecker ¶ added in v0.3.0
type IExtenderDriver ¶ added in v0.3.0
type IExtenderDriverFactory ¶ added in v0.3.0
type IExtenderDriverManager ¶ added in v0.3.1
type IExtenderDriverManager interface { IExtenderDriverRegister }
type IExtenderDriverRegister ¶ added in v0.3.0
type IExtenderDriverRegister interface {
RegisterExtenderDriver(name string, factory IExtenderDriverFactory) error
}
type IExtenderDrivers ¶ added in v0.3.0
type IExtenderDrivers interface {
GetDriver(name string) (IExtenderDriverFactory, bool)
}
type IFormatter ¶ added in v0.4.0
IFormatter format config
type IFormatterFactory ¶ added in v0.4.0
type IFormatterFactory interface {
Create(cfg FormatterConfig) (IFormatter, error)
}
type IProfession ¶
type IProfession interface { Drivers() []*DriverConfig GetDriver(name string) (*DriverConfig, bool) HasDriver(name string) bool AppendAttr() []string Mod() ProfessionConfig_ProfessionMod }
type IProfessions ¶
type IProfessions interface { Set(name string, profession *ProfessionConfig) error Delete(name string) error Reset([]*ProfessionConfig) Names() []string GetProfession(name string) (IProfession, bool) All() []*ProfessionConfig }
type IRegister ¶
type IRegister interface { Register(name string, obj interface{}, force bool) error Get(name string) (interface{}, bool) Del(name string) (interface{}, bool) }
func NewRegister ¶
func NewRegister() IRegister
type IUntyped ¶
type IUntyped interface { Set(name string, v interface{}) Get(name string) (interface{}, bool) Del(name string) (interface{}, bool) List() []interface{} Keys() []string All() map[string]interface{} Clone() IUntyped Count() int }
func NewUntyped ¶
func NewUntyped() IUntyped
type IWorkerResources ¶ added in v0.1.0
type IWorkerResources interface {
Ports() []int
}
type ProcessStatus ¶ added in v0.5.0
type ProcessStatus struct { Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ProcessStatus) Descriptor
deprecated
added in
v0.5.0
func (*ProcessStatus) Descriptor() ([]byte, []int)
Deprecated: Use ProcessStatus.ProtoReflect.Descriptor instead.
func (*ProcessStatus) GetData ¶ added in v0.5.0
func (x *ProcessStatus) GetData() []byte
func (*ProcessStatus) GetMsg ¶ added in v0.5.0
func (x *ProcessStatus) GetMsg() string
func (*ProcessStatus) GetStatus ¶ added in v0.5.0
func (x *ProcessStatus) GetStatus() int32
func (*ProcessStatus) ProtoMessage ¶ added in v0.5.0
func (*ProcessStatus) ProtoMessage()
func (*ProcessStatus) ProtoReflect ¶ added in v0.5.0
func (x *ProcessStatus) ProtoReflect() protoreflect.Message
func (*ProcessStatus) Reset ¶ added in v0.5.0
func (x *ProcessStatus) Reset()
func (*ProcessStatus) String ¶ added in v0.5.0
func (x *ProcessStatus) String() string
type ProfessionConfig ¶
type ProfessionConfig struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Label string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"` // Desc string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"` // Dependencies []string `protobuf:"bytes,4,rep,name=dependencies,proto3" json:"dependencies,omitempty"` AppendLabels []string `protobuf:"bytes,5,rep,name=appendLabels,proto3" json:"appendLabels,omitempty"` Drivers []*DriverConfig `protobuf:"bytes,6,rep,name=drivers,proto3" json:"drivers,omitempty"` Mod ProfessionConfig_ProfessionMod `protobuf:"varint,7,opt,name=mod,proto3,enum=service.ProfessionConfig_ProfessionMod" json:"mod,omitempty"` // contains filtered or unexported fields }
func (*ProfessionConfig) Descriptor
deprecated
added in
v0.1.0
func (*ProfessionConfig) Descriptor() ([]byte, []int)
Deprecated: Use ProfessionConfig.ProtoReflect.Descriptor instead.
func (*ProfessionConfig) GetAppendLabels ¶ added in v0.1.0
func (x *ProfessionConfig) GetAppendLabels() []string
func (*ProfessionConfig) GetDependencies ¶ added in v0.1.0
func (x *ProfessionConfig) GetDependencies() []string
func (*ProfessionConfig) GetDesc ¶ added in v0.1.0
func (x *ProfessionConfig) GetDesc() string
func (*ProfessionConfig) GetDrivers ¶ added in v0.1.0
func (x *ProfessionConfig) GetDrivers() []*DriverConfig
func (*ProfessionConfig) GetLabel ¶ added in v0.1.0
func (x *ProfessionConfig) GetLabel() string
func (*ProfessionConfig) GetMod ¶ added in v0.3.0
func (x *ProfessionConfig) GetMod() ProfessionConfig_ProfessionMod
func (*ProfessionConfig) GetName ¶ added in v0.1.0
func (x *ProfessionConfig) GetName() string
func (*ProfessionConfig) ProtoMessage ¶ added in v0.1.0
func (*ProfessionConfig) ProtoMessage()
func (*ProfessionConfig) ProtoReflect ¶ added in v0.1.0
func (x *ProfessionConfig) ProtoReflect() protoreflect.Message
func (*ProfessionConfig) Reset ¶ added in v0.1.0
func (x *ProfessionConfig) Reset()
func (*ProfessionConfig) String ¶ added in v0.1.0
func (x *ProfessionConfig) String() string
type ProfessionConfig_ProfessionMod ¶ added in v0.3.0
type ProfessionConfig_ProfessionMod int32
const ( ProfessionConfig_Worker ProfessionConfig_ProfessionMod = 0 ProfessionConfig_Singleton ProfessionConfig_ProfessionMod = 1 )
func (ProfessionConfig_ProfessionMod) Descriptor ¶ added in v0.3.0
func (ProfessionConfig_ProfessionMod) Descriptor() protoreflect.EnumDescriptor
func (ProfessionConfig_ProfessionMod) Enum ¶ added in v0.3.0
func (x ProfessionConfig_ProfessionMod) Enum() *ProfessionConfig_ProfessionMod
func (ProfessionConfig_ProfessionMod) EnumDescriptor
deprecated
added in
v0.3.0
func (ProfessionConfig_ProfessionMod) EnumDescriptor() ([]byte, []int)
Deprecated: Use ProfessionConfig_ProfessionMod.Descriptor instead.
func (ProfessionConfig_ProfessionMod) Number ¶ added in v0.3.0
func (x ProfessionConfig_ProfessionMod) Number() protoreflect.EnumNumber
func (ProfessionConfig_ProfessionMod) String ¶ added in v0.3.0
func (x ProfessionConfig_ProfessionMod) String() string
func (ProfessionConfig_ProfessionMod) Type ¶ added in v0.3.0
func (ProfessionConfig_ProfessionMod) Type() protoreflect.EnumType
type ProfessionConfigs ¶
type ProfessionConfigs struct { Data []*ProfessionConfig `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ProfessionConfigs) Descriptor
deprecated
added in
v0.3.0
func (*ProfessionConfigs) Descriptor() ([]byte, []int)
Deprecated: Use ProfessionConfigs.ProtoReflect.Descriptor instead.
func (*ProfessionConfigs) GetData ¶ added in v0.3.0
func (x *ProfessionConfigs) GetData() []*ProfessionConfig
func (*ProfessionConfigs) ProtoMessage ¶ added in v0.3.0
func (*ProfessionConfigs) ProtoMessage()
func (*ProfessionConfigs) ProtoReflect ¶ added in v0.3.0
func (x *ProfessionConfigs) ProtoReflect() protoreflect.Message
func (*ProfessionConfigs) Reset ¶ added in v0.3.0
func (x *ProfessionConfigs) Reset()
func (*ProfessionConfigs) String ¶ added in v0.3.0
func (x *ProfessionConfigs) String() string
type TWorker ¶ added in v0.1.0
type TWorker struct { Id string `json:"id,omitempty" yaml:"id"` Name string `json:"name,omitempty" yaml:"name"` Driver string `json:"driver,omitempty" yaml:"driver"` Profession string `json:"profession,omitempty" yaml:"profession"` Create time.Time `json:"create" yaml:"create"` Update time.Time `json:"update" yaml:"update"` Data interface{} `json:"data,omitempty" yaml:"data"` }
type WorkerConfig ¶ added in v0.3.0
type WorkerConfig struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Profession string `protobuf:"bytes,2,opt,name=profession,proto3" json:"profession,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Driver string `protobuf:"bytes,4,opt,name=driver,proto3" json:"driver,omitempty"` Create string `protobuf:"bytes,5,opt,name=create,proto3" json:"create,omitempty"` Update string `protobuf:"bytes,6,opt,name=update,proto3" json:"update,omitempty"` Body []byte `protobuf:"bytes,7,opt,name=body,proto3" json:"body,omitempty"` Description string `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"` // contains filtered or unexported fields }
func GenInitWorkerConfig ¶ added in v0.5.0
func GenInitWorkerConfig(ps []*ProfessionConfig) []*WorkerConfig
func (*WorkerConfig) Descriptor
deprecated
added in
v0.3.0
func (*WorkerConfig) Descriptor() ([]byte, []int)
Deprecated: Use WorkerConfig.ProtoReflect.Descriptor instead.
func (*WorkerConfig) GetBody ¶ added in v0.3.0
func (x *WorkerConfig) GetBody() []byte
func (*WorkerConfig) GetCreate ¶ added in v0.3.0
func (x *WorkerConfig) GetCreate() string
func (*WorkerConfig) GetDescription ¶ added in v0.5.0
func (x *WorkerConfig) GetDescription() string
func (*WorkerConfig) GetDriver ¶ added in v0.3.0
func (x *WorkerConfig) GetDriver() string
func (*WorkerConfig) GetId ¶ added in v0.3.0
func (x *WorkerConfig) GetId() string
func (*WorkerConfig) GetName ¶ added in v0.3.0
func (x *WorkerConfig) GetName() string
func (*WorkerConfig) GetProfession ¶ added in v0.3.0
func (x *WorkerConfig) GetProfession() string
func (*WorkerConfig) GetUpdate ¶ added in v0.3.0
func (x *WorkerConfig) GetUpdate() string
func (*WorkerConfig) ProtoMessage ¶ added in v0.3.0
func (*WorkerConfig) ProtoMessage()
func (*WorkerConfig) ProtoReflect ¶ added in v0.3.0
func (x *WorkerConfig) ProtoReflect() protoreflect.Message
func (*WorkerConfig) Reset ¶ added in v0.3.0
func (x *WorkerConfig) Reset()
func (*WorkerConfig) String ¶ added in v0.3.0
func (x *WorkerConfig) String() string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.