virtual KinesisManagerStatus Install()

in kinesis_manager/include/kinesis_manager/stream_subscription_installer.h [56:68]

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

  virtual KinesisManagerStatus Install(const StreamSubscriptionDescriptor & descriptor) const
  {
    if (descriptor.topic_name.empty() || descriptor.stream_name.empty()) {
      return KINESIS_MANAGER_STATUS_INVALID_INPUT;
    }
    if (0 == installers_.count(descriptor.input_type)) {
      return KINESIS_MANAGER_STATUS_SUBSCRIPTION_INSTALLER_NOT_FOUND;
    }

    bool result = installers_.at(descriptor.input_type)(descriptor);
    return result ? KINESIS_MANAGER_STATUS_SUCCESS
                  : KINESIS_MANAGER_STATUS_SUBSCRIPTION_INSTALLATION_FAILED;
  }