relay

type ElasticsearchIndexer struct {
	Index    func(item interface{}) string
	Type     func(item interface{}) *string
	Id       func(item interface{}) *string
	BodyJson func(item interface{}) interface{}
}

type Emitter interface {
	scaffold.Contextualizer
	Emit(item interface{}) error
	Flush() error
}