eosc

Aug 24, 2023

Changes in this version

+ func ReadStringFromEntry(entry IEntry, key string) string

May 10, 2023

Changes in this version

type WorkerConfig

+ Version string

+ func (x *WorkerConfig) GetVersion() string

Mar 31, 2023

Changes in this version

type Untyped

+ Dels func(k ...K) []T

Feb 24, 2023

Changes in this version

+ type EoFiles []GzipFile

+ type GzipFile struct

+ Data string

+ Name string

+ Size int

+ Type string

+ func (f *GzipFile) DecodeData() ([]byte, error)

+ type IMetricEntry interface

+ Children func(child string) []IMetricEntry

+ GetFloat func(pattern string) (float64, bool)

+ Read func(pattern string) string

Dec 5, 2022

Changes in this version

+ const NamespaceCluster

Nov 4, 2022

Changes in this version

+ var ErrorConfigType = errors.New("error config type")

+ type Untyped interface

+ All func() map[K]T

+ Clone func() Untyped[K, T]

+ Count func() int

+ Del func(k K) (T, bool)

+ Get func(k K) (T, bool)

+ Keys func() []K

+ List func() []T

+ Set func(k K, v T)

+ func BuildUntyped() Untyped[K, T]

Sep 28, 2022

Changes in this version

+ const NamespaceVariable

+ var ErrorUnsupportedKind = errors.New("unsupported kind")

+ var ErrorWorkerNotRunning = errors.New("worker-data not running")

+ func SplitWorkerId(id string) (profession string, name string, success bool)

+ type ConfigType struct

+ func NewConfigType(alias map[string]string, cfgType map[string]reflect.Type) *ConfigType

+ func (c *ConfigType) Get(id string) (reflect.Type, bool)

+ func (c *ConfigType) GetByAlias(alias string) (reflect.Type, bool)

+ type IRequires interface

+ Del func(id string)

+ RequireBy func(requireId string) []string

+ RequireByCount func(requireId string) int

+ Requires func(id string) []string

+ Set func(id string, requires []string)

+ type ISetting interface

+ AllWorkers func() []string

+ Check func(cfg interface{}) (profession, name, driver, desc string, err error)

+ ConfigType func() reflect.Type

+ Get func() interface{}

+ Mode func() SettingMode

+ Set func(conf interface{}) (err error)

+ type ISettings interface

+ CheckVariable func(name string, variable IVariable) (err error)

+ GetConfig func(name string) interface{}

+ GetDriver func(name string) (ISetting, bool)

+ SettingWorker func(name string, config []byte, variable IVariable) error

+ Update func(name string, variable IVariable) (err error)

+ type IVariable interface

+ Check func(namespace string, variables map[string]string) ([]string, IVariable, error)

+ Get func(id string) (string, bool)

+ GetByNamespace func(namespace string) (map[string]string, bool)

+ Len func() int

+ RemoveRequire func(id string)

+ SetByNamespace func(namespace string, variables map[string]string) error

+ SetVariablesById func(id string, variables []string)

+ Unmarshal func(buf []byte, typ reflect.Type) (interface{}, []string, error)

+ type IWorkerDestroy interface

+ Destroy func() error

+ type SettingMode int

+ const SettingModeBatch

+ const SettingModeReadonly

+ const SettingModeSingleton

Jun 17, 2022

Changes in this version

+ const EventDel

+ const EventInit

+ const EventReset

+ const EventSet

+ const NamespaceExtender

+ const NamespaceProfession

+ const NamespaceWorker

+ const ProcessAdmin

+ var Namespaces = []string

type IExtenderDriverFactory

+ Render func() interface{}

type IProfessions

+ Names func() []string

+ type ProcessStatus struct

+ Data []byte

+ Msg string

+ Status int32

+ func (*ProcessStatus) Descriptor() ([]byte, []int)

+ func (*ProcessStatus) ProtoMessage()

+ func (x *ProcessStatus) GetData() []byte

+ func (x *ProcessStatus) GetMsg() string

