processor

package

v1.0.3 Latest Latest Go to latest Published: Jun 23, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func Plugin(
	module string,
	factory Factory,
) map[string][]interface{}

func Register(name string, factory Factory) error

func Validate(processor Processor) error

type Factory interface {
	// 组件示例配置
	SampleConfig() string

	// 组件描述
	Description() string

	// 创建实例
	New(config string) (Processor, error)
}

func GetFactory(name string) (Factory, error)

func NewFactory(sampleConfig interface{}, description string, factoryFunc FactoryFunc) Factory

func NewFactoryWithProcessor(sampleConfig interface{}, description string, p Processor) Factory

type FactoryFunc func(config string) (Processor, error)

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

func (f FactoryTemplate) Description() string

func (f FactoryTemplate) New(config string) (Processor, error)

func (f FactoryTemplate) SampleConfig() string

type NamedFactory struct {
	Name    string
	Factory Factory
}

func ListFactory() []NamedFactory

type Processor interface{}