plugins

Documentation

Index

• func GetPlugin(name string) common.IPluginContract
• func NewFSPlugin() common.IPluginContract
• type FSPlugin
  • func (p FSPlugin) Configs(conf map[string]string) common.IPluginContract
  • func (FSPlugin) Execute(task *protos.Task) *protos.TaskResult
  • func (p FSPlugin) Name() string
  • func (p FSPlugin) Plan(args ...interface{}) []*protos.Task

Functions

func GetPlugin

func GetPlugin(name string) common.IPluginContract

func NewFSPlugin

func NewFSPlugin() common.IPluginContract

Name must be New + struct name

Types

type FSPlugin

type FSPlugin struct {
	Path        string
	Format      string
	Parallelism int
}

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

func (p FSPlugin) Name() string

Name implements plugins.IPluginContract

func (FSPlugin) Plan

func (p FSPlugin) Plan(args ...interface{}) []*protos.Task

Plan implements plugins.IPluginContract