+ func (x *ProcessStatus) GetStatus() int32

+ func (x *ProcessStatus) ProtoReflect() protoreflect.Message

+ func (x *ProcessStatus) Reset()

+ func (x *ProcessStatus) String() string

type TWorker

+ Create time.Time

+ Data interface{}

+ Driver string

+ Id string

+ Name string

+ Profession string

+ Update time.Time

type WorkerConfig

+ Description string

+ func GenInitWorkerConfig(ps []*ProfessionConfig) []*WorkerConfig

+ func (x *WorkerConfig) GetDescription() string

Dec 27, 2021

Changes in this version

+ type FormatterConfig map[string][]string

+ type IEntry interface

+ Children func(child string) []IEntry

+ Read func(pattern string) string

+ type IFormatter interface

+ Format func(entry IEntry) []byte

+ type IFormatterFactory interface

+ Create func(cfg FormatterConfig) (IFormatter, error)

Nov 25, 2021

Changes in this version

+ type IAdminExtender interface

+ GetPlugin func(id string) (interface{}, error)

+ Plugins func() []interface{}

+ PluginsByExtenderID func(extenderID string) []interface{}

Nov 22, 2021

Changes in this version

+ type ExtenderBuilder interface

+ Register func(register IExtenderDriverRegister)

Nov 22, 2021

Changes in this version

type ExtenderRegister

+ func (p *ExtenderRegister) Remove(name string)

+ type IExtenderDriverManager interface

+ Remove func(name string)

type IRegister

+ Del func(name string) (interface{}, bool)

type Register

+ func (r *Register) Del(name string) (interface{}, bool)

Nov 17, 2021

Changes in this version

+ var ErrorNotAllowCreateForSingleton = errors.New("not allow create for singleton profession")

+ var ProfessionConfig_ProfessionMod_name = map[int32]string

+ var ProfessionConfig_ProfessionMod_value = map[string]int32

+ func CreateFile(name string) (*os.File, error)

+ func Decompress(filePath string, dest string) error

+ func FileSha1(file *os.File, size int64) (string, error)

+ func SHA1(data []byte) string

+ func Version() string

+ type ExtenderRegister struct

+ func NewExtenderRegister() *ExtenderRegister

+ func (p *ExtenderRegister) GetDriver(name string) (IExtenderDriverFactory, bool)

+ func (p *ExtenderRegister) RegisterExtenderDriver(name string, factory IExtenderDriverFactory) error

+ type ExtendersSettings struct

+ Extenders map[string]string

+ func (*ExtendersSettings) Descriptor() ([]byte, []int)

+ func (*ExtendersSettings) ProtoMessage()

+ func (x *ExtendersSettings) GetExtenders() map[string]string

+ func (x *ExtendersSettings) ProtoReflect() protoreflect.Message

+ func (x *ExtendersSettings) Reset()

+ func (x *ExtendersSettings) String() string

+ type IExtenderConfigChecker interface

+ Check func(v interface{}, workers map[RequireId]interface{}) error

+ type IExtenderDriver interface

+ ConfigType func() reflect.Type

+ Create func(id, name string, v interface{}, workers map[RequireId]interface{}) (IWorker, error)

+ type IExtenderDriverFactory interface

+ Create func(profession string, name string, label string, desc string, ...) (IExtenderDriver, error)

+ type IExtenderDriverRegister interface

+ RegisterExtenderDriver func(name string, factory IExtenderDriverFactory) error

+ type IExtenderDrivers interface

+ GetDriver func(name string) (IExtenderDriverFactory, bool)

type IProfession

+ AppendAttr func() []string

+ Detail func() *ProfessionDetail

+ Drivers func() []*DriverInfo

+ DriversItem func() []*Item

+ GetDriver func(name string) (*DriverDetail, bool)

+ HasDriver func(name string) bool

+ Mod func() ProfessionConfig_ProfessionMod

type IProfessions

+ All func() []*ProfessionConfig

+ Delete func(name string) error

+ GetProfession func(name string) (IProfession, bool)

