fd

package
v0.25.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 26, 2024 License: BSD-3-Clause Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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 (*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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL