process_worker

type ExtenderRegister interface {
	eosc.IExtenderDriverManager
	eosc.IExtenderDrivers
}

type IProfession interface {
	GetDriver(name string) (eosc.IExtenderDriver, bool)
}

type IProfessions interface {
	Get(name string) (*Profession, bool)
	Sort() []*Profession
	List() []*Profession
	Reset(configs []*eosc.ProfessionConfig, extends eosc.IExtenderDrivers)
}

type ITypedProfessionDrivers interface {
	Get(name string) (eosc.IExtenderDriver, bool)
}

type ITypedWorkers interface {
	Set(id string, w *Worker)
	Del(id string) (*Worker, bool)
	Get(id string) (*Worker, bool)
	All() []*Worker
}

type IWorker interface {
	eosc.IWorker
}

type IWorkerRequireManager interface {
	Set(id string, requires []string)
	Del(id string)
	RequireByCount(requireId string) int
}

type IWorkers interface {
	eosc.IWorkers
	Del(id string) error
	Check(id, profession, name, driverName string, body []byte) error
	Set(id, profession, name, driverName string, body []byte) error
	RequiredCount(id string) int
	Reset(wdl []*eosc.WorkerConfig) error
}

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

type Profession struct {
	*eosc.ProfessionConfig
	// contains filtered or unexported fields
}

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

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

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

type Worker struct {
	eosc.IWorker

	Profession string
	Name       string
	Driver     string
	// contains filtered or unexported fields
}

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

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

type WorkerServer struct {
	service.UnimplementedWorkerServiceServer
	*grpc.Server
	// contains filtered or unexported fields
}