+ Reset func([]*ProfessionConfig)

+ Set func(name string, profession *ProfessionConfig) error

type ProfessionConfig

+ Mod ProfessionConfig_ProfessionMod

+ func (x *ProfessionConfig) GetMod() ProfessionConfig_ProfessionMod

+ type ProfessionConfig_ProfessionMod int32

+ const ProfessionConfig_Singleton

+ const ProfessionConfig_Worker

+ func (ProfessionConfig_ProfessionMod) Descriptor() protoreflect.EnumDescriptor

+ func (ProfessionConfig_ProfessionMod) EnumDescriptor() ([]byte, []int)

+ func (ProfessionConfig_ProfessionMod) Type() protoreflect.EnumType

+ func (x ProfessionConfig_ProfessionMod) Enum() *ProfessionConfig_ProfessionMod

+ func (x ProfessionConfig_ProfessionMod) Number() protoreflect.EnumNumber

+ func (x ProfessionConfig_ProfessionMod) String() string

type ProfessionConfigs

+ Data []*ProfessionConfig

+ func (*ProfessionConfigs) Descriptor() ([]byte, []int)

+ func (*ProfessionConfigs) ProtoMessage()

+ func (x *ProfessionConfigs) GetData() []*ProfessionConfig

+ func (x *ProfessionConfigs) ProtoReflect() protoreflect.Message

+ func (x *ProfessionConfigs) Reset()

+ func (x *ProfessionConfigs) String() string

+ type WorkerConfig struct

+ Body []byte

+ Create string

+ Driver string

+ Id string

+ Name string

+ Profession string

+ Update string

+ func (*WorkerConfig) Descriptor() ([]byte, []int)

+ func (*WorkerConfig) ProtoMessage()

+ func (x *WorkerConfig) GetBody() []byte

+ func (x *WorkerConfig) GetCreate() 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 (x *WorkerConfig) ProtoReflect() protoreflect.Message

+ func (x *WorkerConfig) Reset()

+ func (x *WorkerConfig) String() string

+ type WorkerConfigs struct

+ Data []*WorkerConfig

+ func (*WorkerConfigs) Descriptor() ([]byte, []int)

+ func (*WorkerConfigs) ProtoMessage()

+ func (x *WorkerConfigs) GetData() []*WorkerConfig

+ func (x *WorkerConfigs) ProtoReflect() protoreflect.Message

+ func (x *WorkerConfigs) Reset()

+ func (x *WorkerConfigs) String() string

Oct 14, 2021

Changes in this version

+ var File_service_message_proto protoreflect.FileDescriptor

+ func GetRealIP(r *http.Request) string

Sep 30, 2021

Changes in this version

+ const ProcessHelper

+ const ProcessMaster

+ const ProcessWorker

+ var File_message_proto protoreflect.FileDescriptor

+ func ToWorkerId(value, profession string) (string, bool)

type DriverConfig

+ Id string

+ func (*DriverConfig) Descriptor() ([]byte, []int)

+ func (*DriverConfig) ProtoMessage()

+ 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 (x *DriverConfig) ProtoReflect() protoreflect.Message

+ func (x *DriverConfig) Reset()

+ func (x *DriverConfig) String() string

type DriverDetail

+ Desc string

+ Driver string

+ Id string

+ Label string

+ Params map[string]string

+ Plugin *PluginInfo

+ func ToDriverDetail(config *DriverConfig) *DriverDetail

+ func ToDriverDetails(config []*DriverConfig) []*DriverDetail

+ func (*DriverDetail) Descriptor() ([]byte, []int)

+ func (*DriverDetail) ProtoMessage()

+ func (x *DriverDetail) GetDesc() string

+ func (x *DriverDetail) GetDriver() string

+ func (x *DriverDetail) GetId() string

+ func (x *DriverDetail) GetLabel() string

+ func (x *DriverDetail) GetParams() map[string]string

+ func (x *DriverDetail) GetPlugin() *PluginInfo

+ func (x *DriverDetail) ProtoReflect() protoreflect.Message

