fd

Documentation

Index

• Variables
• func DecodeConfig(config pipeline.AnyConfig, configJson []byte) error
• type FileD
  • func New(config *cfg.Config, httpAddr string) *FileD
  • func (f *FileD) SetConfig(config *cfg.Config)
  • func (f *FileD) Start()
  • func (f *FileD) Stop(ctx context.Context) error
• type PluginRegistry
  • func (r *PluginRegistry) Get(kind pipeline.PluginKind, t string) *pipeline.PluginStaticInfo
  • func (r *PluginRegistry) GetActionByType(t string) *pipeline.PluginStaticInfo
  • func (r *PluginRegistry) MakeID(pluginKind pipeline.PluginKind, pluginType string) string
  • func (r *PluginRegistry) RegisterAction(info *pipeline.PluginStaticInfo)
  • func (r *PluginRegistry) RegisterInput(info *pipeline.PluginStaticInfo)
  • func (r *PluginRegistry) RegisterOutput(info *pipeline.PluginStaticInfo)

Variables

var DefaultPluginRegistry = &PluginRegistry{
	plugins: make(map[string]*pipeline.PluginStaticInfo),
}

Functions

func DecodeConfig

func DecodeConfig(config pipeline.AnyConfig, configJson []byte) error

Types

type FileD

type FileD struct {
	Pipelines []*pipeline.Pipeline
	// contains filtered or unexported fields
}

func New

func New(config *cfg.Config, httpAddr string) *FileD

func (*FileD) SetConfig

func (f *FileD) SetConfig(config *cfg.Config)

func (*FileD) Start

func (f *FileD) Start()

func (*FileD) Stop

func (f *FileD) Stop(ctx context.Context) error

type PluginRegistry

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

func (*PluginRegistry) Get

func (r *PluginRegistry) Get(kind pipeline.PluginKind, t string) *pipeline.PluginStaticInfo

func (*PluginRegistry) GetActionByType

func (r *PluginRegistry) GetActionByType(t string) *pipeline.PluginStaticInfo

func (*PluginRegistry) MakeID

func (r *PluginRegistry) MakeID(pluginKind pipeline.PluginKind, pluginType string) string

func (*PluginRegistry) RegisterAction

func (r *PluginRegistry) RegisterAction(info *pipeline.PluginStaticInfo)

func (*PluginRegistry) RegisterInput

func (r *PluginRegistry) RegisterInput(info *pipeline.PluginStaticInfo)

func (*PluginRegistry) RegisterOutput

func (r *PluginRegistry) RegisterOutput(info *pipeline.PluginStaticInfo)