cinovo-loganalyzer-aws

       __                                         /\_ \                                            /\_ \
  ___ /\_\    ___     ___   __  __    ___         \//\ \     ___      __      __      ___      __  \//\ \    __  __  ____      __   _ __
 /'___\/\ \ /' _ `\  / __`\/\ \/\ \  / __`\  _______\ \ \   / __`\  /'_ `\  /'__`\  /' _ `\  /'__`\  \ \ \  /\ \/\ \/\_ ,`\  /'__`\/\`'__\
/\ \__/\ \ \/\ \/\ \/\ \L\ \ \ \_/ |/\ \L\ \/\______\\_\ \_/\ \L\ \/\ \L\ \/\ \L\.\_/\ \/\ \/\ \L\.\_ \_\ \_\ \ \_\ \/_/  /_/\  __/\ \ \/
\ \____\\ \_\ \_\ \_\ \____/\ \___/ \ \____/\/______//\____\ \____/\ \____ \ \__/.\_\ \_\ \_\ \__/.\_\/\____\\/`____ \/\____\ \____\\ \_\
 \/____/ \/_/\/_/\/_/\/___/  \/__/   \/___/          \/____/\/___/  \/___L\ \/__/\/_/\/_/\/_/\/__/\/_/\/____/ `/___/> \/____/\/____/ \/_/
                                                                      /\____/                                    /\___/
                                                                      \_/__/                                     \/__/

cinovo-loganalyzer-aws

AWS SQS sourcepoint and SNS siren for cinovo-loganalyzer.

API

sourcepoint.sqs(cfg)

Sync creates an SQS sourcepoint.

• cfg: Object ** region: String - your AWS region ** queueUrl: String - the URL of the SQS queue to take action on ** accessKeyId: String - your AWS access key ID (optional) ** secretAccessKey: String - your AWS secret access key (optional)

return: Sourcepoint - use the sourcepoint like this loganalyzer.connect(sourcepoint, callback)

Events

consume()

We start to consume messages.

consumed(consumeTime)

We consumed some messages.

• consumeTime: Number - consume time in ms

siren.sns(cfg)

Sync crated an SNS siren.

• cfg: Object ** region: String - your AWS region ** topicArn: String - the topic you want to publish to ** accessKeyId: String - your AWS access key ID (optional) ** secretAccessKey: String - your AWS secret access key (optional) ** batchMaxSize: Number - (default 10) ** batchMaxAge: Number - in seconds (default 10)

return: Siren - use the siren like this loganalyzer.hook(siren)