+ func (x *DriverDetail) Reset()

+ func (x *DriverDetail) String() string

type DriverInfo

+ func (*DriverInfo) Descriptor() ([]byte, []int)

+ func (*DriverInfo) ProtoMessage()

+ func (x *DriverInfo) GetDesc() string

+ func (x *DriverInfo) GetId() string

+ func (x *DriverInfo) GetLabel() string

+ func (x *DriverInfo) GetName() string

+ func (x *DriverInfo) ProtoReflect() protoreflect.Message

+ func (x *DriverInfo) Reset()

+ func (x *DriverInfo) String() string

+ type IAdminPermission interface

+ DriverInfo func(profession, driver string) (*DriverDetail, error)

+ Drivers func(profession string) ([]*DriverInfo, error)

+ DriversItem func(profession string) ([]*Item, error)

+ ListProfessions func() []*ProfessionInfo

+ type IAdminWorker interface

+ Delete func(profession, name string) (interface{}, error)

+ GetEmployee func(profession, name string) (interface{}, error)

+ ListEmployees func(profession string) ([]interface{}, error)

+ Update func(profession, name, driver string, data []byte) (interface{}, error)

+ type IDataMarshaller interface

+ Encode func(startIndex int) ([]byte, []*os.File, error)

+ type IProfessionData interface

+ AppendAttr func() []string

+ Detail func() *ProfessionDetail

+ Drivers func() []*DriverInfo

+ DriversItem func() []*Item

+ GetDriver func(name string) (*DriverDetail, bool)

+ HasDriver func(name string) bool

+ type IProfessionDataEdit interface

+ DeleteDriver func(name string) error

+ SetDriver func(name string, detail *DriverConfig) error

+ type IProfessionsData interface

+ All func() []*ProfessionConfig

+ Delete func(name string) error

+ GetProfession func(name string) (IProfessionData, bool)

+ Infos func() []*ProfessionInfo

+ Reset func([]*ProfessionConfig)

+ Set func(name string, profession *ProfessionConfig) error

+ type IWorkerResources interface

+ Ports func() []int

+ type IWorkersData interface

+ Delete func(id string) (TWorker, error)

+ GetList func(profession string) ([]TWorker, error)

+ GetWork func(id string) (TWorker, error)

+ Set func(profession, name, driver string, data []byte) (TWorker, error)

+ type PluginInfo struct

+ Group string

+ Name string

+ Project string

+ func (*PluginInfo) Descriptor() ([]byte, []int)

+ func (*PluginInfo) ProtoMessage()

+ func (x *PluginInfo) GetGroup() string

+ func (x *PluginInfo) GetName() string

+ func (x *PluginInfo) GetProject() string

+ func (x *PluginInfo) ProtoReflect() protoreflect.Message

+ func (x *PluginInfo) Reset()

+ func (x *PluginInfo) String() string

type ProfessionConfig

+ AppendLabels []string

+ func (*ProfessionConfig) Descriptor() ([]byte, []int)

+ func (*ProfessionConfig) ProtoMessage()

+ 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) GetName() string

+ func (x *ProfessionConfig) ProtoReflect() protoreflect.Message

+ func (x *ProfessionConfig) Reset()

+ func (x *ProfessionConfig) String() string

+ type ProfessionConfigData struct

+ Data []*ProfessionConfig

+ func (*ProfessionConfigData) Descriptor() ([]byte, []int)

+ func (*ProfessionConfigData) ProtoMessage()

+ func (x *ProfessionConfigData) GetData() []*ProfessionConfig

+ func (x *ProfessionConfigData) ProtoReflect() protoreflect.Message

+ func (x *ProfessionConfigData) Reset()

+ func (x *ProfessionConfigData) String() string

+ type ProfessionDetail struct

+ AppendLabels []string

+ Dependencies []string

+ Desc string

+ Drivers []*DriverDetail

+ Label string

+ Name string

+ func (*ProfessionDetail) Descriptor() ([]byte, []int)

