stdstream

Documentation

Index

• func Plugin() plugin.Plugin
• func SinkErr(ctx context.Context, src iterator.Iterator, _ ...*dsl.Arg) error
• func SinkOut(ctx context.Context, src iterator.Iterator, _ ...*dsl.Arg) error
• func SourceIn(ctx context.Context, _ ...*dsl.Arg) (iterator.Iterator, error)

Examples

• SinkOut

Functions

func Plugin

func Plugin() plugin.Plugin

func SinkErr

func SinkErr(ctx context.Context, src iterator.Iterator, _ ...*dsl.Arg) error

func SinkOut

func SinkOut(ctx context.Context, src iterator.Iterator, _ ...*dsl.Arg) error

Example

iter := iterator.FromSlice([]entries.LogEntry{
	{"a": "a"},
	{"b": "b"},
	{"c": "c"},
})
if err := SinkOut(context.Background(), iter); err != nil {
	panic(err)
}

Output:

{"a":"a"}
{"b":"b"}
{"c":"c"}

func SourceIn

func SourceIn(ctx context.Context, _ ...*dsl.Arg) (iterator.Iterator, error)