in cloudwatch/cloudwatch.go [800:812]
func (output *OutputPlugin) processRejectedEventsInfo(response *cloudwatchlogs.PutLogEventsOutput) {
if response.RejectedLogEventsInfo != nil {
if response.RejectedLogEventsInfo.ExpiredLogEventEndIndex != nil {
logrus.Warnf("[cloudwatch %d] %d log events were marked as expired by CloudWatch\n", output.PluginInstanceID, aws.Int64Value(response.RejectedLogEventsInfo.ExpiredLogEventEndIndex))
}
if response.RejectedLogEventsInfo.TooNewLogEventStartIndex != nil {
logrus.Warnf("[cloudwatch %d] %d log events were marked as too new by CloudWatch\n", output.PluginInstanceID, aws.Int64Value(response.RejectedLogEventsInfo.TooNewLogEventStartIndex))
}
if response.RejectedLogEventsInfo.TooOldLogEventEndIndex != nil {
logrus.Warnf("[cloudwatch %d] %d log events were marked as too old by CloudWatch\n", output.PluginInstanceID, aws.Int64Value(response.RejectedLogEventsInfo.TooOldLogEventEndIndex))
}
}
}