func()

in cloudwatch/cloudwatch.go [434:451]

• 15 lines of code
• 5 McCabe index (conditional complexity)

func (output *OutputPlugin) getLogStream(e *Event) (*logStream, error) {
	stream, ok := output.streams[e.group+e.stream]
	if !ok {
		// stream doesn't exist, create it
		stream, err := output.createStream(e)
		if err != nil {
			if awsErr, ok := err.(awserr.Error); ok {
				if awsErr.Code() == cloudwatchlogs.ErrCodeResourceAlreadyExistsException {
					// existing stream
					return output.existingLogStream(e)
				}
			}
		}
		return stream, err
	}

	return stream, nil
}