code: func (l *logStream) Log(msg *logger.Message) error {
  	l.lock.RLock()
  	defer l.lock.RUnlock()
  	if l.closed {
  		return errors.New("awslogs is closed")
  	}
  	if l.logNonBlocking {
  		select {
  		case l.messages <- msg:
  			return nil
  		default:
  			return errors.New("awslogs buffer is full")
  		}
  	}
  	l.messages <- msg
  	return nil
  }
docs: // Log submits messages for logging by an instance of the awslogs logging driver