pluginapi

type ConsumerIOPluginable interface {
	PluginConfigurer
	graph.Consumer[[]byte]
}

type IOWorkerPluginable interface {
	PluginConfigurer
	graph.IOWorker[[]byte]
}

type PluginConfigurer interface {
	GetInputSchema() ([]byte, error)
	Config(config []byte) error
}

type ProducerIOPluginable interface {
	PluginConfigurer
	graph.Producer[[]byte]
}

type RunnerIOPluginable interface {
	PluginConfigurer
	graph.Runner[[]byte]
}

type WorkerPluginable interface {
	PluginConfigurer
	graph.Worker[[]byte]
}