Versions in this module Expand all Collapse all v0 v0.0.2 Jan 3, 2025 Changes in this version + func NewIOWorkerPluginFromConsumer(plugin ConsumerIOPluginable) ioWorker + func NewIOWorkerPluginFromProducer(plugin ProducerIOPluginable) ioWorker + func NewIOWorkerPluginFromRunner(plugin RunnerIOPluginable) ioWorker + func NewIOWorkerPluginFromWorker(plugin WorkerPluginable) ioWorker + type ConsumerIOPluginable interface + type IOWorkerPluginable interface + type PluginConfigurer interface + Config func(config []byte) error + GetInputSchema func() ([]byte, error) + type ProducerIOPluginable interface + type RunnerIOPluginable interface + type WorkerPluginable interface
Go to main page