eosc

package module
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 30, 2021 License: Apache-2.0 Imports: 12 Imported by: 99

README

架构

image

抽象概念

profession

profession:职业,定义抽象分类

  1. profession定义名是唯一的,在框架中等于常量,不区分大小写, 只能用 字母、数字、下划线
    • 例如: upstream,service,router,plugin
  2. profession 定义列表字段,以及列表默认值
  3. 所有的配置项目都是profession实例,实例必须具有如下属性
    • id: uuid,全局唯一
    • name: name, 同profession内唯一
    • driver: 实现该实例的驱动名
  4. profession 实例需要实现销毁方法,框架会检查依赖关系并中断销毁

目前已知可能有的 profession 定义有

  • upstream
  • service
  • router
  • service discovery
  • auth
driver

driver:驱动,定义一个profession并实现能力

  1. driver需要定义一个render 给 admin ui 处理界面
  2. driver 实现检查 profession 的属性
  3. driver 实现通过 profession 的属性实例话运行的实例并完成运行状态的
  4. profession 实例的能力和属性由driver来定义
  5. driver 声明一个能力清单, 在实例依赖另一个实例时,通过查询对方能力来决定是否可用,并在执行时使用该能力

Documentation

Overview

SPDX-License-Identifier: Apache-2.0

Index

Constants

View Source 
const (
	ProcessMaster = "master"
	ProcessWorker = "worker"
	ProcessHelper = "helper"
)

Variables

View Source 
var (
	ErrorDriverNotExist          = errors.New("driver not exist")
	ErrorProfessionNotExist      = errors.New("profession not exist")
	ErrorWorkerNotExits          = errors.New("workers 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 File_message_proto protoreflect.FileDescriptor

Functions

func CheckConfig 

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

func Now added in v0.0.7 

func Now() string

func RegisterProfessionDriver 

func RegisterProfessionDriver(name string, factory IProfessionDriverFactory) error

func ToWorkerId added in v0.1.0 

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

func TypeName 

func TypeName(t reflect.Type) string

func TypeNameOf 

func TypeNameOf(v interface{}) string

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 DriverDetail 

type DriverDetail struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Driver string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"` // 驱动名 = driverConfig.name
	Label  string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	Desc   string `protobuf:"bytes,4,opt,name=desc,proto3" json:"desc,omitempty"`
	//  string profession=5;
	Params map[string]string `` /* 153-byte string literal not displayed */
	Plugin *PluginInfo       `protobuf:"bytes,6,opt,name=plugin,proto3" json:"plugin,omitempty"`
	// contains filtered or unexported fields
}

驱动详情

func ToDriverDetail added in v0.1.0 

func ToDriverDetail(config *DriverConfig) *DriverDetail

func ToDriverDetails added in v0.1.0 

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

func (*DriverDetail) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use DriverDetail.ProtoReflect.Descriptor instead.

func (*DriverDetail) GetDesc added in v0.1.0 

func (x *DriverDetail) GetDesc() string

func (*DriverDetail) GetDriver added in v0.1.0 

func (x *DriverDetail) GetDriver() string

func (*DriverDetail) GetId added in v0.1.0 

func (x *DriverDetail) GetId() string

func (*DriverDetail) GetLabel added in v0.1.0 

func (x *DriverDetail) GetLabel() string

func (*DriverDetail) GetParams added in v0.1.0 

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

func (*DriverDetail) GetPlugin added in v0.1.0 

func (x *DriverDetail) GetPlugin() *PluginInfo

func (*DriverDetail) ProtoMessage added in v0.1.0 

func (*DriverDetail) ProtoMessage()

func (*DriverDetail) ProtoReflect added in v0.1.0 

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

func (*DriverDetail) Reset added in v0.1.0 

func (x *DriverDetail) Reset()

func (*DriverDetail) String added in v0.1.0 

func (x *DriverDetail) String() string

type DriverInfo 

type DriverInfo 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"` //  string profession=5;
	// contains filtered or unexported fields
}

func (*DriverInfo) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use DriverInfo.ProtoReflect.Descriptor instead.

func (*DriverInfo) GetDesc added in v0.1.0 

func (x *DriverInfo) GetDesc() string

func (*DriverInfo) GetId added in v0.1.0 

func (x *DriverInfo) GetId() string

func (*DriverInfo) GetLabel added in v0.1.0 

