kronos-interceptor-object-data-processor-chunk

Splits a line by a sparator into tokens

API

Table of Contents

• ChunkProcessorInterceptor
  • Parameters
• stream
• constructor
  • Parameters
• addRowActions
  • Parameters
• _transform
  • Parameters
• _flush
  • Parameters
• addError
  • Parameters
• createTmpHashAction
  • Parameters
• createFunctions
  • Parameters
• createHashFunction
  • Parameters
• record
  • Parameters

ChunkProcessorInterceptor

Extends Interceptor

This interceptor cares about the handling of the messages. It will add the hops and copies the messages

Parameters

• config
• endpoint

stream

This module will turn an array of tokens into an object.

constructor

Parameters

• opts
• validate

addRowActions

Add custom actions to the rowActions. These actions will be executed per row

Parameters

• actions

_transform

Reads the stream data and split it into lines.

Parameters

• data
• enc
• cb

_flush

Flushes the data. Only needed if there are multi row fields used

Parameters

• cb

addError

Adds an error to the stream data

Parameters

• data The current stream data
• error The error to be added.

createTmpHashAction

Creates a hash function to compute a content hash without the multirow fields

Parameters

• contentHashFields
• multiRowFields

createFunctions

Creates the checks for checking boolean values

Parameters

• chunkDefinition The chunk definition for these records.

createHashFunction

Creates a function which generates a hash from the given content and stores the generated Hash under the given name in the record

Parameters

• hashFields All the field names used to create the hash
• hashName The name to be used to store the hash value back in the record

record

The function gerates the hash for the given record

Parameters

• record The record to create the hash for

install

With npm do:

npm install kronos-interceptor-object-data-processor-chunk

license

BSD-2-Clause