constants.js

OK = 'OK';
ERROR = 'ERROR';
FORWARD_TO_FIREHOSE_STREAM = "ForwardToFirehoseStream";
DDB_SERVICE_NAME = "aws:dynamodb";
KINESIS_SERVICE_NAME = "aws:kinesis";
FIREHOSE_MAX_BATCH_COUNT = 500;
// firehose max PutRecordBatch size 4MB
FIREHOSE_MAX_BATCH_BYTES = 4 * 1000 * 1000;
MAX_RETRY_ON_FAILED_PUT = process.env['MAX_RETRY_ON_FAILED_PUT'] || 3;
RETRY_INTERVAL_MS = process.env['RETRY_INTERVAL_MS'] || 300;
TRANSFORMER_FUNCTION_ENV = 'UseTransformer';
STREAM_DATATYPE_ENV = 'StreamDatatype';
targetEncoding = "utf8";
transformerRegistry = {
    doNothingTransformer : "doNothingTransformer",
    addNewlineTransformer : "addNewlineTransformer",
    jsonToStringTransformer : "jsonToStringTransformer",
    regexToDelimiter : "regexToDelimiter"
};
supportedDatatypeTransformerMappings = {
    JSON : transformerRegistry.jsonToStringTransformer,
    CSV : transformerRegistry.addNewlineTransformer,
    BINARY : transformerRegistry.doNothingTransformer,
    "CSV-WITH-NEWLINES" : transformerRegistry.doNothingTransformer
}