Use Recipe
Imports
Whenever add new type of inlets, flows, outlets and codec, it should be imported. If this is too cumbersome, import all plugins at once.
Define pipeline
Create a pipeline
Start the pipeline
The Start()
function in the code snippet above initiates the pipeline execution but does not wait for it to complete. Instead, it spawns a goroutine by calling go pipeline.Run()
and returns immediately. On the other hand, pipeline.Run()
is a blocking function that waits until the pipeline finishes its execution before returning control.
Last updated