Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPlugin ¶
func GetPlugin(name string) *common.IPluginContract
Types ¶
type FSPlugin ¶
func (FSPlugin) Configs ¶
func (p FSPlugin) Configs(conf map[string]string) common.IPluginContract
Configs implements contract.IPluginContract
func (FSPlugin) Execute ¶
func (FSPlugin) Execute(task *protos.Task) *protos.TaskResult
Execute implements contract.IPluginContract (worker job)
func (FSPlugin) PlanRead ¶
func (p FSPlugin) PlanRead() []*protos.IPartition
Plan implements plugins.IPluginContract
Click to show internal directories.
Click to hide internal directories.