+ func (*ProfessionDetail) ProtoMessage()

+ func (x *ProfessionDetail) GetAppendLabels() []string

+ func (x *ProfessionDetail) GetDependencies() []string

+ func (x *ProfessionDetail) GetDesc() string

+ func (x *ProfessionDetail) GetDrivers() []*DriverDetail

+ func (x *ProfessionDetail) GetLabel() string

+ func (x *ProfessionDetail) GetName() string

+ func (x *ProfessionDetail) ProtoReflect() protoreflect.Message

+ func (x *ProfessionDetail) Reset()

+ func (x *ProfessionDetail) String() string

type ProfessionInfo

+ Label string

+ func (*ProfessionInfo) Descriptor() ([]byte, []int)

+ func (*ProfessionInfo) ProtoMessage()

+ func (x *ProfessionInfo) GetDesc() string

+ func (x *ProfessionInfo) GetLabel() string

+ func (x *ProfessionInfo) GetName() string

+ func (x *ProfessionInfo) ProtoReflect() protoreflect.Message

+ func (x *ProfessionInfo) Reset()

+ func (x *ProfessionInfo) String() string

+ type TWorker map[string]interface

+ type WorkerData struct

+ Body []byte

+ Create string

+ Driver string

+ Id string

+ Name string

+ Profession string

+ Update string

+ func (*WorkerData) Descriptor() ([]byte, []int)

+ func (*WorkerData) ProtoMessage()

+ func (x *WorkerData) GetBody() []byte

+ func (x *WorkerData) GetCreate() string

+ func (x *WorkerData) GetDriver() string

+ func (x *WorkerData) GetId() string

+ func (x *WorkerData) GetName() string

+ func (x *WorkerData) GetProfession() string

+ func (x *WorkerData) GetUpdate() string

+ func (x *WorkerData) ProtoReflect() protoreflect.Message

+ func (x *WorkerData) Reset()

+ func (x *WorkerData) String() string

type WorkerInfo

+ Profession string

+ func (*WorkerInfo) Descriptor() ([]byte, []int)

+ func (*WorkerInfo) ProtoMessage()

+ func (x *WorkerInfo) GetCreate() string

+ func (x *WorkerInfo) GetDriver() string

+ func (x *WorkerInfo) GetId() string

+ func (x *WorkerInfo) GetName() string

+ func (x *WorkerInfo) GetProfession() string

+ func (x *WorkerInfo) GetUpdate() string

+ func (x *WorkerInfo) ProtoReflect() protoreflect.Message

+ func (x *WorkerInfo) Reset()

+ func (x *WorkerInfo) String() string

+ type WorkersData struct

+ Data []*WorkerData

+ func (*WorkersData) Descriptor() ([]byte, []int)

+ func (*WorkersData) ProtoMessage()

+ func (x *WorkersData) GetData() []*WorkerData

+ func (x *WorkersData) ProtoReflect() protoreflect.Message

+ func (x *WorkersData) Reset()

+ func (x *WorkersData) String() string

Aug 25, 2021

Changes in this version

+ var SpaceProfession = "profession"

+ var SpaceWorker = "worker"

type IStoreRW

+ Reset func([]StoreValue) error

+ type JsonData []byte

+ func (j JsonData) Marshal() ([]byte, error)

+ func (j JsonData) UnMarshal(v interface{}) error

+ type XMLData []byte

+ type YamlData []byte

+ func (y YamlData) Marshal() ([]byte, error)

+ func (y YamlData) UnMarshal(v interface{}) error

Aug 13, 2021

Changes in this version

+ func Now() string

type IAdmin

+ GetEmployee func(profession, name string) (interface{}, error)

+ ListEmployeeNames func(profession string) ([]string, error)

type IProfession

+ ChangeWorker func(driver, id, name string, cdata IData, workers IWorkers) error

+ CheckerConfig func(driver string, cdata IData, workers IWorkers) error

+ type IProfessionDriverCheckConfig interface

+ Check func(v interface{}, workers map[RequireId]interface{}) error

