eosc

package module
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2021 License: Apache-2.0 Imports: 18 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")
	ErrorNotAllowCreateForSingleton = errors.New("not allow create for singleton profession")
	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 (
	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

Functions

func CheckConfig 

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

func CreateFile added in v0.3.0 

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

func Decompress added in v0.3.0 

func Decompress(filePath string, dest string) error

Decompress 解压文件

func FileSha1 added in v0.3.0 

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

func GetRealIP added in v0.1.1 

func GetRealIP(r *http.Request) string

func Now added in v0.0.7 

func Now() string

func SHA1 added in v0.3.0 

func SHA1(data []byte) string

SHA1 生成SHA1加密后的16进制字符串

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

func Version added in v0.3.0 

func Version() 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 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 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 IExtenderConfigChecker added in v0.3.0 

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

type IExtenderDriver added in v0.3.0 

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

type IExtenderDriverFactory added in v0.3.0 

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

type IExtenderDriverManager added in v0.3.1 

type IExtenderDriverManager interface {
	IExtenderDriverRegister
	Remove(name string)
}

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 IProfession 

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

type IProfessions 

type IProfessions interface {
	Set(name string, profession *ProfessionConfig) error
	Delete(name string) error
	GetProfession(name string) (IProfession, 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)
	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 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"`
	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 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 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) Del added in v0.3.1 

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

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

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) 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

type WorkerConfigs added in v0.3.0 

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

func (*WorkerConfigs) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use WorkerConfigs.ProtoReflect.Descriptor instead.

func (*WorkerConfigs) GetData added in v0.3.0 

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

func (*WorkerConfigs) ProtoMessage added in v0.3.0 

func (*WorkerConfigs) ProtoMessage()

func (*WorkerConfigs) ProtoReflect added in v0.3.0 

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

func (*WorkerConfigs) Reset added in v0.3.0 

func (x *WorkerConfigs) Reset()

func (*WorkerConfigs) String added in v0.3.0 

func (x *WorkerConfigs) 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
fileLocker
port-reqiure
log
filelog
transporter-manager
modules
admin-html
admin-open-api
admin
extenders
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.