fileparser_action

package

v0.0.0-...-f514c2e Latest Latest Go to latest Published: Feb 1, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/The-New-Fork/pipeline

README ¶

File parser action

Input

The input map can contain the following values:

Key	Description	Allowed values
Filetype	The type of file to parse	"csv"
File	Raw file as byte array ([]byte)	Any []byte
Header	Indicate whether a CSV file contains a header. If it does the result will contain the keys.	true or false (optional)

Output

Messages: The output of the file parser action is a map with messages. Messages contains an array of map[string]interface{}.

CSV

In case the CSV does not contain headers the result will be put in a map based on the order of the columns. The keys in the map will be the column number prefixed with 'col-', e.g. the first column of a csv file without headers will be part of a message output map under the key 'col-1'.

Documentation ¶

Index ¶

Constants
func Invoke(stub domain.Stub, input map[string]interface{}) (output map[string]interface{}, err error)
func ParseCsv(stub domain.Stub, rawFile []byte, header bool, delimiter rune) (map[string]interface{}, error)
func ParseJson(logger logger.Logger, rawJson []byte) (map[string]interface{}, error)

Constants ¶

View Source

const (
	FileType  = "filetype"
	File      = "file"
	Header    = "header"
	Delimiter = "delimiter"
)

Variables ¶

This section is empty.

Functions ¶

func Invoke ¶

func Invoke(stub domain.Stub, input map[string]interface{}) (output map[string]interface{}, err error)

func ParseCsv ¶

func ParseCsv(stub domain.Stub, rawFile []byte, header bool, delimiter rune) (map[string]interface{}, error)

func ParseJson ¶

func ParseJson(logger logger.Logger, rawJson []byte) (map[string]interface{}, error)

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL