Method Start

cpp/src/arrow/filesystem/s3_test_util.cc:112–154

}

Status MinioTestServer::Start(bool enable_tls) {
  const char* connect_str = std::getenv(kEnvConnectString);
  const char* access_key = std::getenv(kEnvAccessKey);
  const char* secret_key = std::getenv(kEnvSecretKey);
  if (connect_str && access_key && secret_key) {
    // Use external instance
    impl_->connect_string_ = connect_str;
    impl_->access_key_ = access_key;
    impl_->secret_key_ = secret_key;
    return Status::OK();
  }

  ARROW_ASSIGN_OR_RAISE(impl_->temp_dir_, TemporaryDir::Make("s3fs-test-"));

  impl_->server_process_ = std::make_unique<util::Process>();
  impl_->server_process_->SetEnv("MINIO_ACCESS_KEY", kMinioAccessKey);
  impl_->server_process_->SetEnv("MINIO_SECRET_KEY", kMinioSecretKey);
  // Disable the embedded console (one less listening address to care about)
  impl_->server_process_->SetEnv("MINIO_BROWSER", "off");
  // NOTE: --quiet makes startup faster by suppressing remote version check
  std::vector<std::string> minio_args({"server", "--quiet", "--compat"});
  if (enable_tls) {
    ARROW_RETURN_NOT_OK(GenerateCertificateFile());
    minio_args.emplace_back("--certs-dir");
    minio_args.emplace_back(ca_dir_path());
    impl_->scheme_ = "https";
    // With TLS enabled, we need the connection hostname to match the certificate's
    // subject name. This also constrains the actual listening IP address.
    impl_->connect_string_ = GetListenAddress("localhost");
  } else {
    // Without TLS enabled, we want to minimize the likelihood of address collisions
    // by varying the listening IP address (note that most tests don't enable TLS).
    impl_->connect_string_ = GetListenAddress();
  }
  minio_args.emplace_back("--address");
  minio_args.emplace_back(impl_->connect_string_);
  minio_args.emplace_back(impl_->temp_dir_->path().ToString());

  ARROW_RETURN_NOT_OK(impl_->server_process_->SetExecutable(kMinioExecutableName));
  impl_->server_process_->SetArgs(minio_args);
  ARROW_RETURN_NOT_OK(impl_->server_process_->Execute());
  return Status::OK();
}

Status MinioTestServer::Stop() {
  impl_->server_process_ = nullptr;