type IWorkers

+ Set func(id string, w IWorker)

type Profession

+ func (p *Profession) ChangeWorker(driver, id, name string, cdata IData, workers IWorkers) error

+ func (p *Profession) CheckerConfig(driver string, cdata IData, workers IWorkers) error

type Professions

+ func (ps *Professions) GetEmployee(profession, name string) (interface{}, error)

+ func (ps *Professions) ListEmployeeNames(profession string) ([]string, error)

+ func (ps *Professions) Save(v StoreValue) error

type WorkManager

+ func (wm *WorkManager) Set(id string, w IWorker)

Jul 20, 2021

Changes in this version

+ var ErrorConfigFieldUnknown = errors.New("unknown type")

+ var ErrorConfigIsNil = errors.New("config is nil")

+ var ErrorDriverNotExist = errors.New("driver not exist")

+ var ErrorNotGetSillForRequire = errors.New("not get skill for require")

+ var ErrorParamNotExist = errors.New("not exist")

+ var ErrorParamsIsNil = errors.New("params is nil")

+ var ErrorProfessionDependencies = errors.New("profession dependencies not complete")

+ var ErrorProfessionNotExist = errors.New("profession not exist")

+ var ErrorRegisterConflict = errors.New("conflict of register")

+ var ErrorRequire = errors.New("require")

+ var ErrorStoreReadOnly = errors.New("store read only")

+ var ErrorTargetNotImplementSkill = errors.New("require of skill not implement")

+ var ErrorWorkerNotExits = errors.New("worker not exits")

+ func CheckConfig(v interface{}, workers IWorkers) (map[RequireId]interface{}, error)

+ func RegisterProfessionDriver(name string, factory IProfessionDriverFactory) error

+ func RegisterStoreDriver(name string, factory IStoreFactory)

+ func TypeName(t reflect.Type) string

+ func TypeNameOf(v interface{}) string

+ func WriteError(w http.ResponseWriter, resultErr error)

+ func WriteResult(w http.ResponseWriter, code string, resultType, resultKey string, ...)

+ func WriteResultInfo(w http.ResponseWriter, resultType string, resultKey string, result interface{})

+ func WriteResultInfoWithCode(w http.ResponseWriter, code string, resultType, resultKey string, ...)

+ func WriteResultInfoWithPage(w http.ResponseWriter, resultType, resultKey string, result interface{}, ...)

+ func WriteSuccessInData(w http.ResponseWriter, resultType, resultKey string, result interface{})

+ func WriteSuccessNoData(w http.ResponseWriter, resultType string)

+ type BytesData []byte

+ func MarshalBytes(v interface{}) (BytesData, error)

+ func (b BytesData) Marshal() ([]byte, error)

+ func (b BytesData) UnMarshal(v interface{}) error

+ type DriverConfig struct

+ Desc string

+ ID string

+ Label string

+ Name string

+ Params map[string]string

+ type DriverDetail struct

+ Extends ExtendInfo

+ type DriverInfo struct

+ Desc string

+ Id string

+ Label string

+ Name string

+ Params map[string]string

+ Profession string

+ type ExtendInfo struct

+ Group string

+ ID string

+ Name string

+ Project string

+ type IAdmin interface

+ Delete func(profession, name string) error

+ DriverInfo func(profession, driver string) (DriverDetail, error)

+ Drivers func(profession string) ([]DriverInfo, error)

+ DriversItem func(profession string) ([]Item, error)

+ Get func(profession, name string) (interface{}, error)

+ ListEmployees func(profession string) ([]interface{}, error)

+ ListProfessions func() []ProfessionInfo

+ Render func(profession, driver string) (*Render, error)

+ Renders func(profession string) (map[string]*Render, error)

+ SearchBySkill func(profession string, skill []string) ([]WorkerInfo, error)

+ Update func(profession, name, driver string, data IData) (*WorkerInfo, error)

+ type IAdminHandler interface

+ GenHandler func() (http.Handler, error)

+ type IData interface

