manager

type AlreadyRegisteredError struct{}

type Capabilities struct {
	Receiver bool
	Filterer bool
	Sender   bool
}

type Config struct {
	Name   string `yaml:"name"`
	Path   string `yaml:"path"`
	Config string `yaml:"config"`
}

type InvalidConfigError struct {
	Err error
}

type Manager interface {
	// Probably needs some sort of asset interface to
	// be able to load from file system, s3, and other places [Future]
	LoadPlugin(config Config) (plugin.Pluginer, error)

	RegisterPlugin(name string, p plugin.Pluginer) error
	UnregisterPlugin(name string) error

	Plugins() map[string]Registration
	Plugin(name string) Registration

	Receiverers() map[string]receiver.NewReceiverer
	Receiverer(pluginName string) (receiver.NewReceiverer, error)

	Filterers() map[string]filter.NewFilterer
	Filterer(pluginName string) (filter.NewFilterer, error)

	Senderers() map[string]sender.NewSenderer
	Senderer(pluginName string) (sender.NewSenderer, error)
}

type NewFiltererNotImplementedError struct{}

type NewPluginerError struct {
	Err error
}

type NewPluginerNotImplementedError struct{}

type NewReceivererNotImplementedError struct{}

type NewSendererNotImplementedError struct{}

type NilPluginError struct{}

type NotFoundError struct{}

type NotRegisteredError struct{}

type OpenPluginError struct {
	Err error
}

type Option func(OptionProcessor) error

type OptionProcessor interface{}

type Registration struct {
	Config Config
	Plugin plugin.Pluginer

	Capabilities Capabilities
}

type VariableLookupError struct {
	Err error
}