in cloudwatch/cloudwatch.go [489:504]
func (output *OutputPlugin) describeLogStreams(e *Event, nextToken *string) (*cloudwatchlogs.DescribeLogStreamsOutput, error) {
output.timer.Check()
resp, err := output.client.DescribeLogStreams(&cloudwatchlogs.DescribeLogStreamsInput{
LogGroupName: aws.String(e.group),
LogStreamNamePrefix: aws.String(e.stream),
NextToken: nextToken,
})
if err != nil {
output.timer.Start()
return nil, err
}
output.timer.Reset()
return resp, err
}