+ Marshal func() ([]byte, error)

+ UnMarshal func(v interface{}) error

+ type IDriverRegister interface

+ GetProfessionDriver func(name string) (IProfessionDriverFactory, bool)

+ RegisterProfessionDriver func(name string, factory IProfessionDriverFactory) error

+ var DefaultProfessionDriverRegister IDriverRegister = NewProfessionDriverRegister()

+ type IProfession interface

+ AppendLabels func() []string

+ Dependencies func() []string

+ Desc func() string

+ Label func() string

+ Name func() string

+ type IProfessionDriver interface

+ ConfigType func() reflect.Type

+ Create func(id, name string, v interface{}, workers map[RequireId]interface{}) (IWorker, error)

+ type IProfessionDriverFactory interface

+ Create func(profession string, name string, label string, desc string, ...) (IProfessionDriver, error)

+ ExtendInfo func() ExtendInfo

+ func GetProfessionDriver(name string) (IProfessionDriverFactory, bool)

+ type IProfessionDriverInfo interface

+ DriverInfo func() DriverInfo

+ ExtendInfo func() ExtendInfo

+ type IProfessionDrivers interface

+ Get func(name string) (driver IProfessionDriverInfo, has bool)

+ Keys func() []string

+ List func() []IProfessionDriverInfo

+ func NewDrivers(drivers []*_TProfessionDriver) IProfessionDrivers

+ type IProfessions interface

+ Infos func() []ProfessionInfo

+ type IRegister interface

+ Get func(name string) (interface{}, bool)

+ Register func(name string, obj interface{}, force bool) error

+ func NewRegister() IRegister

+ type IRegisterData interface

+ Get func(name string) (interface{}, bool)

+ Set func(name string, v interface{})

+ type IStore interface

+ GetListener func() IStoreListener

+ type IStoreEventHandler interface

+ OnChange func(v StoreValue) error

+ OnDel func(v StoreValue) error

+ OnInit func(vs []StoreValue) error

+ type IStoreFactory interface

+ Create func(params map[string]string) (IStore, error)

+ func GetStoreDriver(name string) (IStoreFactory, bool)

+ type IStoreListener interface

+ AddListen func(h IStoreEventHandler) error

+ type IStoreLock interface

+ ReadLock func(ctx context.Context) (bool, error)

+ ReadUnLock func() error

+ TryLock func(ctx context.Context, expire int) (bool, error)

+ UnLock func() error

+ type IStoreRW interface

+ All func() []StoreValue

+ Del func(id string) error

+ Get func(id string) (StoreValue, bool)

+ Initialization func() error

+ ReadOnly func() bool

+ Set func(v StoreValue) error

+ type IUntyped interface

+ All func() map[string]interface{}

+ Clone func() IUntyped

+ Count func() int

+ Del func(name string) (interface{}, bool)

+ Get func(name string) (interface{}, bool)

+ Keys func() []string

+ List func() []interface{}

+ Set func(name string, v interface{})

+ func NewUntyped() IUntyped

+ type IWorker interface

+ CheckSkill func(skill string) bool

+ Id func() string

+ Reset func(conf interface{}, workers map[RequireId]interface{}) error

+ Start func() error

+ Stop func() error

+ type IWorkers interface

+ Del func(id string) (IWorker, bool)

+ Get func(id string) (IWorker, bool)

+ type Item struct

+ Label string

+ Value string

+ type Marshaler interface

+ Marshal func() (string, error)

+ type PageInfo struct

+ ItemNum int

+ Page int

+ PageSize int

+ TotalNum int

+ func NewItemNum(num int) *PageInfo

+ func (p *PageInfo) SetPage(page, size, total int) *PageInfo

+ type Profession struct

+ func (p *Profession) AppendLabels() []string

+ func (p *Profession) Dependencies() []string

+ func (p *Profession) Desc() string

+ func (p *Profession) Label() string

+ func (p *Profession) Name() string

+ type ProfessionConfig struct

+ AppendLabel []string

+ Dependencies []string

+ Desc string

