Use Recipe

Imports

import (
    github.com/OutOfBedlam/tine/engine
    _ github.com/OutOfBedlam/tine/plugins/base
    _ github.com/OutOfBedlam/tine/plugins/psutil
)

Whenever add new type of inlets, flows, outlets and codec, it should be imported. If this is too cumbersome, import all plugins at once.

import (
    github.com/OutOfBedlam/tine/engine
    _ github.com/OutOfBedlam/tine/plugins/all
)

Define pipeline

const pipelineRecipe = `
[[inlets.cpu]]
	interval = "3s"
[[flows.select]]
	includes = ["#_ts", "*"]
[[outlets.file]]
	format = "json"
	decimal = 2
`

Create a pipeline

pipeline, err := engine.New(engine.WithConfig(pipelineRecipe))

Start the pipeline

pipeline.Start()

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.