__ /\_ \ /\_ \
___ /\_\ ___ ___ __ __ ___ \//\ \ ___ __ __ ___ __ \//\ \ __ __ ____ __ _ __
/'___\/\ \ /' _ `\ / __`\/\ \/\ \ / __`\ _______\ \ \ / __`\ /'_ `\ /'__`\ /' _ `\ /'__`\ \ \ \ /\ \/\ \/\_ ,`\ /'__`\/\`'__\
/\ \__/\ \ \/\ \/\ \/\ \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)
return
: Siren - use the siren like this loganalyzer.hook(siren)