Home Identifier Source Repository
import {RumSqsDriver} from 'deep-log/lib/Driver/RumSqsDriver.js'
public class | source

RumSqsDriver

Extends:

lib/Driver/AbstractDriver~AbstractDriver → RumSqsDriver

SQS logging driver

Static Member Summary

Static Public Members
public static get
public static get
public static get

Static Method Summary

Static Public Methods
public static

Constructor Summary

Public Constructor
public

constructor(queueUrl: String, kernel: Object, enabled: Boolean)

Member Summary

Public Members
public get
public get
public get
public get

sqs: AWS.SQS: *

Method Summary

Public Methods
public

deleteMessages(messages: Array, callback: Function)

public

flush(callback: Function)

public

getQueueAttributes(callback: Function, additionalAttributes: Object[])

public

log(message: Object, callback: Function)

public

Static Public Members

public static get BATCH_SIZE: Number: number source

Return:

Number

public static get ES_LOGS_INDEX: String: string source

Return:

String

public static get ES_LOGS_TYPE: String: string source

Return:

String

Static Public Methods

public static getRegionFromSqsQueueUrl(queueUrl: String): String source

Params:

NameTypeAttributeDescription
queueUrl String

Return:

String

Public Constructors

public constructor(queueUrl: String, kernel: Object, enabled: Boolean) source

Params:

NameTypeAttributeDescription
queueUrl String
kernel Object
enabled Boolean

Public Members

public get enabled: Boolean: * source

Return:

Boolean

public get kernel: Object: * source

Return:

Object

public get queueUrl: String: * source

Return:

String

public get sqs: AWS.SQS: * source

Return:

AWS.SQS

Public Methods

public deleteMessages(messages: Array, callback: Function) source

Params:

NameTypeAttributeDescription
messages Array
callback Function

public flush(callback: Function) source

Params:

NameTypeAttributeDescription
callback Function

public getQueueAttributes(callback: Function, additionalAttributes: Object[]) source

Params:

NameTypeAttributeDescription
callback Function
additionalAttributes Object[]

public log(message: Object, callback: Function) source

Params:

NameTypeAttributeDescription
message Object
callback Function

public receiveMessages(callback: Function) source

Params:

NameTypeAttributeDescription
callback Function