in cloudwatch/cloudwatch.go [818:830]
func (stream *logStream) logBatchSpan(timestamp time.Time) time.Duration {
if stream.currentBatchStart == nil || stream.currentBatchEnd == nil {
return 0
}
if stream.currentBatchStart.After(timestamp) {
return stream.currentBatchEnd.Sub(timestamp)
} else if stream.currentBatchEnd.Before(timestamp) {
return timestamp.Sub(*stream.currentBatchStart)
}
return stream.currentBatchEnd.Sub(*stream.currentBatchStart)
}