intf

type Format interface {
	Parse(line string) Record
}

type Input interface {
	GetRecord() Record
	IsEOF() bool
	Teardown()
}

type Output interface {
	PutRecord(record Record) bool
}

type PostProcessor interface {
	SetChannel(channel chan Record)
	Do(record Record) bool
	Teardown()
}

type PreProcessor interface {
	Do(line string)
}

type Record map[string]interface{}

type Writer interface {
	IsAlive() bool
	Setup()
	Boot()
	GetCounters() (int32, int32, int32, int32)
	ResetCounters()
	Teardown()
}