Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

process_admin

package

Go to main page

Versions in this module

v1

v1.15.7

Feb 3, 2024

v1.15.6

Jan 31, 2024

v1.15.5

Jan 31, 2024

Changes in this version

type Workers

+ func (oe *Workers) InitOutput(professions professions.IProfessions, data *WorkerDatas, ...)

v1.15.4

Jan 30, 2024

v1.15.3

Jan 16, 2024

v1.15.2

Jan 10, 2024

Changes in this version

+ const Setting

+ var ErrorDuplicatePath = errors.New("path duplicate")

+ var ErrorExtenderNotWork = errors.New("not work")

+ var ErrorExtenderVersionIsChange = errors.New("the version of extender has changed")

+ var ErrorInnerExtenderCantChange = errors.New("is inner")

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

+ var ErrorNotMatch = errors.New("not match profession")

+ var ErrorUnknownContentType = errors.New("unknown content type")

+ func Process()

+ type BaseArg struct

+ Description string

+ Driver string

+ Id string

+ Name string

+ Version string

+ type CacheItem struct

+ type ExportApi struct

+ func NewExportApi(extenders *ExtenderData, profession professions.IProfessions, workers *Workers) *ExportApi

+ func (oe *ExportApi) Register(router *httprouter.Router)

+ type ExtenderData struct

+ Infos map[string]*ExtenderProject

+ Versions map[string]string

+ func NewExtenderData(conf map[string][]byte, extenderRequire eosc.IRequires) *ExtenderData

+ func (e *ExtenderData) Delete(group, project, version string) (*ExtenderProject, error)

+ func (e *ExtenderData) GetConfigTypes() map[string]reflect.Type

+ func (e *ExtenderData) GetInfo(group, project string) ([]*ExtenderItemInfo, bool)

+ func (e *ExtenderData) GetRender(group, project, name string) (*ExtenderItemRender, bool)

+ func (e *ExtenderData) IsWork() bool

+ func (e *ExtenderData) List() []*ExtenderItem

+ func (e *ExtenderData) SetVersion(group, project, version string) (*ExtenderProject, bool, error)

+ type ExtenderItem struct

+ Id string

+ type ExtenderItemInfo struct

+ Group string

+ Name string

+ Project string

+ Version string

+ type ExtenderItemRender struct

+ Render interface{}

+ type ExtenderOpenApi struct

+ func NewExtenderOpenApi(extenders *ExtenderData) *ExtenderOpenApi

+ func (oe *ExtenderOpenApi) Delete(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (oe *ExtenderOpenApi) Info(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (oe *ExtenderOpenApi) List(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (oe *ExtenderOpenApi) Register(router *httprouter.Router)

+ func (oe *ExtenderOpenApi) Render(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (oe *ExtenderOpenApi) SET(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ type ExtenderProject struct

+ type IData interface

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

+ UnMarshal func(v interface{}) error

+ func GetData(req *http.Request) (IData, error)

+ type JsonData []byte

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

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

+ func (j JsonData) String() string

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

+ type ProcessAdmin struct

+ func NewProcessAdmin(parent context.Context, arg map[string]map[string][]byte) (*ProcessAdmin, error)

+ func (pa *ProcessAdmin) OpenApiServer() error

+ func (pa *ProcessAdmin) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type ProfessionApi struct

+ func NewProfessionApi(data professions.IProfessions, ws *WorkerDatas) *ProfessionApi

+ func (pi *ProfessionApi) AddDriver(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (pi *ProfessionApi) All(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (pi *ProfessionApi) Delete(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (pi *ProfessionApi) Detail(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (pi *ProfessionApi) DriverInfo(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (pi *ProfessionApi) Drivers(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (pi *ProfessionApi) Register(router *httprouter.Router)

+ func (pi *ProfessionApi) ResetDrivers(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (pi *ProfessionApi) SetDriver(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (pi *ProfessionApi) Skill(req *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ type ProfessionInfo struct

+ Desc string

+ Driver []string

+ Label string

+ Name string

+ type ProfessionsRequire struct

+ func NewProfessionsRequire(professions professions.IProfessions, requires eosc.IRequires) *ProfessionsRequire

+ func (p *ProfessionsRequire) Delete(name string) error

+ func (p *ProfessionsRequire) Reset(configs []*eosc.ProfessionConfig)

+ func (p *ProfessionsRequire) Set(name string, profession *eosc.ProfessionConfig) error

+ type SettingApi struct

+ func NewSettingApi(init map[string][]byte, workers *Workers, variable eosc.IVariable) *SettingApi

+ func (oe *SettingApi) Get(req *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (oe *SettingApi) RegisterSetting(router *httprouter.Router)

+ func (oe *SettingApi) Set(req *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ type VariableApi struct

+ func NewVariableApi(extenderData *ExtenderData, workers *Workers, variableData eosc.IVariable, ...) *VariableApi

+ func (oe *VariableApi) Register(router *httprouter.Router)

+ type WorkerApi struct

+ func NewWorkerApi(workers *Workers, ...) *WorkerApi

+ func (oe *WorkerApi) Add(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (oe *WorkerApi) Delete(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (oe *WorkerApi) Patch(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ func (oe *WorkerApi) Register(router *httprouter.Router)

+ func (oe *WorkerApi) Save(r *http.Request, params httprouter.Params) (status int, header http.Header, events []*open_api.EventResponse, ...)

+ type WorkerDatas struct

+ func NewWorkerDatas(initData map[string][]byte) *WorkerDatas

+ func (w *WorkerDatas) All() map[string]*WorkerInfo

+ func (w *WorkerDatas) Clone() *WorkerDatas

+ func (w *WorkerDatas) Count() int

+ func (w *WorkerDatas) Del(id string) (*WorkerInfo, bool)

+ func (w *WorkerDatas) Get(id string) (eosc.IWorker, bool)

+ func (w *WorkerDatas) GetInfo(id string) (*WorkerInfo, bool)

+ func (w *WorkerDatas) Keys() []string

+ func (w *WorkerDatas) List() []*WorkerInfo

+ func (w *WorkerDatas) Set(id string, v *WorkerInfo)

+ type WorkerInfo struct

+ func NewWorkerInfo(worker eosc.IWorker, id string, profession string, ...) *WorkerInfo

+ func (w *WorkerInfo) Body() []byte

+ func (w *WorkerInfo) ConfigType() reflect.Type

+ func (w *WorkerInfo) Detail() interface{}

+ func (w *WorkerInfo) Info(appendLabels ...string) interface{}

+ type Workers struct

+ func NewWorkers() *Workers

+ func (oe *Workers) Delete(id string) (*WorkerInfo, error)

+ func (oe *Workers) DeleteTest(ids ...string) (requires []string)

+ func (oe *Workers) Export() map[string][]*WorkerInfo

+ func (oe *Workers) GetEmployee(profession, name string) (*WorkerInfo, error)

+ func (oe *Workers) Init(professions professions.IProfessions, data *WorkerDatas, ...)

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

+ func (oe *Workers) Update(profession, name, driver, version, desc string, data IData) (*WorkerInfo, error)

+ type YamlData []byte

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

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

+ func (y YamlData) String() string

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