stdin

Documentation

Overview

Receives flows from stdin in JSON format, as exported by the json segment. This segment can also read from a file with flows in json format per each line

Index

• type StdIn
  • func (segment StdIn) New(config map[string]string) segments.Segment
  • func (segment *StdIn) Run(wg *sync.WaitGroup)

Types

type StdIn

type StdIn struct {
	segments.BaseSegment

	FileName  string // optional, default is empty which means read from stdin
	EofCloses bool   // optional, default is false. Closes Pipeleine gracefully after input file was read
	// contains filtered or unexported fields
}

func (StdIn) New

func (segment StdIn) New(config map[string]string) segments.Segment

func (*StdIn) Run

func (segment *StdIn) Run(wg *sync.WaitGroup)