func (x *DriverInfo) GetLabel() string

func (*DriverInfo) GetName added in v0.1.0 

func (x *DriverInfo) GetName() string

func (*DriverInfo) ProtoMessage added in v0.1.0 

func (*DriverInfo) ProtoMessage()

func (*DriverInfo) ProtoReflect added in v0.1.0 

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

func (*DriverInfo) Reset added in v0.1.0 

func (x *DriverInfo) Reset()

func (*DriverInfo) String added in v0.1.0 

func (x *DriverInfo) String() string

type IAdmin 

type IAdmin interface {
	IAdminWorker
	IAdminPermission
}

type IAdminHandler 

type IAdminHandler interface {
	GenHandler() (http.Handler, error)
}

type IAdminPermission added in v0.1.0 

type IAdminPermission interface {
	Drivers(profession string) ([]*DriverInfo, error)
	DriverInfo(profession, driver string) (*DriverDetail, error)
	DriversItem(profession string) ([]*Item, error)
	ListProfessions() []*ProfessionInfo
}

type IAdminWorker added in v0.1.0 

type IAdminWorker interface {
	ListEmployees(profession string) ([]interface{}, error)
	//ListEmployeeNames(profession string) ([]string, error)
	Update(profession, name, driver string, data []byte) (interface{}, error)
	Delete(profession, name string) (interface{}, error)
	GetEmployee(profession, name string) (interface{}, error)
}

type IDataMarshaller added in v0.1.0 

type IDataMarshaller interface {
	Encode(startIndex int) ([]byte, []*os.File, error)
}

type IDriverRegister 

type IDriverRegister interface {
	RegisterProfessionDriver(name string, factory IProfessionDriverFactory) error
	GetProfessionDriver(name string) (IProfessionDriverFactory, bool)
}
var (
	DefaultProfessionDriverRegister IDriverRegister = NewProfessionDriverRegister()
)

type IProfessionData added in v0.1.0 

type IProfessionData interface {
	Drivers() []*DriverInfo
	GetDriver(name string) (*DriverDetail, bool)
	HasDriver(name string) bool
	AppendAttr() []string
	DriversItem() []*Item
	Detail() *ProfessionDetail
}

type IProfessionDataEdit added in v0.1.0 

type IProfessionDataEdit interface {
	SetDriver(name string, detail *DriverConfig) error
	DeleteDriver(name string) error
}

type IProfessionDriver 

type IProfessionDriver interface {
	ConfigType() reflect.Type
	Create(id, name string, v interface{}, workers map[RequireId]interface{}) (IWorker, error)
}

type IProfessionDriverCheckConfig added in v0.0.7 

type IProfessionDriverCheckConfig interface {
	Check(v interface{}, workers map[RequireId]interface{}) error
}

type IProfessionDriverFactory 

type IProfessionDriverFactory interface {
	Create(profession string, name string, label string, desc string, params map[string]string) (IProfessionDriver, error)
}

func GetProfessionDriver 

func GetProfessionDriver(name string) (IProfessionDriverFactory, bool)

type IProfessionsData added in v0.1.0 

type IProfessionsData interface {
	Set(name string, profession *ProfessionConfig) error
	Delete(name string) error
	GetProfession(name string) (IProfessionData, bool)

	Infos() []*ProfessionInfo
	Reset([]*ProfessionConfig)
	All() []*ProfessionConfig
}

type IRegister 

type IRegister interface {
	Register(name string, obj interface{}, force bool) error
	Get(name string) (interface{}, bool)
}

func NewRegister 

func NewRegister() IRegister

type IRegisterData 

type IRegisterData interface {
	Set(name string, v interface{})
	Get(name string) (interface{}, bool)
}

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 IWorker 

type IWorker interface {
	Id() string
	Start() error
	Reset(conf interface{}, workers map[RequireId]interface{}) error
	Stop() error
	CheckSkill(skill string) bool
}

type IWorkerResources added in v0.1.0 

type IWorkerResources interface {
	Ports() []int
}

type IWorkers 

type IWorkers interface {
	Get(id string) (IWorker, bool)
}

type IWorkersData added in v0.1.0 

type IWorkersData interface {
	GetWork(id string) (TWorker, error)
	GetList(profession string) ([]TWorker, error)
	Delete(id string) (TWorker, error)
	Set(profession, name, driver string, data []byte) (TWorker, error)
}

