Package org.graylog.integrations.aws.cloudwatch

Class CloudWatchLogSubscriptionData

java.lang.Object

org.graylog.integrations.aws.cloudwatch.CloudWatchLogSubscriptionData

public abstract class CloudWatchLogSubscriptionData
extends Object

A collection of CloudWatch log events that was generated by a Kinesis CloudWatch log subscription. See for more info: https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/Subscriptions.html

Example payload:

 {
   "messageType": "DATA_MESSAGE",
   "owner": "123456789",
   "logGroup": "aws-plugin-test-flows",
   "logStream": "eni-aaaaaaaa-all",
   "subscriptionFilters": ["match-all"],
   "logEvents": [
     {
       "id": "33503748002479370955346306650196094071913271643270021120",
       "timestamp": 1502360020000,
       "message": "2 123456789 eni-aaaaaaaa 10.0.27.226 10.42.96.199 3604 17720 17 1 132 1502360020 1502360079 REJECT OK"
     },
     {
       "id": "33503748002479370955346306650196094071913271643270021127",
       "timestamp": 1502360020000,
       "message": "2 123456789 eni-aaaaaaaa 10.0.34.113 10.42.96.199 53421 17720 6 1 48 1502360020 1502360079 REJECT OK"
     }
   ]
 }
 

Constructor Summary

Constructors

Constructor	Description
CloudWatchLogSubscriptionData()

Method Summary

Modifier and Type	Method	Description
static CloudWatchLogSubscriptionData	create(String messageType, String owner, String logGroup, String logStream, List<String> subscriptionFilters, List<CloudWatchLogEvent> logEvents)
abstract List<CloudWatchLogEvent>	logEvents()
abstract String	logGroup()
abstract String	logStream()
abstract String	messageType()
abstract String	owner()
abstract List<String>	subscriptionFilters()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CloudWatchLogSubscriptionData

public CloudWatchLogSubscriptionData()

Method Details

messageType

public abstract String messageType()

owner

public abstract String owner()

logGroup

public abstract String logGroup()

logStream

public abstract String logStream()

subscriptionFilters

public abstract List<String> subscriptionFilters()

logEvents

public abstract List<CloudWatchLogEvent> logEvents()

create

public static CloudWatchLogSubscriptionData create(String messageType,
 String owner,
 String logGroup,
 String logStream,
 List<String> subscriptionFilters,
 List<CloudWatchLogEvent> logEvents)