Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildSource ¶
func BuildSource(cfg core.Configurator, taskName string) core.Source
`BuildSource` creates a new instance of the source endpoint specified by the configuration object passed as argument.
The `cfg` is the global configuration object. The `taskName` is the name of the task to be executed.
func IsaDatabaseQuerySource ¶
`IsaDatabaseQuerySource` returns true if given source type is an Database Query.
func IsaJSONLFileSource ¶
func NewDatabaseQuerySource ¶
func NewDatabaseQuerySource(cfg core.Configurator, taskName string) core.Source
`NewDatabaseQuerySource` creates a new instance of the Database Source endpoint.
The `cfg` is the global configuration object. The `taskName` is the name of the task to be executed.
Types ¶
type DatabaseQuerySource ¶
type DatabaseQuerySource struct {
// contains filtered or unexported fields
}
`DatabaseQuerySource` is the concrete implementation of the source interface for Oracle databases. It reads data from an Oracle database and sends it to the output processing channel.
type JSONLFileSource ¶
type JSONLFileSource struct {
// contains filtered or unexported fields
}
`JSONLFileSource` is the concrete implementation of the source interface for JSONLines (or NDJSON) file reader. It reads data from a given file(s) in NDJSON format and send each row to the output processing channel.
func NewJSONLFileSource ¶
func NewJSONLFileSource(cfg core.Configurator, taskName string) *JSONLFileSource
`NewJSONLFileSource` creates a new instance of the JSONLines source endpoint.
The `task` is the name of the task to be executed. The `filename` is the name of the file to be read.
Source Files