type Item 

type Item struct {
	Value string `json:"value"`
	Label string `json:"label"`
}

type JsonData added in v0.0.9 

type JsonData []byte

func (JsonData) Marshal added in v0.0.9 

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

func (JsonData) UnMarshal added in v0.0.9 

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

type PluginInfo added in v0.1.0 

type PluginInfo struct {
	Group   string `protobuf:"bytes,6,opt,name=group,proto3" json:"group,omitempty"`
	Project string `protobuf:"bytes,7,opt,name=project,proto3" json:"project,omitempty"`
	Name    string `protobuf:"bytes,8,opt,name=name,proto3" json:"name,omitempty"` // 插件名
	// contains filtered or unexported fields
}

func (*PluginInfo) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use PluginInfo.ProtoReflect.Descriptor instead.

func (*PluginInfo) GetGroup added in v0.1.0 

func (x *PluginInfo) GetGroup() string

func (*PluginInfo) GetName added in v0.1.0 

func (x *PluginInfo) GetName() string

func (*PluginInfo) GetProject added in v0.1.0 

func (x *PluginInfo) GetProject() string

func (*PluginInfo) ProtoMessage added in v0.1.0 

func (*PluginInfo) ProtoMessage()

func (*PluginInfo) ProtoReflect added in v0.1.0 

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

func (*PluginInfo) Reset added in v0.1.0 

func (x *PluginInfo) Reset()

func (*PluginInfo) String added in v0.1.0 

func (x *PluginInfo) 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"`
	// 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) 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 ProfessionConfigData added in v0.1.0 

type ProfessionConfigData struct {
	Data []*ProfessionConfig `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfessionConfigData) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ProfessionConfigData.ProtoReflect.Descriptor instead.

func (*ProfessionConfigData) GetData added in v0.1.0 

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

func (*ProfessionConfigData) ProtoMessage added in v0.1.0 

func (*ProfessionConfigData) ProtoMessage()

func (*ProfessionConfigData) ProtoReflect added in v0.1.0 

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

func (*ProfessionConfigData) Reset added in v0.1.0 

func (x *ProfessionConfigData) Reset()

func (*ProfessionConfigData) String added in v0.1.0 

func (x *ProfessionConfigData) String() string

type ProfessionDetail added in v0.1.0 

type ProfessionDetail 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      []*DriverDetail `protobuf:"bytes,6,rep,name=drivers,proto3" json:"drivers,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfessionDetail) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ProfessionDetail.ProtoReflect.Descriptor instead.

func (*ProfessionDetail) GetAppendLabels added in v0.1.0 

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

func (*ProfessionDetail) GetDependencies added in v0.1.0 

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

func (*ProfessionDetail) GetDesc added in v0.1.0 

func (x *ProfessionDetail) GetDesc() string

func (*ProfessionDetail) GetDrivers added in v0.1.0 

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

func (*ProfessionDetail) GetLabel added in v0.1.0 

func (x *ProfessionDetail) GetLabel() string

func (*ProfessionDetail) GetName added in v0.1.0 

func (x *ProfessionDetail) GetName() string

func (*ProfessionDetail) ProtoMessage added in v0.1.0 

func (*ProfessionDetail) ProtoMessage()

func (*ProfessionDetail) ProtoReflect added in v0.1.0 

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

func (*ProfessionDetail) Reset added in v0.1.0 

func (x *ProfessionDetail) Reset()

func (*ProfessionDetail) String added in v0.1.0 

func (x *ProfessionDetail) String() string

type ProfessionDriverRegister 

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

func NewProfessionDriverRegister 

func NewProfessionDriverRegister() *ProfessionDriverRegister

func (*ProfessionDriverRegister) GetProfessionDriver 

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

func (*ProfessionDriverRegister) RegisterProfessionDriver 

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

type ProfessionInfo 

type ProfessionInfo 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"`   //
	// contains filtered or unexported fields
}

func (*ProfessionInfo) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ProfessionInfo.ProtoReflect.Descriptor instead.

func (*ProfessionInfo) GetDesc added in v0.1.0 

func (x *ProfessionInfo) GetDesc() string

func (*ProfessionInfo) GetLabel added in v0.1.0 

func (x *ProfessionInfo) GetLabel() string

