pluginapi

Documentation

Index

• func NewIOWorkerPluginFromConsumer(plugin ConsumerIOPluginable) ioWorker
• func NewIOWorkerPluginFromProducer(plugin ProducerIOPluginable) ioWorker
• func NewIOWorkerPluginFromRunner(plugin RunnerIOPluginable) ioWorker
• func NewIOWorkerPluginFromWorker(plugin WorkerPluginable) ioWorker
• type ConsumerIOPluginable
• type IOWorkerPluginable
• type PluginConfigurer
• type ProducerIOPluginable
• type RunnerIOPluginable
• type WorkerPluginable

Functions

func NewIOWorkerPluginFromConsumer

func NewIOWorkerPluginFromConsumer(plugin ConsumerIOPluginable) ioWorker

func NewIOWorkerPluginFromProducer

func NewIOWorkerPluginFromProducer(plugin ProducerIOPluginable) ioWorker

func NewIOWorkerPluginFromRunner

func NewIOWorkerPluginFromRunner(plugin RunnerIOPluginable) ioWorker

func NewIOWorkerPluginFromWorker

func NewIOWorkerPluginFromWorker(plugin WorkerPluginable) ioWorker

Types

type ConsumerIOPluginable

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

type IOWorkerPluginable

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

type PluginConfigurer

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

type ProducerIOPluginable

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

type RunnerIOPluginable

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

type WorkerPluginable

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