code: func (l *logStream) createLogStream() error {
  	input := &cloudwatchlogs.CreateLogStreamInput{
  		LogGroupName:  aws.String(l.logGroupName),
  		LogStreamName: aws.String(l.logStreamName),
  	}
  
  	_, err := l.client.CreateLogStream(input)
  
  	if err != nil {
  		if awsErr, ok := err.(awserr.Error); ok {
  			fields := logrus.Fields{
  				"errorCode":     awsErr.Code(),
  				"message":       awsErr.Message(),
  				"origError":     awsErr.OrigErr(),
  				"logGroupName":  l.logGroupName,
  				"logStreamName": l.logStreamName,
  			}
  			if awsErr.Code() == resourceAlreadyExistsCode {
  				// Allow creation to succeed
  				logrus.WithFields(fields).Info("Log stream already exists")
  				return nil
  			}
  			logrus.WithFields(fields).Error("Failed to create log stream")
  		}
  	}
  	return err
  }
docs: // createLogStream creates a log stream for the instance of the awslogs logging driver