func (*ProfessionInfo) GetName added in v0.1.0 

func (x *ProfessionInfo) GetName() string

func (*ProfessionInfo) ProtoMessage added in v0.1.0 

func (*ProfessionInfo) ProtoMessage()

func (*ProfessionInfo) ProtoReflect added in v0.1.0 

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

func (*ProfessionInfo) Reset added in v0.1.0 

func (x *ProfessionInfo) Reset()

func (*ProfessionInfo) String added in v0.1.0 

func (x *ProfessionInfo) String() string

type Register 

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

func (*Register) Get 

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

func (*Register) Register 

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

type RequireId 

type RequireId string

type TWorker added in v0.1.0 

type TWorker map[string]interface{}

type WorkerData added in v0.1.0 

type WorkerData 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"`
	// contains filtered or unexported fields
}

func (*WorkerData) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use WorkerData.ProtoReflect.Descriptor instead.

func (*WorkerData) GetBody added in v0.1.0 

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

func (*WorkerData) GetCreate added in v0.1.0 

func (x *WorkerData) GetCreate() string

func (*WorkerData) GetDriver added in v0.1.0 

func (x *WorkerData) GetDriver() string

func (*WorkerData) GetId added in v0.1.0 

func (x *WorkerData) GetId() string

func (*WorkerData) GetName added in v0.1.0 

func (x *WorkerData) GetName() string

func (*WorkerData) GetProfession added in v0.1.0 

func (x *WorkerData) GetProfession() string

func (*WorkerData) GetUpdate added in v0.1.0 

func (x *WorkerData) GetUpdate() string

func (*WorkerData) ProtoMessage added in v0.1.0 

func (*WorkerData) ProtoMessage()

func (*WorkerData) ProtoReflect added in v0.1.0 

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

func (*WorkerData) Reset added in v0.1.0 

func (x *WorkerData) Reset()

func (*WorkerData) String added in v0.1.0 

func (x *WorkerData) String() string

type WorkerInfo 

type WorkerInfo 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"`
	// contains filtered or unexported fields
}

func (*WorkerInfo) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use WorkerInfo.ProtoReflect.Descriptor instead.

func (*WorkerInfo) GetCreate added in v0.1.0 

func (x *WorkerInfo) GetCreate() string

func (*WorkerInfo) GetDriver added in v0.1.0 

func (x *WorkerInfo) GetDriver() string

func (*WorkerInfo) GetId added in v0.1.0 

func (x *WorkerInfo) GetId() string

func (*WorkerInfo) GetName added in v0.1.0 

func (x *WorkerInfo) GetName() string

func (*WorkerInfo) GetProfession added in v0.1.0 

func (x *WorkerInfo) GetProfession() string

func (*WorkerInfo) GetUpdate added in v0.1.0 

func (x *WorkerInfo) GetUpdate() string

func (*WorkerInfo) ProtoMessage added in v0.1.0 

func (*WorkerInfo) ProtoMessage()

func (*WorkerInfo) ProtoReflect added in v0.1.0 

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

func (*WorkerInfo) Reset added in v0.1.0 

func (x *WorkerInfo) Reset()

func (*WorkerInfo) String added in v0.1.0 

func (x *WorkerInfo) String() string

type WorkersData added in v0.1.0 

type WorkersData struct {
	Data []*WorkerData `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkersData) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use WorkersData.ProtoReflect.Descriptor instead.

func (*WorkersData) GetData added in v0.1.0 

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

func (*WorkersData) ProtoMessage added in v0.1.0 

func (*WorkersData) ProtoMessage()

func (*WorkersData) ProtoReflect added in v0.1.0 

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

func (*WorkersData) Reset added in v0.1.0 

func (x *WorkersData) Reset()

func (*WorkersData) String added in v0.1.0 

func (x *WorkersData) String() string

type XMLData added in v0.0.9 

type XMLData []byte

type YamlData added in v0.0.9 

type YamlData []byte

func (YamlData) Marshal added in v0.0.9 

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

func (YamlData) UnMarshal added in v0.0.9 

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

Source Files

View all Source files

Directories

Path Synopsis
app
eoserver
common
bean
log
filelog
transporter-manager
modules
admin-html
admin-open-api
admin
professions
service
workers
raft-service
* Copyright (c) 2021.
 * Copyright (c) 2021.
traffic-http-fast

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.