worker

type ManagesPlugins interface {
	Load(...string) (core.CatalogedPlugin, perror.PulseError)
	Unload(plugin core.Plugin) (core.CatalogedPlugin, perror.PulseError)
	PluginCatalog() core.PluginCatalog
}

type ManagesTasks interface {
	GetTask(id string) (core.Task, error)
	CreateTask(sch schedule.Schedule, wfMap *wmap.WorkflowMap, startOnCreate bool, opts ...core.TaskOption) (core.Task, core.TaskErrors)
}

type Member interface {
	GetAddr() net.IP
	GetRestPort() string
	GetRestProto() string
	GetRestInsecureSkipVerify() bool
	GetName() string
}

type PluginRequest struct {
	Plugin      core.Plugin
	RequestType int
}

type Task struct {
	ID            string
	StartOnCreate bool
}

type TaskRequest struct {
	Task        Task
	RequestType int
}