+ Drivers []DriverConfig

+ Label string

+ Name string

+ type ProfessionConfigs []ProfessionConfig

+ func (pcs ProfessionConfigs) Gen(driverRegister IDriverRegister, store IStore) (*Professions, error)

+ type ProfessionDriverRegister struct

+ func NewProfessionDriverRegister() *ProfessionDriverRegister

+ func (p *ProfessionDriverRegister) GetProfessionDriver(name string) (IProfessionDriverFactory, bool)

+ func (p *ProfessionDriverRegister) RegisterProfessionDriver(name string, factory IProfessionDriverFactory) error

+ type ProfessionDrivers struct

+ func (d *ProfessionDrivers) Get(name string) (IProfessionDriverInfo, bool)

+ func (d *ProfessionDrivers) Keys() []string

+ func (d *ProfessionDrivers) List() []IProfessionDriverInfo

+ type ProfessionInfo struct

+ AppendLabels []string

+ Dependencies []string

+ Desc string

+ Drivers []DriverInfo

+ LocalName string

+ Name string

+ type ProfessionItem struct

+ type Professions struct

+ func (ps *Professions) Delete(profession, name string) error

+ func (ps *Professions) DriverInfo(profession, driver string) (DriverDetail, error)

+ func (ps *Professions) Drivers(profession string) ([]DriverInfo, error)

+ func (ps *Professions) DriversItem(profession string) ([]Item, error)

+ func (ps *Professions) Get(profession, name string) (interface{}, error)

+ func (ps *Professions) Infos() []ProfessionInfo

+ func (ps *Professions) ListEmployees(profession string) ([]interface{}, error)

+ func (ps *Professions) ListProfessions() []ProfessionInfo

+ func (ps *Professions) OnChange(v StoreValue) error

+ func (ps *Professions) OnDel(v StoreValue) error

+ func (ps *Professions) OnInit(vs []StoreValue) error

+ func (ps *Professions) Render(profession, driver string) (*Render, error)

+ func (ps *Professions) Renders(profession string) (map[string]*Render, error)

+ func (ps *Professions) SearchBySkill(profession string, skill []string) ([]WorkerInfo, error)

+ func (ps *Professions) Update(profession, name, driver string, data IData) (*WorkerInfo, error)

+ type Register struct

+ func (r *Register) Get(name string) (interface{}, bool)

+ func (r *Register) Register(name string, obj interface{}, force bool) error

+ type Render struct

+ func GenRender(t reflect.Type) *Render

+ type RequireId string

+ type StoreEventDispatcher struct

+ func NewStoreDispatcher() *StoreEventDispatcher

+ func (s *StoreEventDispatcher) AddListen(h IStoreEventHandler) bool

+ func (s *StoreEventDispatcher) DispatchChange(v StoreValue) error

+ func (s *StoreEventDispatcher) DispatchDel(v StoreValue) error

+ func (s *StoreEventDispatcher) DispatchInit(vs []StoreValue) error

+ type StoreValue struct

+ CreateTime string

+ Driver string

+ IData IData

+ Id string

+ Name string

+ Profession string

+ Sing string

+ UpdateTime string

+ type WorkManager struct

+ func NewWorkers(professions IProfessions, store IStore) (*WorkManager, error)

+ func (wm *WorkManager) Del(id string) (IWorker, bool)

+ func (wm *WorkManager) Get(id string) (IWorker, bool)

+ func (wm *WorkManager) OnChange(v StoreValue) error

+ func (wm *WorkManager) OnDel(v StoreValue) error

+ func (wm *WorkManager) OnInit(vs []StoreValue) error

+ func (wm *WorkManager) SetWorker(v *StoreValue) error

+ type WorkerInfo struct

+ Create string

+ Driver string

+ Id string

+ Name string

+ Update string

+ type Workers struct

+ func (ws *Workers) Del(id string) (*tWorker, bool)

+ func (ws *Workers) Get(id string) (*tWorker, bool)

+ func (ws *Workers) Set(id string, w *tWorker)