sources

type Definition struct {
	InputDefinition json.RawMessage
	ParserDefition  json.RawMessage
}

type Factory struct {
	// contains filtered or unexported fields
}

type InputFactory interface {
	NewInput(json.RawMessage) (io.ReadCloser, error)
}

type ParserFactory interface {
	NewParser(json.RawMessage) (io.WriteCloser, error)
}

type Source struct {
	// contains filtered or unexported fields
}