Documentation
¶
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCSVDecoder ¶
func NewCSVDecoder(conf engine.DecoderConfig) engine.Decoder
func NewCSVEncoder ¶
func NewCSVEncoder(c engine.EncoderConfig) engine.Encoder
func StringFields ¶
func StringFieldsWithFormat ¶
Types ¶
type CSVDecoder ¶
type CSVDecoder struct {
// contains filtered or unexported fields
}
type CSVEncoder ¶
type CSVEncoder struct {
engine.EncoderConfig
// contains filtered or unexported fields
}
Example ¶
package main
import (
"time"
"github.com/OutOfBedlam/tine/engine"
_ "github.com/OutOfBedlam/tine/plugin/codec/csv"
_ "github.com/OutOfBedlam/tine/plugin/codec/json"
_ "github.com/OutOfBedlam/tine/plugin/inlets/file"
_ "github.com/OutOfBedlam/tine/plugin/outlets/file"
)
func main() {
dsl := `
[log]
level = "warn"
[[inlets.file]]
data = [
"a,1",
"b,2",
"c,3",
]
format = "csv"
[[outlets.file]]
path = "-"
format = "csv"
`
// Mock the current time
count := int64(0)
engine.Now = func() time.Time { count++; return time.Unix(1721954797+count, 0) }
// Create a new pipeline
pipeline, err := engine.New(engine.WithConfig(dsl))
if err != nil {
panic(err)
}
if err := pipeline.Run(); err != nil {
panic(err)
}
}
Output: a,1 b,2 c,3
Source Files
Click to show internal directories.
Click to hide internal directories.